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, org.apache.activemq.artemis.api.core.SimpleString queueName, org.apache.activemq.artemis.api.core.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, org.apache.activemq.artemis.api.core.SimpleString filterString, boolean browseOnly, boolean supportLargeMessage)
    Before a consumer is created

    Methods inherited from interface ActiveMQServerBasePlugin

    init, registered, setInit, unregistered

  • Method Details

    • beforeCreateConsumer

      @Deprecated default void beforeCreateConsumer(long consumerID, org.apache.activemq.artemis.api.core.SimpleString queueName, org.apache.activemq.artemis.api.core.SimpleString filterString, boolean browseOnly, boolean supportLargeMessage) throws org.apache.activemq.artemis.api.core.ActiveMQException
      Deprecated.
      use beforeCreateConsumer(long, QueueBinding, SimpleString, boolean, boolean)
      Before a consumer is created
      Throws:
      org.apache.activemq.artemis.api.core.ActiveMQException

    • beforeCreateConsumer

      default void beforeCreateConsumer(long consumerID, org.apache.activemq.artemis.core.postoffice.QueueBinding queueBinding, org.apache.activemq.artemis.api.core.SimpleString filterString, boolean browseOnly, boolean supportLargeMessage) throws org.apache.activemq.artemis.api.core.ActiveMQException
      Before a consumer is created
      Throws:
      org.apache.activemq.artemis.api.core.ActiveMQException

    • afterCreateConsumer

      default void afterCreateConsumer(org.apache.activemq.artemis.core.server.ServerConsumer consumer) throws org.apache.activemq.artemis.api.core.ActiveMQException
      After a consumer has been created
      Parameters:
      consumer - the created consumer
      Throws:
      org.apache.activemq.artemis.api.core.ActiveMQException

    • beforeCloseConsumer

      default void beforeCloseConsumer(org.apache.activemq.artemis.core.server.ServerConsumer consumer, boolean failed) throws org.apache.activemq.artemis.api.core.ActiveMQException
      Before a consumer is closed
      Throws:
      org.apache.activemq.artemis.api.core.ActiveMQException

    • afterCloseConsumer

      default void afterCloseConsumer(org.apache.activemq.artemis.core.server.ServerConsumer consumer, boolean failed) throws org.apache.activemq.artemis.api.core.ActiveMQException
      After a consumer is closed
      Throws:
      org.apache.activemq.artemis.api.core.ActiveMQException