fixed duplicated messages in backend when receiving via websocket

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
eclipse-ditto · Dec 18, 2017 · 5e9e59c · 5e9e59c
1 parent 76d0152
commit 5e9e59c
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/.../main/java/org/eclipse/ditto/services/gateway/streaming/actors/StreamingSessionActor.java b/.../main/java/org/eclipse/ditto/services/gateway/streaming/actors/StreamingSessionActor.java
@@ -119,7 +119,11 @@ public Receive createReceive() {
                 /* Live Signals */
                 // publish all those live signals which were issued by this session into the cluster
                 .match(Signal.class, signal -> isLiveSignal(signal) && wasIssuedByThisSession(signal) &&
-                                (signal instanceof MessageCommand || signal instanceof MessageCommandResponse),
+                                (signal instanceof MessageCommand),
+                        signal -> logger.debug("Don't publishing message again - was already published: <{}>", signal)
+                )
+                .match(Signal.class, signal -> isLiveSignal(signal) && wasIssuedByThisSession(signal) &&
+                                (signal instanceof MessageCommandResponse),
                         publishLiveSignal(StreamingType.MESSAGES.getDistributedPubSubTopic())
                 )
                 .match(Signal.class, signal -> isLiveSignal(signal) && wasIssuedByThisSession(signal) &&