public interface ActiveMQServerMessagePlugin extends ActiveMQServerBasePlugin
| Modifier and Type | Method and Description |
|---|---|
default void |
afterDeliver(MessageReference reference)
Deprecated.
|
default void |
afterDeliver(ServerConsumer consumer,
MessageReference reference)
After a message is delivered to a client consumer
|
default void |
afterMessageRoute(Message message,
RoutingContext context,
boolean direct,
boolean rejectDuplicates,
RoutingStatus result)
After a message is routed
|
default void |
afterSend(ServerSession session,
Transaction tx,
Message message,
boolean direct,
boolean noAutoCreateQueue,
RoutingStatus result)
After a message is sent
|
default void |
afterSend(Transaction tx,
Message message,
boolean direct,
boolean noAutoCreateQueue,
RoutingStatus result)
|
default void |
beforeDeliver(MessageReference reference)
Deprecated.
use throws ActiveMQException
beforeDeliver(ServerConsumer, MessageReference) |
default void |
beforeDeliver(ServerConsumer consumer,
MessageReference reference)
Before a message is delivered to a client consumer
|
default void |
beforeMessageRoute(Message message,
RoutingContext context,
boolean direct,
boolean rejectDuplicates)
Before a message is routed
|
default void |
beforeSend(ServerSession session,
Transaction tx,
Message message,
boolean direct,
boolean noAutoCreateQueue)
Before a message is sent
|
default void |
beforeSend(Transaction tx,
Message message,
boolean direct,
boolean noAutoCreateQueue)
|
default void |
messageAcknowledged(MessageReference ref,
AckReason reason)
Deprecated.
|
default void |
messageAcknowledged(MessageReference ref,
AckReason reason,
ServerConsumer consumer)
A message has been acknowledged
|
default void |
messageExpired(MessageReference message,
SimpleString messageExpiryAddress)
Deprecated.
|
default void |
messageExpired(MessageReference message,
SimpleString messageExpiryAddress,
ServerConsumer consumer)
A message has been expired
|
default void |
onMessageRouteException(Message message,
RoutingContext context,
boolean direct,
boolean rejectDuplicates,
Exception e)
When there was an error routing the message
|
default void |
onSendException(ServerSession session,
Transaction tx,
Message message,
boolean direct,
boolean noAutoCreateQueue,
Exception e)
When there was an exception sending the message
|
init, registered, unregistereddefault void beforeSend(ServerSession session, Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue) throws ActiveMQException
session - the session that sends the messagetx - message - direct - noAutoCreateQueue - ActiveMQExceptiondefault void afterSend(ServerSession session, Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue, RoutingStatus result) throws ActiveMQException
session - the session that sends the messagetx - message - direct - noAutoCreateQueue - result - ActiveMQExceptiondefault void onSendException(ServerSession session, Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue, Exception e) throws ActiveMQException
session - tx - message - direct - noAutoCreateQueue - e - the exception that occurred when sending the messageActiveMQException@Deprecated default void beforeSend(Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue) throws ActiveMQException
tx - message - direct - noAutoCreateQueue - ActiveMQException@Deprecated default void afterSend(Transaction tx, Message message, boolean direct, boolean noAutoCreateQueue, RoutingStatus result) throws ActiveMQException
tx - message - direct - noAutoCreateQueue - result - ActiveMQExceptiondefault void beforeMessageRoute(Message message, RoutingContext context, boolean direct, boolean rejectDuplicates) throws ActiveMQException
message - context - direct - rejectDuplicates - ActiveMQExceptiondefault void afterMessageRoute(Message message, RoutingContext context, boolean direct, boolean rejectDuplicates, RoutingStatus result) throws ActiveMQException
message - context - direct - rejectDuplicates - result - ActiveMQExceptiondefault void onMessageRouteException(Message message, RoutingContext context, boolean direct, boolean rejectDuplicates, Exception e) throws ActiveMQException
message - context - direct - rejectDuplicates - e - the exception that occurred during message routingActiveMQExceptiondefault void beforeDeliver(ServerConsumer consumer, MessageReference reference) throws ActiveMQException
consumer - the consumer the message will be delivered toreference - message referenceActiveMQExceptiondefault void afterDeliver(ServerConsumer consumer, MessageReference reference) throws ActiveMQException
consumer - the consumer the message was delivered toreference - message referenceActiveMQException@Deprecated default void beforeDeliver(MessageReference reference) throws ActiveMQException
beforeDeliver(ServerConsumer, MessageReference)reference - ActiveMQException@Deprecated default void afterDeliver(MessageReference reference) throws ActiveMQException
afterDeliver(ServerConsumer, MessageReference)reference - ActiveMQException@Deprecated default void messageExpired(MessageReference message, SimpleString messageExpiryAddress) throws ActiveMQException
messageExpired(MessageReference, SimpleString, ServerConsumer)message - The expired messagemessageExpiryAddress - The message expiry address if existsActiveMQExceptiondefault void messageExpired(MessageReference message, SimpleString messageExpiryAddress, ServerConsumer consumer) throws ActiveMQException
message - The expired messagemessageExpiryAddress - The message expiry address if existsconsumer - the Consumer that acknowledged the message - this field is optional
and can be nullActiveMQException@Deprecated default void messageAcknowledged(MessageReference ref, AckReason reason) throws ActiveMQException
messageAcknowledged(MessageReference, AckReason, ServerConsumer)ref - The acked messagereason - The ack reasonActiveMQExceptiondefault void messageAcknowledged(MessageReference ref, AckReason reason, ServerConsumer consumer) throws ActiveMQException
ref - The acked messagereason - The ack reasonconsumer - the Consumer that acknowledged the message - this field is optional
and can be nullActiveMQExceptionCopyright © 2019 JBoss by Red Hat. All rights reserved.