Uses of Interface
org.apache.qpid.protonj2.client.Connection
-
Packages that use Connection Package Description org.apache.qpid.protonj2.client org.apache.qpid.protonj2.client.impl -
-
Uses of Connection in org.apache.qpid.protonj2.client
Methods in org.apache.qpid.protonj2.client that return Connection Modifier and Type Method Description Connection
Client. connect(String host)
Connect to the specified host, using the default port, without credentials and with all connection options set to their defaults.Connection
Client. connect(String host, int port)
Connect to the specified host and port, without credentials and with all connection options set to their defaults.Connection
Client. connect(String host, int port, ConnectionOptions options)
Connect to the specified host and port, with given connection options.Connection
Client. connect(String host, ConnectionOptions options)
Connect to the specified host, using the default port, without credentials and with all connection options set to their defaults.Connection
Link. connection()
Connection
Session. connection()
Methods in org.apache.qpid.protonj2.client that return types with arguments of type Connection Modifier and Type Method Description Future<Connection>
Connection. closeAsync()
Requests a close of theConnection
at the remote and returns aFuture
that will be completed once the Connection has been fully closed.Future<Connection>
Connection. closeAsync(ErrorCondition error)
Requests a close of theConnection
at the remote and returns aFuture
that will be completed once the Connection has been fully closed.BiConsumer<Connection,ConnectionEvent>
ConnectionOptions. connectedHandler()
BiConsumer<Connection,DisconnectionEvent>
ConnectionOptions. disconnectedHandler()
BiConsumer<Connection,DisconnectionEvent>
ConnectionOptions. interruptedHandler()
Future<Connection>
Connection. openFuture()
When aConnection
is created it may not be opened on the remote peer, the future returned from this method allows the caller to await the completion of the Connection open by the remote before proceeding on to other messaging operations.BiConsumer<Connection,ConnectionEvent>
ConnectionOptions. reconnectedHandler()
Method parameters in org.apache.qpid.protonj2.client with type arguments of type Connection Modifier and Type Method Description ConnectionOptions
ConnectionOptions. connectedHandler(BiConsumer<Connection,ConnectionEvent> connectedHandler)
Configures a handler that will be notified when aConnection
has established.ConnectionOptions
ConnectionOptions. disconnectedHandler(BiConsumer<Connection,DisconnectionEvent> disconnectedHandler)
Configures a handler that will be notified when the connection has failed and cannot be recovered should reconnect be enabled.ConnectionOptions
ConnectionOptions. interruptedHandler(BiConsumer<Connection,DisconnectionEvent> interruptedHandler)
Configures a handler that will be notified when the currentConnection
experiences an interruption.ConnectionOptions
ConnectionOptions. reconnectedHandler(BiConsumer<Connection,ConnectionEvent> reconnectedHandler)
Configures a handler that will be notified when aConnection
that has previously experienced and interruption has been reconnected to a remote based on the reconnection configuration. -
Uses of Connection in org.apache.qpid.protonj2.client.impl
Classes in org.apache.qpid.protonj2.client.impl that implement Connection Modifier and Type Class Description class
ClientConnection
AConnection
implementation that uses the Proton engine for AMQP protocol support.Methods in org.apache.qpid.protonj2.client.impl that return Connection Modifier and Type Method Description Connection
ClientInstance. connect(String host)
Connection
ClientInstance. connect(String host, int port)
Connection
ClientInstance. connect(String host, int port, ConnectionOptions options)
Connection
ClientInstance. connect(String host, ConnectionOptions options)
Methods in org.apache.qpid.protonj2.client.impl that return types with arguments of type Connection Modifier and Type Method Description Future<Connection>
ClientConnection. closeAsync()
Future<Connection>
ClientConnection. closeAsync(ErrorCondition error)
Future<Connection>
ClientConnection. openFuture()
-