Package org.apache.activemq.artemis.core.server.plugin.impl

Class NotificationActiveMQServerPlugin

java.lang.Object

org.apache.activemq.artemis.core.server.plugin.impl.NotificationActiveMQServerPlugin

All Implemented Interfaces:

ActiveMQServerAddressPlugin, ActiveMQServerBasePlugin, ActiveMQServerBindingPlugin, ActiveMQServerBridgePlugin, ActiveMQServerConnectionPlugin, ActiveMQServerConsumerPlugin, ActiveMQServerCriticalPlugin, ActiveMQServerFederationPlugin, ActiveMQServerMessagePlugin, ActiveMQServerPlugin, ActiveMQServerQueuePlugin, ActiveMQServerResourcePlugin, ActiveMQServerSessionPlugin

public class NotificationActiveMQServerPlugin
extends Object
implements ActiveMQServerPlugin

Field Summary

Fields

Modifier and Type	Field	Description
static final String	SEND_ADDRESS_NOTIFICATIONS
static final String	SEND_CONNECTION_NOTIFICATIONS
static final String	SEND_DELIVERED_NOTIFICATIONS
static final String	SEND_EXPIRED_NOTIFICATIONS

Constructor Summary

Constructors

Constructor	Description
NotificationActiveMQServerPlugin()

Method Summary

Modifier and Type	Method	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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.activemq.artemis.core.server.plugin.ActiveMQServerAddressPlugin

afterUpdateAddress, beforeAddAddress, beforeRemoveAddress, beforeUpdateAddress

Methods inherited from interface org.apache.activemq.artemis.core.server.plugin.ActiveMQServerBasePlugin

setInit

Methods inherited from interface org.apache.activemq.artemis.core.server.plugin.ActiveMQServerBindingPlugin

afterAddBinding, afterRemoveBinding, beforeAddBinding, beforeRemoveBinding

Methods inherited from interface org.apache.activemq.artemis.core.server.plugin.ActiveMQServerBridgePlugin

afterAcknowledgeBridge, afterDeliverBridge, afterDeployBridge, beforeDeliverBridge, beforeDeployBridge

Methods inherited from interface org.apache.activemq.artemis.core.server.plugin.ActiveMQServerConsumerPlugin

afterCloseConsumer, afterCreateConsumer, beforeCloseConsumer, beforeCreateConsumer, beforeCreateConsumer

Methods inherited from interface org.apache.activemq.artemis.core.server.plugin.ActiveMQServerCriticalPlugin

criticalFailure

Methods inherited from interface org.apache.activemq.artemis.core.server.plugin.ActiveMQServerFederationPlugin

afterCloseFederatedQueueConsumer, afterCreateFederatedQueueConsumer, afterFederatedQueueConsumerMessageHandled, beforeCloseFederatedQueueConsumer, beforeCreateFederatedQueueConsumer, beforeFederatedQueueConsumerMessageHandled, federatedAddressConditionalCreateConsumer, federatedAddressConditionalCreateDivertConsumer, federatedQueueConditionalCreateConsumer, federationStreamStarted, federationStreamStopped

Methods inherited from interface org.apache.activemq.artemis.core.server.plugin.ActiveMQServerMessagePlugin

afterDeliver, afterMessageRoute, afterSend, afterSend, beforeDeliver, beforeDeliver, beforeMessageRoute, beforeSend, beforeSend, canAccept, messageAcknowledged, messageAcknowledged, messageAcknowledged, messageExpired, messageMoved, onMessageRouteException, onSendException

Methods inherited from interface org.apache.activemq.artemis.core.server.plugin.ActiveMQServerQueuePlugin

afterCreateQueue, afterDestroyQueue, afterExpiryScan, beforeCreateQueue, beforeCreateQueue, beforeDestroyQueue, beforeDestroyQueue, beforeExpiryScan

Methods inherited from interface org.apache.activemq.artemis.core.server.plugin.ActiveMQServerResourcePlugin

afterPutTransaction, afterRemoveTransaction, beforePutTransaction, beforeRemoveTransaction

Methods inherited from interface org.apache.activemq.artemis.core.server.plugin.ActiveMQServerSessionPlugin

afterCloseSession, afterCreateSession, afterSessionMetadataAdded, beforeCloseSession, beforeCreateSession, beforeSessionMetadataAdded, duplicateSessionMetadataFailure

Field Details

SEND_CONNECTION_NOTIFICATIONS

public static final String SEND_CONNECTION_NOTIFICATIONS

See Also:

• Constant Field Values

SEND_ADDRESS_NOTIFICATIONS

public static final String SEND_ADDRESS_NOTIFICATIONS

See Also:

• Constant Field Values

SEND_DELIVERED_NOTIFICATIONS

public static final String SEND_DELIVERED_NOTIFICATIONS

See Also:

• Constant Field Values

SEND_EXPIRED_NOTIFICATIONS

public static final String SEND_EXPIRED_NOTIFICATIONS

See Also:

• Constant Field Values

Constructor Details

NotificationActiveMQServerPlugin

public NotificationActiveMQServerPlugin()

Method Details

init

public void init(Map<String,String> properties)

used to pass configured properties to Plugin

Specified by:

init in interface ActiveMQServerBasePlugin

registered

public void registered(ActiveMQServer server)

Description copied from interface: ActiveMQServerBasePlugin

The plugin has been registered with the server

Specified by:

registered in interface ActiveMQServerBasePlugin

Parameters:

server - The ActiveMQServer the plugin has been registered to

unregistered

public void unregistered(ActiveMQServer server)

Description copied from interface: ActiveMQServerBasePlugin

The plugin has been unregistered with the server

Specified by:

unregistered in interface ActiveMQServerBasePlugin

Parameters:

server - The ActiveMQServer the plugin has been unregistered to

afterCreateConnection

public void afterCreateConnection(RemotingConnection connection)
                           throws ActiveMQException

Description copied from interface: ActiveMQServerConnectionPlugin

A connection has been created.

Specified by:

afterCreateConnection in interface ActiveMQServerConnectionPlugin

Parameters:

connection - The newly created connection

Throws:

ActiveMQException

afterDestroyConnection

public void afterDestroyConnection(RemotingConnection connection)
                            throws ActiveMQException

Description copied from interface: ActiveMQServerConnectionPlugin

A connection has been destroyed.

Specified by:

afterDestroyConnection in interface ActiveMQServerConnectionPlugin

Throws:

ActiveMQException

afterAddAddress

public void afterAddAddress(AddressInfo addressInfo,
 boolean reload)
                     throws ActiveMQException

Description copied from interface: ActiveMQServerAddressPlugin

After an address has been added tot he broker

Specified by:

afterAddAddress in interface ActiveMQServerAddressPlugin

Parameters:

addressInfo - The newly added address

reload - If the address is being reloaded

Throws:

ActiveMQException

afterRemoveAddress

public void afterRemoveAddress(SimpleString address,
 AddressInfo addressInfo)
                        throws ActiveMQException

Description copied from interface: ActiveMQServerAddressPlugin

After an address has been removed

Specified by:

afterRemoveAddress in interface ActiveMQServerAddressPlugin

Parameters:

address - The address that has been removed

addressInfo - The address info that has been removed or null if not removed

Throws:

ActiveMQException

afterDeliver

public void afterDeliver(ServerConsumer consumer,
 MessageReference reference)
                  throws ActiveMQException

Description copied from interface: ActiveMQServerMessagePlugin

After a message is delivered to a client consumer

Specified by:

afterDeliver in interface ActiveMQServerMessagePlugin

Parameters:

consumer - the consumer the message was delivered to

reference - message reference

Throws:

ActiveMQException

messageExpired

public void messageExpired(MessageReference message,
 SimpleString messageExpiryAddress,
 ServerConsumer consumer)

Description copied from interface: ActiveMQServerMessagePlugin

A message has been expired

Specified by:

messageExpired in interface ActiveMQServerMessagePlugin

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

isSendConnectionNotifications

public boolean isSendConnectionNotifications()

setSendConnectionNotifications

public void setSendConnectionNotifications(boolean sendConnectionNotifications)

isSendDeliveredNotifications

public boolean isSendDeliveredNotifications()

setSendDeliveredNotifications

public void setSendDeliveredNotifications(boolean sendDeliveredNotifications)

isSendExpiredNotifications

public boolean isSendExpiredNotifications()

setSendExpiredNotifications

public void setSendExpiredNotifications(boolean sendExpiredNotifications)

isSendAddressNotifications

public boolean isSendAddressNotifications()

setSendAddressNotifications

public void setSendAddressNotifications(boolean sendAddressNotifications)