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

Interface ActiveMQServerConsumerPlugin

All Superinterfaces:

ActiveMQServerBasePlugin

All Known Subinterfaces:

ActiveMQServerPlugin

All Known Implementing Classes:

FederatedQueue, LoggingActiveMQServerPlugin, NotificationActiveMQServerPlugin

public interface ActiveMQServerConsumerPlugin
extends ActiveMQServerBasePlugin

Method Summary

Modifier and Type	Method and Description
default void	afterCloseConsumer(ServerConsumer consumer, boolean failed) After a consumer is closed
default void	afterCreateConsumer(ServerConsumer consumer) After a consumer has been created
default void	beforeCloseConsumer(ServerConsumer consumer, boolean failed) Before a consumer is closed
default void	beforeCreateConsumer(long consumerID, QueueBinding queueBinding, SimpleString filterString, boolean browseOnly, boolean supportLargeMessage) Before a consumer is created
default void	beforeCreateConsumer(long consumerID, SimpleString queueName, SimpleString filterString, boolean browseOnly, boolean supportLargeMessage) Deprecated. use beforeCreateConsumer(long, QueueBinding, SimpleString, boolean, boolean)

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

init, registered, unregistered

Method Detail

beforeCreateConsumer

@Deprecated
default void beforeCreateConsumer(long consumerID,
                                              SimpleString queueName,
                                              SimpleString filterString,
                                              boolean browseOnly,
                                              boolean supportLargeMessage)
                                       throws ActiveMQException

Deprecated. use beforeCreateConsumer(long, QueueBinding, SimpleString, boolean, boolean)

Before a consumer is created

Parameters:

consumerID -

queueName -

filterString -

browseOnly -

supportLargeMessage -

Throws:

ActiveMQException

beforeCreateConsumer

default void beforeCreateConsumer(long consumerID,
                                  QueueBinding queueBinding,
                                  SimpleString filterString,
                                  boolean browseOnly,
                                  boolean supportLargeMessage)
                           throws ActiveMQException

Before a consumer is created

Parameters:

consumerID -

queueBinding -

filterString -

browseOnly -

supportLargeMessage -

Throws:

ActiveMQException

afterCreateConsumer

default void afterCreateConsumer(ServerConsumer consumer)
                          throws ActiveMQException

After a consumer has been created

Parameters:

consumer - the created consumer

Throws:

ActiveMQException

beforeCloseConsumer

default void beforeCloseConsumer(ServerConsumer consumer,
                                 boolean failed)
                          throws ActiveMQException

Before a consumer is closed

Parameters:

consumer -

failed -

Throws:

ActiveMQException

afterCloseConsumer

default void afterCloseConsumer(ServerConsumer consumer,
                                boolean failed)
                         throws ActiveMQException

After a consumer is closed

Parameters:

consumer -

failed -

Throws:

ActiveMQException