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 |
static String |
SEND_SESSION_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 |
afterCloseSession(ServerSession session,
boolean failed)
After a session is closed
|
void |
afterCreateConnection(RemotingConnection connection)
A connection has been created.
|
void |
afterCreateSession(ServerSession session)
After a session 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() |
boolean |
isSendSessionNotifications() |
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 |
setSendSessionNotifications(boolean sendSessionNotifications) |
void |
unregistered(ActiveMQServer server)
The plugin has been unregistered with the server
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
afterAddBinding, afterCloseConsumer, afterCreateConsumer, afterCreateQueue, afterDeliver, afterDeployBridge, afterDestroyQueue, afterMessageRoute, afterRemoveBinding, afterSend, afterSend, afterSessionMetadataAdded, afterUpdateAddress, beforeAddAddress, beforeAddBinding, beforeCloseConsumer, beforeCloseSession, beforeCreateConsumer, beforeCreateConsumer, beforeCreateQueue, beforeCreateSession, beforeDeliver, beforeDeliver, beforeDeployBridge, beforeDestroyQueue, beforeMessageRoute, beforeRemoveAddress, beforeRemoveBinding, beforeSend, beforeSend, beforeSessionMetadataAdded, beforeUpdateAddress, criticalFailure, messageAcknowledged, messageAcknowledged, messageExpired
public static final String SEND_CONNECTION_NOTIFICATIONS
public static final String SEND_SESSION_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 ActiveMQServerPlugin
properties
- public void registered(ActiveMQServer server)
ActiveMQServerPlugin
registered
in interface ActiveMQServerPlugin
server
- The ActiveMQServer the plugin has been registered topublic void unregistered(ActiveMQServer server)
ActiveMQServerPlugin
unregistered
in interface ActiveMQServerPlugin
server
- The ActiveMQServer the plugin has been unregistered topublic void afterCreateConnection(RemotingConnection connection) throws ActiveMQException
ActiveMQServerPlugin
afterCreateConnection
in interface ActiveMQServerPlugin
connection
- The newly created connectionActiveMQException
public void afterDestroyConnection(RemotingConnection connection) throws ActiveMQException
ActiveMQServerPlugin
afterDestroyConnection
in interface ActiveMQServerPlugin
ActiveMQException
public void afterCreateSession(ServerSession session) throws ActiveMQException
ActiveMQServerPlugin
afterCreateSession
in interface ActiveMQServerPlugin
session
- The newly created sessionActiveMQException
public void afterCloseSession(ServerSession session, boolean failed) throws ActiveMQException
ActiveMQServerPlugin
afterCloseSession
in interface ActiveMQServerPlugin
ActiveMQException
public void afterAddAddress(AddressInfo addressInfo, boolean reload) throws ActiveMQException
ActiveMQServerPlugin
afterAddAddress
in interface ActiveMQServerPlugin
addressInfo
- The newly added addressreload
- If the address is being reloadedActiveMQException
public void afterRemoveAddress(SimpleString address, AddressInfo addressInfo) throws ActiveMQException
ActiveMQServerPlugin
afterRemoveAddress
in interface ActiveMQServerPlugin
address
- The address that has been removedaddressInfo
- The address info that has been removed or null if not removedActiveMQException
public void afterDeliver(ServerConsumer consumer, MessageReference reference) throws ActiveMQException
ActiveMQServerPlugin
afterDeliver
in interface ActiveMQServerPlugin
consumer
- the consumer the message was delivered toreference
- message referenceActiveMQException
public void messageExpired(MessageReference message, SimpleString messageExpiryAddress, ServerConsumer consumer)
ActiveMQServerPlugin
messageExpired
in interface ActiveMQServerPlugin
message
- 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 isSendSessionNotifications()
public void setSendSessionNotifications(boolean sendSessionNotifications)
sendSessionNotifications
- the sendSessionNotifications 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.