通过

你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站，请访问 https://docs.azure.cn。

AmqpLink Interface

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

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