public class NotificationActiveMQServerPlugin extends Object implements ActiveMQServerPlugin
| Modifier and Type | Field and Description |
|---|---|
static String |
SEND_ADDRESS_NOTIFICATIONS |
static String |
SEND_CONNECTION_NOTIFICATIONS |
static String |
SEND_DELIVERED_NOTIFICATIONS |
static String |
SEND_EXPIRED_NOTIFICATIONS |
| Constructor and Description |
|---|
NotificationActiveMQServerPlugin() |
| Modifier and Type | Method and Description |
|---|---|
void |
afterAddAddress(AddressInfo addressInfo,
boolean reload)
After an address has been added tot he broker
|
void |
afterCreateConnection(RemotingConnection connection)
A connection has been created.
|
void |
afterDeliver(ServerConsumer consumer,
MessageReference reference)
After a message is delivered to a client consumer
|
void |
afterDestroyConnection(RemotingConnection connection)
A connection has been destroyed.
|
void |
afterRemoveAddress(SimpleString address,
AddressInfo addressInfo)
After an address has been removed
|
void |
init(Map<String,String> properties)
used to pass configured properties to Plugin
|
boolean |
isSendAddressNotifications() |
boolean |
isSendConnectionNotifications() |
boolean |
isSendDeliveredNotifications() |
boolean |
isSendExpiredNotifications() |
void |
messageExpired(MessageReference message,
SimpleString messageExpiryAddress,
ServerConsumer consumer)
A message has been expired
|
void |
registered(ActiveMQServer server)
The plugin has been registered with the server
|
void |
setSendAddressNotifications(boolean sendAddressNotifications) |
void |
setSendConnectionNotifications(boolean sendConnectionNotifications) |
void |
setSendDeliveredNotifications(boolean sendDeliveredNotifications) |
void |
setSendExpiredNotifications(boolean sendExpiredNotifications) |
void |
unregistered(ActiveMQServer server)
The plugin has been unregistered with the server
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitafterCloseSession, afterCreateSession, afterSessionMetadataAdded, beforeCloseSession, beforeCreateSession, beforeSessionMetadataAdded, duplicateSessionMetadataFailureafterCloseConsumer, afterCreateConsumer, beforeCloseConsumer, beforeCreateConsumer, beforeCreateConsumerafterUpdateAddress, beforeAddAddress, beforeRemoveAddress, beforeUpdateAddressafterCreateQueue, afterDestroyQueue, beforeCreateQueue, beforeDestroyQueue, beforeDestroyQueueafterAddBinding, afterRemoveBinding, beforeAddBinding, beforeRemoveBindingafterDeliver, afterMessageRoute, afterSend, afterSend, beforeDeliver, beforeDeliver, beforeMessageRoute, beforeSend, beforeSend, messageAcknowledged, messageAcknowledged, messageExpired, onMessageRouteException, onSendExceptionafterAcknowledgeBridge, afterDeliverBridge, afterDeployBridge, beforeDeliverBridge, beforeDeployBridgecriticalFailurepublic static final String SEND_CONNECTION_NOTIFICATIONS
public static final String SEND_ADDRESS_NOTIFICATIONS
public static final String SEND_DELIVERED_NOTIFICATIONS
public static final String SEND_EXPIRED_NOTIFICATIONS
public void init(Map<String,String> properties)
init in interface ActiveMQServerBasePluginproperties - public void registered(ActiveMQServer server)
ActiveMQServerBasePluginregistered in interface ActiveMQServerBasePluginserver - The ActiveMQServer the plugin has been registered topublic void unregistered(ActiveMQServer server)
ActiveMQServerBasePluginunregistered in interface ActiveMQServerBasePluginserver - The ActiveMQServer the plugin has been unregistered topublic void afterCreateConnection(RemotingConnection connection) throws ActiveMQException
ActiveMQServerConnectionPluginafterCreateConnection in interface ActiveMQServerConnectionPluginconnection - The newly created connectionActiveMQExceptionpublic void afterDestroyConnection(RemotingConnection connection) throws ActiveMQException
ActiveMQServerConnectionPluginafterDestroyConnection in interface ActiveMQServerConnectionPluginActiveMQExceptionpublic void afterAddAddress(AddressInfo addressInfo, boolean reload) throws ActiveMQException
ActiveMQServerAddressPluginafterAddAddress in interface ActiveMQServerAddressPluginaddressInfo - The newly added addressreload - If the address is being reloadedActiveMQExceptionpublic void afterRemoveAddress(SimpleString address, AddressInfo addressInfo) throws ActiveMQException
ActiveMQServerAddressPluginafterRemoveAddress in interface ActiveMQServerAddressPluginaddress - The address that has been removedaddressInfo - The address info that has been removed or null if not removedActiveMQExceptionpublic void afterDeliver(ServerConsumer consumer, MessageReference reference) throws ActiveMQException
ActiveMQServerMessagePluginafterDeliver in interface ActiveMQServerMessagePluginconsumer - the consumer the message was delivered toreference - message referenceActiveMQExceptionpublic void messageExpired(MessageReference message, SimpleString messageExpiryAddress, ServerConsumer consumer)
ActiveMQServerMessagePluginmessageExpired in interface ActiveMQServerMessagePluginmessage - The expired messagemessageExpiryAddress - The message expiry address if existsconsumer - the Consumer that acknowledged the message - this field is optional
and can be nullpublic boolean isSendConnectionNotifications()
public void setSendConnectionNotifications(boolean sendConnectionNotifications)
sendConnectionNotifications - the sendConnectionNotifications to setpublic boolean isSendDeliveredNotifications()
public void setSendDeliveredNotifications(boolean sendDeliveredNotifications)
sendDeliveredNotifications - the sendDeliveredNotifications to setpublic boolean isSendExpiredNotifications()
public void setSendExpiredNotifications(boolean sendExpiredNotifications)
sendExpiredNotifications - the sendExpiredNotifications to setpublic boolean isSendAddressNotifications()
public void setSendAddressNotifications(boolean sendAddressNotifications)
sendAddressNotifications - the sendAddressNotifications to setCopyright © 2019 JBoss by Red Hat. All rights reserved.