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

Interface ActiveMQServerBridgePlugin

All Superinterfaces:

ActiveMQServerBasePlugin

All Known Subinterfaces:

ActiveMQServerPlugin

public interface ActiveMQServerBridgePlugin
extends ActiveMQServerBasePlugin

Method Summary

Modifier and Type	Method	Description
default void	afterAcknowledgeBridge(org.apache.activemq.artemis.core.server.cluster.Bridge bridge, org.apache.activemq.artemis.core.server.MessageReference ref)	Called after delivered message over this bridge has been acknowledged by the remote broker
default void	afterDeliverBridge(org.apache.activemq.artemis.core.server.cluster.Bridge bridge, org.apache.activemq.artemis.core.server.MessageReference ref, org.apache.activemq.artemis.core.server.HandleStatus status)	Called immediately after a bridge delivers a message but before the message is acknowledged
default void	afterDeployBridge(org.apache.activemq.artemis.core.server.cluster.Bridge bridge)	After a bridge has been deployed
default void	beforeDeliverBridge(org.apache.activemq.artemis.core.server.cluster.Bridge bridge, org.apache.activemq.artemis.core.server.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, setInit, unregistered

Method Details

beforeDeployBridge

default void beforeDeployBridge(BridgeConfiguration config)
                         throws ActiveMQException

Before a bridge is deployed

Parameters:

config - The bridge configuration

Throws:

ActiveMQException

afterDeployBridge

default void afterDeployBridge(org.apache.activemq.artemis.core.server.cluster.Bridge bridge)
                        throws ActiveMQException

After a bridge has been deployed

Parameters:

bridge - The newly deployed bridge

Throws:

ActiveMQException

beforeDeliverBridge

default void beforeDeliverBridge(org.apache.activemq.artemis.core.server.cluster.Bridge bridge,
 org.apache.activemq.artemis.core.server.MessageReference ref)
                          throws ActiveMQException

Called immediately before a bridge delivers a message

Throws:

ActiveMQException

afterDeliverBridge

default void afterDeliverBridge(org.apache.activemq.artemis.core.server.cluster.Bridge bridge,
 org.apache.activemq.artemis.core.server.MessageReference ref,
 org.apache.activemq.artemis.core.server.HandleStatus status)
                         throws ActiveMQException

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

Throws:

ActiveMQException

afterAcknowledgeBridge

default void afterAcknowledgeBridge(org.apache.activemq.artemis.core.server.cluster.Bridge bridge,
 org.apache.activemq.artemis.core.server.MessageReference ref)
                             throws ActiveMQException

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

Throws:

ActiveMQException