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

Interface ActiveMQServerFederationPlugin

All Superinterfaces:

ActiveMQServerBasePlugin

All Known Subinterfaces:

ActiveMQServerPlugin

All Known Implementing Classes:

BrokerMessageAuthorizationPlugin, LoggingActiveMQServerPlugin, NotificationActiveMQServerPlugin

public interface ActiveMQServerFederationPlugin
extends ActiveMQServerBasePlugin

Method Summary

Modifier and Type	Method	Description
default void	afterCloseFederatedQueueConsumer(FederatedQueueConsumer consumer)	After a federated queue consumer is closed
default void	afterCreateFederatedQueueConsumer(FederatedQueueConsumer consumer)	After a federated queue consumer is created
default void	afterFederatedQueueConsumerMessageHandled(FederatedQueueConsumer consumer, Message message)	After a federated queue consumer handles a message
default void	beforeCloseFederatedQueueConsumer(FederatedQueueConsumer consumer)	Before a federated queue consumer is closed
default void	beforeCreateFederatedQueueConsumer(FederatedConsumerKey key)	Before a federated queue consumer is created
default void	beforeFederatedQueueConsumerMessageHandled(FederatedQueueConsumer consumer, Message message)	Before a federated queue consumer handles a message
default boolean	federatedAddressConditionalCreateConsumer(Queue queue)	Conditionally create a federated queue consumer for a federated address.
default boolean	federatedAddressConditionalCreateDivertConsumer(DivertBinding divertBinding, QueueBinding queueBinding)
default boolean	federatedQueueConditionalCreateConsumer(ServerConsumer consumer)	Conditionally create a federated queue consumer for a federated queue.
default void	federationStreamStarted(FederationStream stream)	After a federation stream has been started
default void	federationStreamStopped(FederationStream stream)	After a federation stream has been stopped

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

init, registered, setInit, unregistered

Method Details

federationStreamStarted

default void federationStreamStarted(FederationStream stream)
                              throws ActiveMQException

After a federation stream has been started

Throws:

ActiveMQException

federationStreamStopped

default void federationStreamStopped(FederationStream stream)
                              throws ActiveMQException

After a federation stream has been stopped

Throws:

ActiveMQException

beforeCreateFederatedQueueConsumer

default void beforeCreateFederatedQueueConsumer(FederatedConsumerKey key)
                                         throws ActiveMQException

Before a federated queue consumer is created

Throws:

ActiveMQException

afterCreateFederatedQueueConsumer

default void afterCreateFederatedQueueConsumer(FederatedQueueConsumer consumer)
                                        throws ActiveMQException

After a federated queue consumer is created

Throws:

ActiveMQException

beforeCloseFederatedQueueConsumer

default void beforeCloseFederatedQueueConsumer(FederatedQueueConsumer consumer)
                                        throws ActiveMQException

Before a federated queue consumer is closed

Throws:

ActiveMQException

afterCloseFederatedQueueConsumer

default void afterCloseFederatedQueueConsumer(FederatedQueueConsumer consumer)
                                       throws ActiveMQException

After a federated queue consumer is closed

Throws:

ActiveMQException

beforeFederatedQueueConsumerMessageHandled

default void beforeFederatedQueueConsumerMessageHandled(FederatedQueueConsumer consumer,
 Message message)
                                                 throws ActiveMQException

Before a federated queue consumer handles a message

Throws:

ActiveMQException

afterFederatedQueueConsumerMessageHandled

default void afterFederatedQueueConsumerMessageHandled(FederatedQueueConsumer consumer,
 Message message)
                                                throws ActiveMQException

After a federated queue consumer handles a message

Throws:

ActiveMQException

federatedAddressConditionalCreateConsumer

default boolean federatedAddressConditionalCreateConsumer(Queue queue)
                                                   throws ActiveMQException

Conditionally create a federated queue consumer for a federated address. This allows custom logic to be inserted to decide when to create federated queue consumers

Returns:

if true, create the consumer, else if false don't create

Throws:

ActiveMQException

federatedAddressConditionalCreateDivertConsumer

default boolean federatedAddressConditionalCreateDivertConsumer(DivertBinding divertBinding,
 QueueBinding queueBinding)
                                                         throws ActiveMQException

Throws:

ActiveMQException

federatedQueueConditionalCreateConsumer

default boolean federatedQueueConditionalCreateConsumer(ServerConsumer consumer)
                                                 throws ActiveMQException

Conditionally create a federated queue consumer for a federated queue. This allows custom logic to be inserted to decide when to create federated queue consumers

Returns:

true, create the consumer, else if false don't create

Throws:

ActiveMQException