Github user michaelandrepearce commented on a diff in the pull request:
https://github.com/apache/activemq-artemis/pull/2258#discussion_r211868062
--- Diff:
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/plugin/ActiveMQServerMessagePlugin.java
---
@@ -128,6 +143,21 @@ default void afterMessageRoute(Message message,
RoutingContext context, boolean
}
+ /**
+ * When there was an error routing the message
+ *
+ * @param message
+ * @param context
+ * @param direct
+ * @param rejectDuplicates
+ * @param e the exception that occurred during message routing
+ * @throws ActiveMQException
+ */
+ default void onMessageRouteError(Message message, RoutingContext
context, boolean direct, boolean rejectDuplicates,
--- End diff --
Nit: onMessageRouteException
---
