DATAGO-75198 pr comments

SolaceProducts · Jun 27, 2024 · 2ba49c3 · 2ba49c3
1 parent 91b9cd6
commit 2ba49c3
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/.../com/solace/maas/ep/event/management/agent/subscriber/SolacePersistentMessageHandler.java b/.../com/solace/maas/ep/event/management/agent/subscriber/SolacePersistentMessageHandler.java
@@ -72,7 +72,12 @@ public void onMessage(InboundMessage inboundMessage) {
         } catch (Exception e) {
             if (processor != null && message != null) {
                 log.error("Error while processing inbound message from queue for mopMessageSubclass: {}", mopMessageSubclass);
-                processor.onFailure(e, processor.castToMessageClass(message));
+                try {
+                    processor.onFailure(e, processor.castToMessageClass(message));
+                } catch (Exception e1) {
+                    log.error("error while handling message processing failure for mopMessageSubclass: {}", mopMessageSubclass, e);
+                }
+
             } else {
                 log.error("Unsupported message and/or processor encountered. Skipping processing", e);
             }