-
Method Summary
default void
afterCloseConsumer(org.apache.activemq.artemis.core.server.ServerConsumer consumer,
boolean failed)
After a consumer is closed
default void
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
default void
beforeCreateConsumer(long consumerID,
org.apache.activemq.artemis.core.postoffice.QueueBinding queueBinding,
SimpleString filterString,
boolean browseOnly,
boolean supportLargeMessage)
Before a consumer is created
-
Method Details
-
beforeCreateConsumer
Deprecated.
Before a consumer is created
- Parameters:
consumerID
-
queueName
-
filterString
-
browseOnly
-
supportLargeMessage
-
- 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
- Parameters:
consumerID
-
queueBinding
-
filterString
-
browseOnly
-
supportLargeMessage
-
- 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
- Parameters:
consumer
-
failed
-
- Throws:
ActiveMQException
-
afterCloseConsumer
default void afterCloseConsumer(org.apache.activemq.artemis.core.server.ServerConsumer consumer,
boolean failed)
throws ActiveMQException
After a consumer is closed
- Parameters:
consumer
-
failed
-
- Throws:
ActiveMQException
beforeCreateConsumer(long, QueueBinding, SimpleString, boolean, boolean)