Increase test coverage of actorsystem module
diff --git a/stack/corepersistence/actorsystem/pom.xml b/stack/corepersistence/actorsystem/pom.xml
index 85c0d60..b77f90f 100644
--- a/stack/corepersistence/actorsystem/pom.xml
+++ b/stack/corepersistence/actorsystem/pom.xml
@@ -94,6 +94,13 @@
<scope>test</scope>
</dependency>
+ <dependency>
+ <groupId>org.mockito</groupId>
+ <artifactId>mockito-core</artifactId>
+ <version>${mockito.version}</version>
+ <scope>test</scope>
+ </dependency>
+
</dependencies>
</project>
diff --git a/stack/corepersistence/actorsystem/src/test/java/org/apache/usergrid/persistence/actorsystem/ActorServiceServiceTest.java b/stack/corepersistence/actorsystem/src/test/java/org/apache/usergrid/persistence/actorsystem/ActorServiceServiceTest.java
index a12c5e1..7ac7b12 100644
--- a/stack/corepersistence/actorsystem/src/test/java/org/apache/usergrid/persistence/actorsystem/ActorServiceServiceTest.java
+++ b/stack/corepersistence/actorsystem/src/test/java/org/apache/usergrid/persistence/actorsystem/ActorServiceServiceTest.java
@@ -24,11 +24,17 @@
import org.junit.Before;
import org.junit.Test;
import org.junit.runner.RunWith;
+import org.mockito.Mockito;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+
import java.util.concurrent.atomic.AtomicBoolean;
+import static org.mockito.Matchers.any;
+import static org.mockito.Matchers.eq;
+import static org.mockito.Mockito.verify;
+
@RunWith( ITRunner.class )
@UseModules( ActorSystemModule.class )
@@ -38,20 +44,31 @@
@Inject
ActorSystemFig actorSystemFig;
+ @Inject
+ ActorSystemManager actorSystemManager;
+
+
private static AtomicBoolean startedAkka = new AtomicBoolean( false );
- @Before
- public void initAkka() {
- if ( !startedAkka.getAndSet( true ) ) {
- }
- }
-
-
@Test
public void testBasicOperation() throws Exception {
- initAkka();
- }
+ RouterProducer routerProducer = Mockito.mock( RouterProducer.class );
+ actorSystemManager.registerRouterProducer( routerProducer );
+
+ actorSystemManager.registerMessageType( String.class, "/users/path" );
+ actorSystemManager.registerMessageType( Integer.class, "/users/path" );
+ actorSystemManager.registerMessageType( Long.class, "/users/path" );
+
+ actorSystemManager.start( "localhost", 2770, "us-east" );
+ actorSystemManager.waitForClientActor();
+
+ verify( routerProducer ).createClusterSingletonManager( any() );
+ verify( routerProducer ).createClusterSingletonProxy( any(), eq("io") );
+ verify( routerProducer ).createLocalSystemActors( any() );
+ verify( routerProducer ).addConfiguration( any() );
+
+ }
}
