Interface AMQPFederationProducerControl

All Known Implementing Classes:
AMQPFederationProducerControlType
public interface AMQPFederationProducerControl
Management interface that is backed by an active federation producer that was created when demand was applied to a matching address or queue on the remote broker that is bringing messages to itself via federation.

The federation producer sends messages for the given address or queue to a remote federation consumer.

  • Method Summary

    Modifier and Type
    Method
    Description
    String
    getAddress()
    Gets the address that will be used for this federation producer instance.
    String
    getFilterString()
    Gets the filter string that will be used when creating the federation producer.
    String
    getFqqn()
    Gets the local FQQN that comprises the address and queue where the remote producer will be attached.
    long
    getMessagesSent()
    Returns the number of messages this federation producer has sent to the remote.
    int
    getPriority()
    Gets the priority value that will be requested for the local subscription that feeds this federation producer with messages to send to the remote.
    String
    getQueueName()
    Gets the queue name that will be used for this federation producer instance.
    String
    getRole()
    Returns the type of federation producer being represented.
    String
    getRoutingType()
    Gets the routing type that will be requested when creating a producer on the local server.

  • Method Details

    • getMessagesSent

      long getMessagesSent()
      Returns the number of messages this federation producer has sent to the remote.
      Returns:
      the number of messages this federation producer has sent to the remote

    • getRole

      String getRole()
      Returns the type of federation producer being represented.
      Returns:
      the type of federation producer being represented

    • getQueueName

      String getQueueName()
      Gets the queue name that will be used for this federation producer instance.

      For Queue federation this will be the name of the queue whose messages are being federated from this server instance to the remote. For an Address federation this will be an automatically generated name that should be unique to a given federation producer instance.

      Returns:
      the queue name associated with the federation producer

    • getAddress

      String getAddress()
      Gets the address that will be used for this federation producer instance.

      For Queue federation this is the address under which the matching queue must reside. For Address federation this is the actual subscription address whose messages are being federated from the local address.

      Returns:
      the address associated with this federation producer

    • getFqqn

      String getFqqn()
      Gets the local FQQN that comprises the address and queue where the remote producer will be attached.
      Returns:
      provides the FQQN that can be used to address the producer queue directly

    • getRoutingType

      String getRoutingType()
      Gets the routing type that will be requested when creating a producer on the local server.
      Returns:
      the routing type of the federation producer

    • getFilterString

      String getFilterString()
      Gets the filter string that will be used when creating the federation producer.

      This is the filter string that is applied to the local subscription used to filter which message are actually sent to the remote broker.

      Returns:
      the filter string that will be used when creating the federation producer

    • getPriority

      int getPriority()
      Gets the priority value that will be requested for the local subscription that feeds this federation producer with messages to send to the remote.
      Returns:
      the assigned producer priority for the federation producer