#1619 adjusted monitor to use in OutboundMappingProcessorActor#messag…

…eDiscarded * to not use `responseDispatchedMonitor`, but getMonitorsForOutboundSignal() with using `responseMappedMonitor` instead for responses Signed-off-by: Thomas Jäckle <thomas.jaeckle@beyonnex.io>
eclipse-ditto · May 4, 2023 · f57e41f · f57e41f
1 parent 316edf6
commit f57e41f
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 5 deletions.
diff --git a/.../java/org/eclipse/ditto/connectivity/service/messaging/OutboundMappingProcessorActor.java b/.../java/org/eclipse/ditto/connectivity/service/messaging/OutboundMappingProcessorActor.java
@@ -349,13 +349,21 @@ protected OutboundSignalWithSender mapMessage(final OutboundSignal message) {
     }
 
     @Override
-    protected void messageDiscarded(OutboundSignal message,  QueueOfferResult result) {
+    protected void messageDiscarded(final OutboundSignal message, final QueueOfferResult result) {
+        final Set<ConnectionMonitor> monitorsForOutboundSignal =
+                getMonitorsForOutboundSignal(message, MAPPED, LogType.MAPPED, responseMappedMonitor);
         if (QueueOfferResult.dropped().equals(result)) {
-            responseDispatchedMonitor.failure(message.getSource(), "Message is dropped as a result of backpressure strategy!");
+            monitorsForOutboundSignal.forEach(monitor ->
+                    monitor.failure(message.getSource(), "Message is dropped as a result of backpressure strategy!")
+            );
         } else if (result instanceof final QueueOfferResult.Failure failure) {
-            responseDispatchedMonitor.failure(message.getSource(), "Enqueue failed! - failure: {}", failure.cause());
+            monitorsForOutboundSignal.forEach(monitor ->
+                    monitor.failure(message.getSource(), "Enqueue failed! - failure: {}", failure.cause())
+            );
         } else {
-            responseDispatchedMonitor.failure(message.getSource(), "Enqueue failed without acknowledgement!");
+            monitorsForOutboundSignal.forEach(monitor ->
+                    monitor.failure(message.getSource(), "Enqueue failed without acknowledgement!")
+            );
         }
     }
 

diff --git a/...a/org/eclipse/ditto/connectivity/service/messaging/OutboundMappingProcessorActorTest.java b/...a/org/eclipse/ditto/connectivity/service/messaging/OutboundMappingProcessorActorTest.java
@@ -63,11 +63,11 @@
 import akka.testkit.TestProbe;
 import akka.testkit.javadsl.TestKit;
 
-@FixMethodOrder(MethodSorters.DEFAULT)
 /**
  * Tests in addition to {@link MessageMappingProcessorActorTest}
  * for {@link OutboundMappingProcessorActor} only.
  */
+@FixMethodOrder(MethodSorters.DEFAULT)
 public final class OutboundMappingProcessorActorTest {
 
     @ClassRule