Github user michaelandrepearce commented on a diff in the pull request:
https://github.com/apache/activemq-artemis/pull/2258#discussion_r211867898
--- Diff:
artemis-server/src/main/java/org/apache/activemq/artemis/core/server/plugin/ActiveMQServerMessagePlugin.java
---
@@ -65,6 +65,21 @@ default void afterSend(ServerSession session,
Transaction tx, Message message, b
this.afterSend(tx, message, direct, noAutoCreateQueue, result);
}
+ /**
+ * When there was an exception sending the message
+ *
+ * @param session
+ * @param tx
+ * @param message
+ * @param direct
+ * @param noAutoCreateQueue
+ * @param e the exception that occurred when sending the message
+ * @throws ActiveMQException
+ */
+ default void onSendError(ServerSession session, Transaction tx, Message
message, boolean direct, boolean noAutoCreateQueue,
--- End diff --
Nit: onSendException
---
