From 1c2c16858e95db9ae90726fa0da69b88457c1807 Mon Sep 17 00:00:00 2001 From: Trygve Laugstøl Date: Wed, 5 Dec 2012 13:09:49 +0100 Subject: o More common XML parsing and HTTP client code. o Reimplemented the Nexus code to consume the timeline instead of calculating its own diff. --- .../trygvis/esper/testing/gitorious/GitoriousProjectDiscovery.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) (limited to 'src/main/java/io/trygvis/esper/testing/gitorious') diff --git a/src/main/java/io/trygvis/esper/testing/gitorious/GitoriousProjectDiscovery.java b/src/main/java/io/trygvis/esper/testing/gitorious/GitoriousProjectDiscovery.java index a236e45..9bafc17 100755 --- a/src/main/java/io/trygvis/esper/testing/gitorious/GitoriousProjectDiscovery.java +++ b/src/main/java/io/trygvis/esper/testing/gitorious/GitoriousProjectDiscovery.java @@ -10,6 +10,7 @@ import io.trygvis.esper.testing.object.ObjectManager; import io.trygvis.esper.testing.object.ObjectUtil; import io.trygvis.esper.testing.object.TransactionalActor; +import io.trygvis.esper.testing.util.*; import static java.lang.System.*; import org.apache.abdera.parser.*; @@ -31,7 +32,7 @@ public class GitoriousProjectDiscovery { public GitoriousProjectDiscovery(final Config config) throws Exception { boneCp = config.createBoneCp(); - gitoriousClient = new GitoriousClient(HttpClient.createHttpClient(config), config.gitorious.url); + gitoriousClient = new GitoriousClient(HttpClient.createHttpCache(config), config.gitorious.url); final ScheduledThreadPoolExecutor service = new ScheduledThreadPoolExecutor(1); @@ -44,11 +45,11 @@ public class GitoriousProjectDiscovery { final ObjectManager> repositoryManager = new ObjectManager<>("", repositories, new ObjectFactory>() { public ActorRef create(GitoriousRepositoryDto repository) { - return ObjectUtil.scheduledActorWithFixedDelay(service, 0, 60, TimeUnit.SECONDS, boneCp, new GitoriousRepository(gitoriousClient, repository)); + return ObjectUtil.scheduledActorWithFixedDelay(service, 0, 60, TimeUnit.SECONDS, boneCp, "Gitorious", new GitoriousRepository(gitoriousClient, repository)); } }); - ObjectUtil.scheduledActorWithFixedDelay(service, config.gitorious.projectListUpdateDelay, config.gitorious.projectListUpdateInterval, TimeUnit.MILLISECONDS, boneCp, new TransactionalActor() { + ObjectUtil.scheduledActorWithFixedDelay(service, config.gitorious.projectListUpdateDelay, config.gitorious.projectListUpdateInterval, TimeUnit.MILLISECONDS, boneCp, "Gitorious", new TransactionalActor() { @Override public void act(Connection c) throws Exception { Daos daos = new Daos(c); -- cgit v1.2.3