#326 Improve testing adapter

dvoraka · Jul 10, 2019 · 8817d08 · 8817d08
1 parent d820405
commit 8817d08
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 2 deletions.
diff --git a/client/src/main/java/dvoraka/avservice/client/transport/test/TestingReplicationAdapter.java b/client/src/main/java/dvoraka/avservice/client/transport/test/TestingReplicationAdapter.java
@@ -48,4 +48,9 @@ public void send(ReplicationMessage message) {
             broker.send(message.getToId(), message);
         }
     }
+
+    @Override
+    public void onMessage(ReplicationMessage message) {
+        log.debug("On message ({}): {}", nodeId, message);
+    }
 }
diff --git a/...ge/src/test/groovy/dvoraka/avservice/storage/replication/NewReplicationServiceSpec.groovy b/...ge/src/test/groovy/dvoraka/avservice/storage/replication/NewReplicationServiceSpec.groovy
@@ -5,10 +5,11 @@ import dvoraka.avservice.client.transport.test.DefaultSimpleBroker
 import dvoraka.avservice.client.transport.test.SimpleBroker
 import dvoraka.avservice.client.transport.test.TestingReplicationAdapter
 import dvoraka.avservice.common.data.replication.ReplicationMessage
+import dvoraka.avservice.common.helper.replication.ReplicationHelper
 import spock.lang.Shared
 import spock.lang.Specification
 
-class NewReplicationServiceSpec extends Specification {
+class NewReplicationServiceSpec extends Specification implements ReplicationHelper {
 
     @Shared
     String nodeId1 = "testNode1"
@@ -33,10 +34,12 @@ class NewReplicationServiceSpec extends Specification {
         service1 = new NewReplicationService(component1)
 
         broker.addMessageListener(component1, nodeId1)
+
+        broker.addMessageListener(component1, broadcastKey)
     }
 
     def "test"() {
         expect:
-            component1
+            component1.send(createDiscoverRequest(nodeId1))
     }
 }