public interface ActiveMQServerConsumerPlugin extends ActiveMQServerBasePlugin
| 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 {@link #beforeCreateConsumer(long, QueueBinding, SimpleString, boolean, boolean)
|
init, registered, unregistered@Deprecated default void beforeCreateConsumer(long consumerID, SimpleString queueName, SimpleString filterString, boolean browseOnly, boolean supportLargeMessage) throws ActiveMQException
consumerID - queueName - filterString - browseOnly - supportLargeMessage - ActiveMQExceptiondefault void beforeCreateConsumer(long consumerID,
QueueBinding queueBinding,
SimpleString filterString,
boolean browseOnly,
boolean supportLargeMessage)
throws ActiveMQException
consumerID - queueBinding - filterString - browseOnly - supportLargeMessage - ActiveMQExceptiondefault void afterCreateConsumer(ServerConsumer consumer) throws ActiveMQException
consumer - the created consumerActiveMQExceptiondefault void beforeCloseConsumer(ServerConsumer consumer, boolean failed) throws ActiveMQException
consumer - failed - ActiveMQExceptiondefault void afterCloseConsumer(ServerConsumer consumer, boolean failed) throws ActiveMQException
consumer - failed - ActiveMQExceptionCopyright © 2019 JBoss by Red Hat. All rights reserved.