do not retry connectivity commands in EdgeCommandForwarderActor

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
eclipse-ditto · Jun 21, 2022 · bd0420d · bd0420d
1 parent 543481a
commit bd0420d
Showing 1 changed file with 2 additions and 8 deletions.
diff --git a/...e/src/main/java/org/eclipse/ditto/edge/service/dispatching/EdgeCommandForwarderActor.java b/...e/src/main/java/org/eclipse/ditto/edge/service/dispatching/EdgeCommandForwarderActor.java
@@ -188,14 +188,8 @@ private void forwardToConnectivity(final ConnectivityCommand<?> connectivityComm
                                                 "shard region", withEntityId.getEntityId(),
                                         transformedConnectivityCommand.getType());
 
-                        if (isIdempotent(transformedConnectivityCommand)) {
-                            askWithRetryCommandForwarder.forwardCommand(transformedConnectivityCommand,
-                                    shardRegions.connections(),
-                                    sender);
-                        } else {
-                            shardRegions.connections().tell(transformedConnectivityCommand, sender);
-                        }
-
+                        // don't retry connectivity commands
+                        shardRegions.connections().tell(transformedConnectivityCommand, sender);
                     });
         } else {
             log.withCorrelationId(connectivityCommand)