aboutsummaryrefslogtreecommitdiff
path: root/src/main/java/io/trygvis/esper/testing/gitorious/GitoriousProjectDiscovery.java
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/java/io/trygvis/esper/testing/gitorious/GitoriousProjectDiscovery.java')
-rwxr-xr-xsrc/main/java/io/trygvis/esper/testing/gitorious/GitoriousProjectDiscovery.java7
1 files changed, 4 insertions, 3 deletions
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<GitoriousRepositoryDto, ActorRef<GitoriousRepository>> repositoryManager = new ObjectManager<>("", repositories, new ObjectFactory<GitoriousRepositoryDto, ActorRef<GitoriousRepository>>() {
public ActorRef<GitoriousRepository> 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);