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

Interface ActiveMQServerConsumerPlugin

All Superinterfaces:

ActiveMQServerBasePlugin

All Known Subinterfaces:

ActiveMQServerPlugin

public interface ActiveMQServerConsumerPlugin
extends ActiveMQServerBasePlugin

Method Summary

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

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

init, registered, setInit, unregistered

Method Details

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

Throws:

ActiveMQException

beforeCreateConsumer

default void beforeCreateConsumer(long consumerID,
 org.apache.activemq.artemis.core.postoffice.QueueBinding queueBinding,
 SimpleString filterString,
 boolean browseOnly,
 boolean supportLargeMessage)
                           throws ActiveMQException

Before a consumer is created

Throws:

ActiveMQException

afterCreateConsumer

default void afterCreateConsumer(org.apache.activemq.artemis.core.server.ServerConsumer consumer)
                          throws ActiveMQException

After a consumer has been created

Parameters:

consumer - the created consumer

Throws:

ActiveMQException

beforeCloseConsumer

default void beforeCloseConsumer(org.apache.activemq.artemis.core.server.ServerConsumer consumer,
 boolean failed)
                          throws ActiveMQException

Before a consumer is closed

Throws:

ActiveMQException

afterCloseConsumer

default void afterCloseConsumer(org.apache.activemq.artemis.core.server.ServerConsumer consumer,
 boolean failed)
                         throws ActiveMQException

After a consumer is closed

Throws:

ActiveMQException