Interface ActiveMQServerFederationPlugin

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

  • Method Summary

    Modifier and Type
    Method
    Description
    default void
    afterCloseFederatedQueueConsumer(org.apache.activemq.artemis.core.server.federation.FederatedQueueConsumer consumer)
    After a federated queue consumer is closed
    default void
    afterCreateFederatedQueueConsumer(org.apache.activemq.artemis.core.server.federation.FederatedQueueConsumer consumer)
    After a federated queue consumer is created
    default void
    afterFederatedQueueConsumerMessageHandled(org.apache.activemq.artemis.core.server.federation.FederatedQueueConsumer consumer, org.apache.activemq.artemis.api.core.Message message)
    After a federated queue consumer handles a message
    default void
    beforeCloseFederatedQueueConsumer(org.apache.activemq.artemis.core.server.federation.FederatedQueueConsumer consumer)
    Before a federated queue consumer is closed
    default void
    beforeCreateFederatedQueueConsumer(org.apache.activemq.artemis.core.server.federation.FederatedConsumerKey key)
    Before a federated queue consumer is created
    default void
    beforeFederatedQueueConsumerMessageHandled(org.apache.activemq.artemis.core.server.federation.FederatedQueueConsumer consumer, org.apache.activemq.artemis.api.core.Message message)
    Before a federated queue consumer handles a message
    default boolean
    federatedAddressConditionalCreateConsumer(org.apache.activemq.artemis.core.server.Queue queue)
    Conditionally create a federated queue consumer for a federated address.
    default boolean
    federatedAddressConditionalCreateDivertConsumer(org.apache.activemq.artemis.core.postoffice.impl.DivertBinding divertBinding, org.apache.activemq.artemis.core.postoffice.QueueBinding queueBinding)
     
    default boolean
    federatedQueueConditionalCreateConsumer(org.apache.activemq.artemis.core.server.ServerConsumer consumer)
    Conditionally create a federated queue consumer for a federated queue.
    default void
    federationStreamStarted(org.apache.activemq.artemis.core.server.federation.FederationStream stream)
    After a federation stream has been started
    default void
    federationStreamStopped(org.apache.activemq.artemis.core.server.federation.FederationStream stream)
    After a federation stream has been stopped

    Methods inherited from interface ActiveMQServerBasePlugin

    init, registered, setInit, unregistered

  • Method Details

    • federationStreamStarted

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

    • federationStreamStopped

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

    • beforeCreateFederatedQueueConsumer

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

    • afterCreateFederatedQueueConsumer

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

    • beforeCloseFederatedQueueConsumer

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

    • afterCloseFederatedQueueConsumer

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

    • beforeFederatedQueueConsumerMessageHandled

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

    • afterFederatedQueueConsumerMessageHandled

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

    • federatedAddressConditionalCreateConsumer

      default boolean federatedAddressConditionalCreateConsumer(org.apache.activemq.artemis.core.server.Queue queue) throws org.apache.activemq.artemis.api.core.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:
      org.apache.activemq.artemis.api.core.ActiveMQException

    • federatedAddressConditionalCreateDivertConsumer

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

    • federatedQueueConditionalCreateConsumer

      default boolean federatedQueueConditionalCreateConsumer(org.apache.activemq.artemis.core.server.ServerConsumer consumer) throws org.apache.activemq.artemis.api.core.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:
      org.apache.activemq.artemis.api.core.ActiveMQException