Interface ActiveMQServerMessagePlugin
-
- All Superinterfaces:
ActiveMQServerBasePlugin
- All Known Subinterfaces:
ActiveMQServerPlugin
public interface ActiveMQServerMessagePlugin extends ActiveMQServerBasePlugin
-
-
Method Summary
All Methods Instance Methods Default Methods Deprecated Methods Modifier and Type Method Description default void
afterDeliver(org.apache.activemq.artemis.core.server.MessageReference reference)
Deprecated.default void
afterDeliver(org.apache.activemq.artemis.core.server.ServerConsumer consumer, org.apache.activemq.artemis.core.server.MessageReference reference)
After a message is delivered to a client consumerdefault void
afterMessageRoute(Message message, org.apache.activemq.artemis.core.server.RoutingContext context, boolean direct, boolean rejectDuplicates, org.apache.activemq.artemis.core.postoffice.RoutingStatus result)
After a message is routeddefault void
afterSend(org.apache.activemq.artemis.core.server.ServerSession session, org.apache.activemq.artemis.core.transaction.Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue, org.apache.activemq.artemis.core.postoffice.RoutingStatus result)
After a message is sentdefault void
afterSend(org.apache.activemq.artemis.core.transaction.Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue, org.apache.activemq.artemis.core.postoffice.RoutingStatus result)
default void
beforeDeliver(org.apache.activemq.artemis.core.server.MessageReference reference)
Deprecated.use throws ActiveMQExceptionbeforeDeliver(ServerConsumer, MessageReference)
default void
beforeDeliver(org.apache.activemq.artemis.core.server.ServerConsumer consumer, org.apache.activemq.artemis.core.server.MessageReference reference)
Before a message is delivered to a client consumerdefault void
beforeMessageRoute(Message message, org.apache.activemq.artemis.core.server.RoutingContext context, boolean direct, boolean rejectDuplicates)
Before a message is routeddefault void
beforeSend(org.apache.activemq.artemis.core.server.ServerSession session, org.apache.activemq.artemis.core.transaction.Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue)
Before a message is sentdefault void
beforeSend(org.apache.activemq.artemis.core.transaction.Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue)
default boolean
canAccept(org.apache.activemq.artemis.core.server.ServerConsumer consumer, org.apache.activemq.artemis.core.server.MessageReference reference)
Before a message is delivered to a client consumerdefault void
messageAcknowledged(org.apache.activemq.artemis.core.server.MessageReference ref, org.apache.activemq.artemis.core.server.impl.AckReason reason)
Deprecated.default void
messageAcknowledged(org.apache.activemq.artemis.core.server.MessageReference ref, org.apache.activemq.artemis.core.server.impl.AckReason reason, org.apache.activemq.artemis.core.server.ServerConsumer consumer)
Deprecated.default void
messageAcknowledged(org.apache.activemq.artemis.core.transaction.Transaction tx, org.apache.activemq.artemis.core.server.MessageReference ref, org.apache.activemq.artemis.core.server.impl.AckReason reason, org.apache.activemq.artemis.core.server.ServerConsumer consumer)
A message has been acknowledgeddefault void
messageExpired(org.apache.activemq.artemis.core.server.MessageReference message, SimpleString messageExpiryAddress)
Deprecated.default void
messageExpired(org.apache.activemq.artemis.core.server.MessageReference message, SimpleString messageExpiryAddress, org.apache.activemq.artemis.core.server.ServerConsumer consumer)
A message has been expireddefault void
onMessageRouteException(Message message, org.apache.activemq.artemis.core.server.RoutingContext context, boolean direct, boolean rejectDuplicates, Exception e)
When there was an error routing the messagedefault void
onSendException(org.apache.activemq.artemis.core.server.ServerSession session, org.apache.activemq.artemis.core.transaction.Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue, Exception e)
When there was an exception sending the message-
Methods inherited from interface org.apache.activemq.artemis.core.server.plugin.ActiveMQServerBasePlugin
init, registered, setInit, unregistered
-
-
-
-
Method Detail
-
beforeSend
default void beforeSend(org.apache.activemq.artemis.core.server.ServerSession session, org.apache.activemq.artemis.core.transaction.Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue) throws ActiveMQException
Before a message is sent- Parameters:
session
- the session that sends the messagetx
-message
-direct
-noAutoCreateQueue
-- Throws:
ActiveMQException
-
afterSend
default void afterSend(org.apache.activemq.artemis.core.server.ServerSession session, org.apache.activemq.artemis.core.transaction.Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue, org.apache.activemq.artemis.core.postoffice.RoutingStatus result) throws ActiveMQException
After a message is sent- Parameters:
session
- the session that sends the messagetx
-message
-direct
-noAutoCreateQueue
-result
-- Throws:
ActiveMQException
-
onSendException
default void onSendException(org.apache.activemq.artemis.core.server.ServerSession session, org.apache.activemq.artemis.core.transaction.Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue, Exception e) throws ActiveMQException
When there was an exception sending the message- Parameters:
session
-tx
-message
-direct
-noAutoCreateQueue
-e
- the exception that occurred when sending the message- Throws:
ActiveMQException
-
beforeSend
@Deprecated default void beforeSend(org.apache.activemq.artemis.core.transaction.Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue) throws ActiveMQException
Before a message is sent- Parameters:
tx
-message
-direct
-noAutoCreateQueue
-- Throws:
ActiveMQException
-
afterSend
@Deprecated default void afterSend(org.apache.activemq.artemis.core.transaction.Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue, org.apache.activemq.artemis.core.postoffice.RoutingStatus result) throws ActiveMQException
After a message is sent- Parameters:
tx
-message
-direct
-noAutoCreateQueue
-result
-- Throws:
ActiveMQException
-
beforeMessageRoute
default void beforeMessageRoute(Message message, org.apache.activemq.artemis.core.server.RoutingContext context, boolean direct, boolean rejectDuplicates) throws ActiveMQException
Before a message is routed- Parameters:
message
-context
-direct
-rejectDuplicates
-- Throws:
ActiveMQException
-
afterMessageRoute
default void afterMessageRoute(Message message, org.apache.activemq.artemis.core.server.RoutingContext context, boolean direct, boolean rejectDuplicates, org.apache.activemq.artemis.core.postoffice.RoutingStatus result) throws ActiveMQException
After a message is routed- Parameters:
message
-context
-direct
-rejectDuplicates
-result
-- Throws:
ActiveMQException
-
onMessageRouteException
default void onMessageRouteException(Message message, org.apache.activemq.artemis.core.server.RoutingContext context, boolean direct, boolean rejectDuplicates, Exception e) throws ActiveMQException
When there was an error routing the message- Parameters:
message
-context
-direct
-rejectDuplicates
-e
- the exception that occurred during message routing- Throws:
ActiveMQException
-
canAccept
default boolean canAccept(org.apache.activemq.artemis.core.server.ServerConsumer consumer, org.apache.activemq.artemis.core.server.MessageReference reference) throws ActiveMQException
Before a message is delivered to a client consumer- Parameters:
consumer
- the consumer the message will be delivered toreference
- message reference- Throws:
ActiveMQException
-
beforeDeliver
default void beforeDeliver(org.apache.activemq.artemis.core.server.ServerConsumer consumer, org.apache.activemq.artemis.core.server.MessageReference reference) throws ActiveMQException
Before a message is delivered to a client consumer- Parameters:
consumer
- the consumer the message will be delivered toreference
- message reference- Throws:
ActiveMQException
-
afterDeliver
default void afterDeliver(org.apache.activemq.artemis.core.server.ServerConsumer consumer, org.apache.activemq.artemis.core.server.MessageReference reference) throws ActiveMQException
After a message is delivered to a client consumer- Parameters:
consumer
- the consumer the message was delivered toreference
- message reference- Throws:
ActiveMQException
-
beforeDeliver
@Deprecated default void beforeDeliver(org.apache.activemq.artemis.core.server.MessageReference reference) throws ActiveMQException
Deprecated.use throws ActiveMQExceptionbeforeDeliver(ServerConsumer, MessageReference)
Before a message is delivered to a client consumer- Parameters:
reference
-- Throws:
ActiveMQException
-
afterDeliver
@Deprecated default void afterDeliver(org.apache.activemq.artemis.core.server.MessageReference reference) throws ActiveMQException
Deprecated.After a message is delivered to a client consumer- Parameters:
reference
-- Throws:
ActiveMQException
-
messageExpired
@Deprecated default void messageExpired(org.apache.activemq.artemis.core.server.MessageReference message, SimpleString messageExpiryAddress) throws ActiveMQException
Deprecated.A message has been expired- Parameters:
message
- The expired messagemessageExpiryAddress
- The message expiry address if exists- Throws:
ActiveMQException
-
messageExpired
default void messageExpired(org.apache.activemq.artemis.core.server.MessageReference message, SimpleString messageExpiryAddress, org.apache.activemq.artemis.core.server.ServerConsumer consumer) throws ActiveMQException
A message has been expired- Parameters:
message
- The expired messagemessageExpiryAddress
- The message expiry address if existsconsumer
- the Consumer that acknowledged the message - this field is optional and can be null- Throws:
ActiveMQException
-
messageAcknowledged
@Deprecated default void messageAcknowledged(org.apache.activemq.artemis.core.server.MessageReference ref, org.apache.activemq.artemis.core.server.impl.AckReason reason) throws ActiveMQException
Deprecated.A message has been acknowledged- Parameters:
ref
- The acked messagereason
- The ack reason- Throws:
ActiveMQException
-
messageAcknowledged
@Deprecated default void messageAcknowledged(org.apache.activemq.artemis.core.server.MessageReference ref, org.apache.activemq.artemis.core.server.impl.AckReason reason, org.apache.activemq.artemis.core.server.ServerConsumer consumer) throws ActiveMQException
Deprecated.A message has been acknowledged- Parameters:
ref
- The acked messagereason
- The ack reasonconsumer
- the Consumer that acknowledged the message - this field is optional and can be null- Throws:
ActiveMQException
-
messageAcknowledged
default void messageAcknowledged(org.apache.activemq.artemis.core.transaction.Transaction tx, org.apache.activemq.artemis.core.server.MessageReference ref, org.apache.activemq.artemis.core.server.impl.AckReason reason, org.apache.activemq.artemis.core.server.ServerConsumer consumer) throws ActiveMQException
A message has been acknowledged- Parameters:
tx
- The transaction associated with the ackref
- The acked messagereason
- The ack reasonconsumer
- the Consumer that acknowledged the message - this field is optional and can be null- Throws:
ActiveMQException
-
-