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

Interface ActiveMQServerBridgePlugin

All Superinterfaces:

ActiveMQServerBasePlugin

All Known Subinterfaces:

ActiveMQServerPlugin

All Known Implementing Classes:

LoggingActiveMQServerPlugin, NotificationActiveMQServerPlugin

public interface ActiveMQServerBridgePlugin
extends ActiveMQServerBasePlugin

Method Summary

Modifier and Type	Method and Description
default void	afterAcknowledgeBridge(Bridge bridge, MessageReference ref) Called after delivered message over this bridge has been acknowledged by the remote broker
default void	afterDeliverBridge(Bridge bridge, MessageReference ref, HandleStatus status) Called immediately after a bridge delivers a message but before the message is acknowledged
default void	afterDeployBridge(Bridge bridge) After a bridge has been deployed
default void	beforeDeliverBridge(Bridge bridge, MessageReference ref) Called immediately before a bridge delivers a message
default void	beforeDeployBridge(BridgeConfiguration config) Before a bridge is deployed

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

init, registered, unregistered

Method Detail

beforeDeployBridge

default void beforeDeployBridge(BridgeConfiguration config)
                         throws ActiveMQException

Before a bridge is deployed

Parameters:

config - The bridge configuration

Throws:

ActiveMQException

afterDeployBridge

default void afterDeployBridge(Bridge bridge)
                        throws ActiveMQException

After a bridge has been deployed

Parameters:

bridge - The newly deployed bridge

Throws:

ActiveMQException

beforeDeliverBridge

default void beforeDeliverBridge(Bridge bridge,
                                 MessageReference ref)
                          throws ActiveMQException

Called immediately before a bridge delivers a message

Parameters:

bridge -

ref -

Throws:

ActiveMQException

afterDeliverBridge

default void afterDeliverBridge(Bridge bridge,
                                MessageReference ref,
                                HandleStatus status)
                         throws ActiveMQException

Called immediately after a bridge delivers a message but before the message is acknowledged

Parameters:

bridge -

ref -

status -

Throws:

ActiveMQException

afterAcknowledgeBridge

default void afterAcknowledgeBridge(Bridge bridge,
                                    MessageReference ref)
                             throws ActiveMQException

Called after delivered message over this bridge has been acknowledged by the remote broker

Parameters:

bridge -

ref -

Throws:

ActiveMQException