-
Method Summary
default void
afterDeliver(org.apache.activemq.artemis.core.server.MessageReference reference)
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 consumer
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)
After a message is routed
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)
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)
default void
beforeDeliver(org.apache.activemq.artemis.core.server.MessageReference reference)
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 consumer
default void
beforeMessageRoute(Message message,
org.apache.activemq.artemis.core.server.RoutingContext context,
boolean direct,
boolean rejectDuplicates)
Before a message is routed
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)
default 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 consumer
default void
messageAcknowledged(org.apache.activemq.artemis.core.server.MessageReference ref,
org.apache.activemq.artemis.core.server.impl.AckReason reason)
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)
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 acknowledged
default void
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 expired
default void
messageMoved(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,
SimpleString destAddress,
Long destQueueID,
org.apache.activemq.artemis.core.server.ServerConsumer consumer,
Message newMessage,
org.apache.activemq.artemis.core.postoffice.RoutingStatus result)
default void
When there was an error routing the message
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)
When there was an exception sending the message
-
Method Details
-
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 message
tx
-
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 message
tx
-
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
Deprecated.
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
Deprecated.
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 to
reference
- 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 to
reference
- 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 to
reference
- message reference
- Throws:
ActiveMQException
-
beforeDeliver
Deprecated.
Before a message is delivered to a client consumer
- Parameters:
reference
-
- Throws:
ActiveMQException
-
afterDeliver
Deprecated.
After a message is delivered to a client consumer
- Parameters:
reference
-
- Throws:
ActiveMQException
-
messageExpired
Deprecated.
A message has been expired
- Parameters:
message
- The expired message
messageExpiryAddress
- 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 message
messageExpiryAddress
- The message expiry address if exists
consumer
- 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 message
reason
- 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 message
reason
- The ack reason
consumer
- 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 ack
ref
- The acked message
reason
- The ack reason
consumer
- the Consumer that acknowledged the message - this field is optional
and can be null
- Throws:
ActiveMQException
-
messageMoved
default void messageMoved(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,
SimpleString destAddress,
Long destQueueID,
org.apache.activemq.artemis.core.server.ServerConsumer consumer,
Message newMessage,
org.apache.activemq.artemis.core.postoffice.RoutingStatus result)
throws ActiveMQException
A message has been moved
- Parameters:
tx
- The transaction associated with the move
ref
- The ref of the message moved
reason
- The move reason
destAddress
- the destination address for the move operation
destQueueID
- the destination queueID for the move operation - this field is optional and can be null
consumer
- the consumer that moved the message - this field is optional and can be null
newMessage
- the new message created by the move operation
result
- routing status of the move operation
- Throws:
ActiveMQException
afterDeliver(ServerConsumer, MessageReference)