Interface AmqpLink

All Superinterfaces:
AsyncCloseable, Disposable

public interface AmqpLink extends Disposable, AsyncCloseable
Represents a unidirectional AMQP link.
  • Method Details

    • getLinkName

      String getLinkName()
      Gets the name of the link.
      Returns:
      The name of the link.
    • getEntityPath

      String getEntityPath()
      The remote endpoint path this link is connected to.
      Returns:
      The remote endpoint path this link is connected to.
    • getHostname

      String getHostname()
      The host name of the message broker that this link that is connected to.
      Returns:
      The host name of the message broker that this link that is connected to.
    • getEndpointStates

      Flux<AmqpEndpointState> getEndpointStates()
      Gets the endpoint states for the AMQP link. AmqpExceptions that occur on the link are reported in the connection state. When the stream terminates, the link is closed.
      Returns:
      A stream of endpoint states for the AMQP link.
    • closeAsync

      default Mono<Void> closeAsync()
      Disposes of the AMQP link.
      Specified by:
      closeAsync in interface AsyncCloseable
      Returns:
      A mono that completes when the link is disposed.