import akka.actor.Props;
import akka.actor.UntypedActor;
import akka.testkit.JavaTestKit;
-import org.junit.After;
-import org.junit.Before;
-import org.junit.Test;
-import scala.concurrent.duration.FiniteDuration;
-
+import com.typesafe.config.Config;
+import com.typesafe.config.ConfigFactory;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.ReentrantLock;
+import org.junit.AfterClass;
+import org.junit.BeforeClass;
+import org.junit.Test;
+import scala.concurrent.duration.FiniteDuration;
public class MeteredBoundedMailboxTest {
private static CommonConfig config;
private final ReentrantLock lock = new ReentrantLock();
- @Before
- public void setUp() throws Exception {
- config = new CommonConfig.Builder<>("testsystem").build();
+ @BeforeClass
+ public static void setUp() throws Exception {
+ config = new CommonConfig.Builder<>("testsystem").withConfigReader(new AkkaConfigurationReader() {
+ @Override
+ public Config read() {
+ return ConfigFactory.load();
+ }
+ }).build();
actorSystem = ActorSystem.create("testsystem", config.get());
}
- @After
- public void tearDown() throws Exception {
- if (actorSystem != null)
- actorSystem.shutdown();
+ @AfterClass
+ public static void tearDown() throws Exception {
+ if (actorSystem != null) {
+ actorSystem.terminate();
+ actorSystem = null;
+ }
}
@Test
ReentrantLock lock;
- private PingPongActor(ReentrantLock lock){
+ private PingPongActor(final ReentrantLock lock){
this.lock = lock;
}
}
@Override
- public void onReceive(Object message) throws Exception {
+ public void onReceive(final Object message) throws Exception {
lock.lock();
try {
- if ("ping".equals(message))
+ if ("ping".equals(message)) {
getSender().tell("pong", getSelf());
+ }
} finally {
lock.unlock();
}