Interface ActiveMQServerConsumerPlugin

All Superinterfaces:
ActiveMQServerBasePlugin
All Known Subinterfaces:
ActiveMQServerPlugin

public interface ActiveMQServerConsumerPlugin extends ActiveMQServerBasePlugin
  • Method Details

    • beforeCreateConsumer

      @Deprecated default void beforeCreateConsumer(long consumerID, SimpleString queueName, SimpleString filterString, boolean browseOnly, boolean supportLargeMessage) throws ActiveMQException
      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