Share via

AmqpLink Interface

Package:
com.azure.core.amqp
Maven Artifact:
com.azure:azure-core-amqp:2.11.2

Implements

Disposable AsyncCloseable

public interface AmqpLink
extends Disposable, AsyncCloseable

Represents a unidirectional AMQP link.

Method Summary

Modifier and Type Method and Description
default Mono<Void> closeAsync()

Disposes of the AMQP link.
abstract Flux<AmqpEndpointState> getEndpointStates()

Gets the endpoint states for the AMQP link.
abstract String getEntityPath()

The remote endpoint path this link is connected to.
abstract String getHostname()

The host name of the message broker that this link that is connected to.
abstract String getLinkName()

Gets the name of the link.

Method Details

closeAsync

public default Mono<Void> closeAsync()

Disposes of the AMQP link.

Returns:

A mono that completes when the link is disposed.

getEndpointStates

public abstract Flux<AmqpEndpointState> getEndpointStates()

Gets the endpoint states for the AMQP link. AmqpException 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.

getEntityPath

public abstract String getEntityPath()

The remote endpoint path this link is connected to.

Returns:

The remote endpoint path this link is connected to.

getHostname

public abstract 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.

getLinkName

public abstract String getLinkName()

Gets the name of the link.

Returns:

The name of the link.

Applies to