Class AMQPFederationEventSupport

java.lang.Object
org.apache.activemq.artemis.protocol.amqp.connect.federation.AMQPFederationEventSupport
public final class AMQPFederationEventSupport extends Object
Tools used for sending and receiving events inside AMQP message instance.

  • Constructor Summary

    Constructors
    Constructor
    Description
    AMQPFederationEventSupport()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    static Map<String,Object>
    decodeAddressAddedEvent(AMQPMessage message)
    Decode and return the Map containing the event data for an Address that was the target of a previous federation request which was not present on the remote server or was later removed has now been (re)added.
    static Map<String,Object>
    decodeQueueAddedEvent(AMQPMessage message)
    Decode and return the Map containing the event data for a Queue that was the target of a previous federation request which was not present on the remote server or was later removed has now been (re)added.
    static AMQPMessage
    encodeAddressAddedEvent(String address)
    Encode an event that indicates that an Address that belongs to a federation request which was not present at the time of the request or was later removed is now present and the remote should check for demand and attempt to federate the resource once again.
    static AMQPMessage
    encodeQueueAddedEvent(String address, String queue)
    Encode an event that indicates that a Queue that belongs to a federation request which was not present at the time of the request or was later removed is now present and the remote should check for demand and attempt to federate the resource once again.

    Methods inherited from class Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • AMQPFederationEventSupport

      public AMQPFederationEventSupport()

  • Method Details

    • encodeQueueAddedEvent

      public static AMQPMessage encodeQueueAddedEvent(String address, String queue)
      Encode an event that indicates that a Queue that belongs to a federation request which was not present at the time of the request or was later removed is now present and the remote should check for demand and attempt to federate the resource once again.
      Parameters:
      address - The address that the queue is currently bound to.
      queue - The queue that was part of a previous federation request.
      Returns:
      the AMQP message with the encoded event data

    • encodeAddressAddedEvent

      public static AMQPMessage encodeAddressAddedEvent(String address)
      Encode an event that indicates that an Address that belongs to a federation request which was not present at the time of the request or was later removed is now present and the remote should check for demand and attempt to federate the resource once again.
      Parameters:
      address - The address portion of the previously failed federation request
      Returns:
      the AMQP message with the encoded event data

    • decodeQueueAddedEvent

      public static Map<String,Object> decodeQueueAddedEvent(AMQPMessage message) throws ActiveMQException
      Decode and return the Map containing the event data for a Queue that was the target of a previous federation request which was not present on the remote server or was later removed has now been (re)added.
      Parameters:
      message - The event message that carries the event data in its body.
      Returns:
      a Map containing the payload of the incoming event
      Throws:
      ActiveMQException - if an error occurs while decoding the event data.

    • decodeAddressAddedEvent

      public static Map<String,Object> decodeAddressAddedEvent(AMQPMessage message) throws ActiveMQException
      Decode and return the Map containing the event data for an Address that was the target of a previous federation request which was not present on the remote server or was later removed has now been (re)added.
      Parameters:
      message - The event message that carries the event data in its body.
      Returns:
      a Map containing the payload of the incoming event
      Throws:
      ActiveMQException - if an error occurs while decoding the event data.