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

Interface ActiveMQServerFederationPlugin

All Superinterfaces:

ActiveMQServerBasePlugin

All Known Subinterfaces:

ActiveMQServerPlugin

All Known Implementing Classes:

LoggingActiveMQServerPlugin, NotificationActiveMQServerPlugin

public interface ActiveMQServerFederationPlugin
extends ActiveMQServerBasePlugin

Method Summary

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

Method Detail

federationStreamStarted

default void federationStreamStarted(FederationStream stream)
                              throws ActiveMQException

After a federation stream has been started

Parameters:

stream -

Throws:

ActiveMQException

federationStreamStopped

default void federationStreamStopped(FederationStream stream)
                              throws ActiveMQException

After a federation stream has been stopped

Parameters:

stream -

Throws:

ActiveMQException

beforeCreateFederatedQueueConsumer

default void beforeCreateFederatedQueueConsumer(FederatedConsumerKey key)
                                         throws ActiveMQException

Before a federated queue consumer is created

Parameters:

key -

Throws:

ActiveMQException

afterCreateFederatedQueueConsumer

default void afterCreateFederatedQueueConsumer(FederatedQueueConsumer consumer)
                                        throws ActiveMQException

After a federated queue consumer is created

Parameters:

consumer -

Throws:

ActiveMQException

beforeCloseFederatedQueueConsumer

default void beforeCloseFederatedQueueConsumer(FederatedQueueConsumer consumer)
                                        throws ActiveMQException

Before a federated queue consumer is closed

Parameters:

consumer -

Throws:

ActiveMQException

afterCloseFederatedQueueConsumer

default void afterCloseFederatedQueueConsumer(FederatedQueueConsumer consumer)
                                       throws ActiveMQException

After a federated queue consumer is closed

Parameters:

consumer -

Throws:

ActiveMQException

beforeFederatedQueueConsumerMessageHandled

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

Before a federated queue consumer handles a message

Parameters:

consumer -

message -

Throws:

ActiveMQException

afterFederatedQueueConsumerMessageHandled

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

After a federated queue consumer handles a message

Parameters:

consumer -

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

Parameters:

queue -

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

Parameters:

consumer -

Returns:

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

Throws:

ActiveMQException