Package com.azure.core.amqp

Interface AmqpConnection

All Superinterfaces:
AsyncCloseable, Disposable
public interface AmqpConnection extends Disposable, AsyncCloseable
Represents a TCP connection between the client and a service that uses the AMQP protocol.

  • Method Details

    • getId

      String getId()
      Gets the connection identifier.
      Returns:
      The connection identifier.

    • getFullyQualifiedNamespace

      String getFullyQualifiedNamespace()
      Gets the fully qualified namespace for the AMQP connection.
      Returns:
      The hostname for the AMQP connection.

    • getMaxFrameSize

      int getMaxFrameSize()
      Gets the maximum frame size for the connection.
      Returns:
      The maximum frame size for the connection.

    • getConnectionProperties

      Map<String,Object> getConnectionProperties()
      Gets the connection properties.
      Returns:
      Properties associated with this connection.

    • getClaimsBasedSecurityNode

      Mono<ClaimsBasedSecurityNode> getClaimsBasedSecurityNode()
      Gets the claims-based security (CBS) node that authorizes access to resources.
      Returns:
      Provider that authorizes access to AMQP resources.

    • createSession

      Mono<AmqpSession> createSession(String sessionName)
      Creates a new session with the given session name.
      Parameters:
      sessionName - Name of the session.
      Returns:
      The AMQP session that was created.

    • removeSession

      boolean removeSession(String sessionName)
      Removes a session with the sessionName from the AMQP connection.
      Parameters:
      sessionName - Name of the session to remove.
      Returns:
      true if a session with the name was removed; false otherwise.

    • getEndpointStates

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

    • getShutdownSignals

      Flux<AmqpShutdownSignal> getShutdownSignals()
      Gets any shutdown signals that occur in the AMQP endpoint.
      Returns:
      A stream of shutdown signals that occur in the AMQP endpoint.

    • getManagementNode

      default Mono<AmqpManagementNode> getManagementNode(String entityPath)
      Gets or creates the management node.
      Parameters:
      entityPath - Entity for which to get the management node of.
      Returns:
      A Mono that completes with the management node.
      Throws:
      UnsupportedOperationException - if there is no implementation of fetching a management node.

    • closeAsync

      default Mono<Void> closeAsync()
      Disposes of the AMQP connection.
      Specified by:
      closeAsync in interface AsyncCloseable
      Returns:
      Mono that completes when the close operation is complete.