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

Interface ActiveMQServerFederationPlugin

All Superinterfaces:
ActiveMQServerBasePlugin
All Known Subinterfaces:
ActiveMQServerPlugin
public interface ActiveMQServerFederationPlugin extends ActiveMQServerBasePlugin

  • Method Details

    • federationStreamStarted

      default void federationStreamStarted(org.apache.activemq.artemis.core.server.federation.FederationStream stream) throws ActiveMQException
      After a federation stream has been started
      Throws:
      ActiveMQException

    • federationStreamStopped

      default void federationStreamStopped(org.apache.activemq.artemis.core.server.federation.FederationStream stream) throws ActiveMQException
      After a federation stream has been stopped
      Throws:
      ActiveMQException

    • beforeCreateFederatedQueueConsumer

      default void beforeCreateFederatedQueueConsumer(org.apache.activemq.artemis.core.server.federation.FederatedConsumerKey key) throws ActiveMQException
      Before a federated queue consumer is created
      Throws:
      ActiveMQException

    • afterCreateFederatedQueueConsumer

      default void afterCreateFederatedQueueConsumer(org.apache.activemq.artemis.core.server.federation.FederatedQueueConsumer consumer) throws ActiveMQException
      After a federated queue consumer is created
      Throws:
      ActiveMQException

    • beforeCloseFederatedQueueConsumer

      default void beforeCloseFederatedQueueConsumer(org.apache.activemq.artemis.core.server.federation.FederatedQueueConsumer consumer) throws ActiveMQException
      Before a federated queue consumer is closed
      Throws:
      ActiveMQException

    • afterCloseFederatedQueueConsumer

      default void afterCloseFederatedQueueConsumer(org.apache.activemq.artemis.core.server.federation.FederatedQueueConsumer consumer) throws ActiveMQException
      After a federated queue consumer is closed
      Throws:
      ActiveMQException

    • beforeFederatedQueueConsumerMessageHandled

      default void beforeFederatedQueueConsumerMessageHandled(org.apache.activemq.artemis.core.server.federation.FederatedQueueConsumer consumer, Message message) throws ActiveMQException
      Before a federated queue consumer handles a message
      Throws:
      ActiveMQException

    • afterFederatedQueueConsumerMessageHandled

      default void afterFederatedQueueConsumerMessageHandled(org.apache.activemq.artemis.core.server.federation.FederatedQueueConsumer consumer, Message message) throws ActiveMQException
      After a federated queue consumer handles a message
      Throws:
      ActiveMQException

    • federatedAddressConditionalCreateConsumer

      default boolean federatedAddressConditionalCreateConsumer(org.apache.activemq.artemis.core.server.Queue queue) throws ActiveMQException
      Conditionally create a federated queue consumer for a federated address. This allows custom logic to be inserted to decide when to create federated queue consumers
      Returns:
      if true, create the consumer, else if false don't create
      Throws:
      ActiveMQException

    • federatedAddressConditionalCreateDivertConsumer

      default boolean federatedAddressConditionalCreateDivertConsumer(org.apache.activemq.artemis.core.postoffice.impl.DivertBinding divertBinding, org.apache.activemq.artemis.core.postoffice.QueueBinding queueBinding) throws ActiveMQException
      Throws:
      ActiveMQException

    • federatedQueueConditionalCreateConsumer

      default boolean federatedQueueConditionalCreateConsumer(org.apache.activemq.artemis.core.server.ServerConsumer consumer) throws ActiveMQException
      Conditionally create a federated queue consumer for a federated queue. This allows custom logic to be inserted to decide when to create federated queue consumers
      Returns:
      true, create the consumer, else if false don't create
      Throws:
      ActiveMQException