diff options
author | Trygve Laugstøl <trygvis@inamo.no> | 2012-11-24 18:02:55 +0100 |
---|---|---|
committer | Trygve Laugstøl <trygvis@inamo.no> | 2012-11-24 18:02:55 +0100 |
commit | e243a6fd6c444b451398ceb659ea4963a19122d0 (patch) | |
tree | 532ca0710468deee4e6fa076546a2d53f1cff498 /src/main/java/io/trygvis/esper/testing/object | |
parent | cac8228f38136cfc41673458c58c25f168b1e1ff (diff) | |
download | esper-testing-e243a6fd6c444b451398ceb659ea4963a19122d0.tar.gz esper-testing-e243a6fd6c444b451398ceb659ea4963a19122d0.tar.bz2 esper-testing-e243a6fd6c444b451398ceb659ea4963a19122d0.tar.xz esper-testing-e243a6fd6c444b451398ceb659ea4963a19122d0.zip |
o Actually storing and deleting new/gone artifacts from Nexus.
Diffstat (limited to 'src/main/java/io/trygvis/esper/testing/object')
-rw-r--r-- | src/main/java/io/trygvis/esper/testing/object/ObjectUtil.java | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/src/main/java/io/trygvis/esper/testing/object/ObjectUtil.java b/src/main/java/io/trygvis/esper/testing/object/ObjectUtil.java index 6b6fe75..2d23822 100644 --- a/src/main/java/io/trygvis/esper/testing/object/ObjectUtil.java +++ b/src/main/java/io/trygvis/esper/testing/object/ObjectUtil.java @@ -6,8 +6,8 @@ import java.sql.*; public class ObjectUtil { - public static <A extends TransactionalActor> ActorRef<A> threadedActor(DataSource dataSource, long delay, A actor) { - return new ThreadedActor<>(dataSource, actor, delay); + public static <A extends TransactionalActor> ActorRef<A> threadedActor(DataSource dataSource, String threadName, long delay, A actor) { + return new ThreadedActor<>(dataSource, threadName, actor, delay); } static class ThreadedActor<A extends TransactionalActor> implements ActorRef<A>, Runnable, Closeable { @@ -18,11 +18,11 @@ public class ObjectUtil { private final Thread thread; private boolean shouldRun = true; - ThreadedActor(DataSource dataSource, A actor, long delay) { + ThreadedActor(DataSource dataSource, String threadName, A actor, long delay) { this.dataSource = dataSource; this.actor = actor; this.delay = delay; - thread = new Thread(this); + thread = new Thread(this, threadName); thread.setDaemon(true); thread.start(); } @@ -43,6 +43,7 @@ public class ObjectUtil { } } } catch (Exception e) { + System.out.println("Exception in thread " + Thread.currentThread().getName()); e.printStackTrace(System.out); } |