Class ClientConnection
- java.lang.Object
-
- org.apache.qpid.protonj2.client.impl.ClientConnection
-
- All Implemented Interfaces:
java.lang.AutoCloseable
,Connection
public final class ClientConnection extends java.lang.Object implements Connection
AConnection
implementation that uses the Proton engine for AMQP protocol support.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
checkClosedOrFailed()
ClientInstance
client()
void
close()
Requests a close of theConnection
at the remote and waits until the Connection has been fully closed or until the configuredConnectionOptions.closeTimeout()
is exceeded.void
close(ErrorCondition error)
Requests a close of theConnection
at the remote and waits until the Connection has been fully closed or until the configuredConnectionOptions.closeTimeout()
is exceeded.java.util.concurrent.Future<Connection>
closeAsync()
Requests a close of theConnection
at the remote and returns aFuture
that will be completed once the Connection has been fully closed.java.util.concurrent.Future<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.Sender
defaultSender()
Returns the default anonymous sender used by thisConnection
forConnection.send(Message)
calls.Session
defaultSession()
java.lang.String[]
desiredCapabilities()
Returns the desired capabilities that the remote provided upon successfully opening theConnection
.Receiver
nextReceiver()
Waits indefinitely for a receiver created from the connection default session to have a delivery ready for receipt.Receiver
nextReceiver(long timeout, java.util.concurrent.TimeUnit unit)
Waits for the configured time interval for a receiver created from the connection default session to have a delivery ready for receipt.Receiver
nextReceiver(NextReceiverPolicy policy)
Waits indefinitely for a receiver created from the connection default session to have a delivery ready for receipt.Receiver
nextReceiver(NextReceiverPolicy policy, long timeout, java.util.concurrent.TimeUnit unit)
Waits for the configured time interval for a receiver created from the connection default session to have a delivery ready for receipt.java.lang.String[]
offeredCapabilities()
Returns the offered capabilities that the remote provided upon successfully opening theConnection
.Sender
openAnonymousSender()
Creates a sender that is established to the 'anonymous relay' and as such each message that is sent using this sender must specify an address in its destination address field.Sender
openAnonymousSender(SenderOptions senderOptions)
Creates a sender that is established to the 'anonymous relay' and as such each message that is sent using this sender must specify an address in its destination address field.Receiver
openDurableReceiver(java.lang.String address, java.lang.String subscriptionName)
Creates a receiver used to consume messages from the given node address and configure it such that the remote create a durable node.Receiver
openDurableReceiver(java.lang.String address, java.lang.String subscriptionName, ReceiverOptions receiverOptions)
Creates a receiver used to consume messages from the given node address and configure it such that the remote create a durable node.Receiver
openDynamicReceiver()
Creates a dynamic receiver used to consume messages from the given node address.Receiver
openDynamicReceiver(java.util.Map<java.lang.String,java.lang.Object> dynamicNodeProperties)
Creates a dynamic receiver used to consume messages from a dynamically generated node on the remote..Receiver
openDynamicReceiver(java.util.Map<java.lang.String,java.lang.Object> dynamicNodeProperties, ReceiverOptions receiverOptions)
Creates a dynamic receiver used to consume messages from the given node address.Receiver
openDynamicReceiver(ReceiverOptions receiverOptions)
Creates a dynamic receiver used to consume messages from a dynamically generated node on the remote..java.util.concurrent.Future<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.Receiver
openReceiver(java.lang.String address)
Creates a receiver used to consumer messages from the given node address.Receiver
openReceiver(java.lang.String address, ReceiverOptions receiverOptions)
Creates a receiver used to consumer messages from the given node address.Sender
openSender(java.lang.String address)
Creates a sender used to send messages to the given node address.Sender
openSender(java.lang.String address, SenderOptions senderOptions)
Creates a sender used to send messages to the given node address.Session
openSession()
Creates a newSession
instance for use by the client application.Session
openSession(SessionOptions sessionOptions)
Creates a newSession
instance for use by the client application.StreamReceiver
openStreamReceiver(java.lang.String address)
Creates a streaming message receiver used to consume large messages from the given node address.StreamReceiver
openStreamReceiver(java.lang.String address, StreamReceiverOptions receiverOptions)
Creates a streaming message receiver used to consume large messages from the given node address.StreamSender
openStreamSender(java.lang.String address)
Creates a stream sender used to send large messages to the given node address.StreamSender
openStreamSender(java.lang.String address, StreamSenderOptions senderOptions)
Creates a streaming sender used to send large messages to the given node address.java.util.Map<java.lang.String,java.lang.Object>
properties()
Returns the properties that the remote provided upon successfully opening theConnection
.Tracker
send(Message<?> message)
Sends the givenMessage
using the internal connection sender.java.lang.String
toString()
-
-
-
Method Detail
-
client
public ClientInstance client()
- Specified by:
client
in interfaceConnection
- Returns:
- the
Client
instance that holds thisConnection
-
openFuture
public java.util.concurrent.Future<Connection> openFuture()
Description copied from interface:Connection
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. If the open of the connection fails at the remote anException
is thrown from theFuture.get()
method when called.- Specified by:
openFuture
in interfaceConnection
- Returns:
- a
Future
that will be completed when the remote opens thisConnection
.
-
close
public void close()
Description copied from interface:Connection
Requests a close of theConnection
at the remote and waits until the Connection has been fully closed or until the configuredConnectionOptions.closeTimeout()
is exceeded.- Specified by:
close
in interfacejava.lang.AutoCloseable
- Specified by:
close
in interfaceConnection
-
close
public void close(ErrorCondition error)
Description copied from interface:Connection
Requests a close of theConnection
at the remote and waits until the Connection has been fully closed or until the configuredConnectionOptions.closeTimeout()
is exceeded.- Specified by:
close
in interfaceConnection
- Parameters:
error
- TheErrorCondition
to transmit to the remote along with the close operation.
-
closeAsync
public java.util.concurrent.Future<Connection> closeAsync()
Description copied from interface:Connection
Requests a close of theConnection
at the remote and returns aFuture
that will be completed once the Connection has been fully closed.- Specified by:
closeAsync
in interfaceConnection
- Returns:
- a
Future
that will be completed when the remote closes thisConnection
.
-
closeAsync
public java.util.concurrent.Future<Connection> closeAsync(ErrorCondition error)
Description copied from interface:Connection
Requests a close of theConnection
at the remote and returns aFuture
that will be completed once the Connection has been fully closed.- Specified by:
closeAsync
in interfaceConnection
- Parameters:
error
- TheErrorCondition
to transmit to the remote along with the close operation.- Returns:
- a
Future
that will be completed when the remote closes thisConnection
.
-
defaultSession
public Session defaultSession() throws ClientException
Description copied from interface:Connection
Returns the defaultSession
instance that is used by this Connection to create the default anonymous connectionSender
as well as creating those resources created from theConnection
such asSender
andReceiver
instances not married to a specificSession
.- Specified by:
defaultSession
in interfaceConnection
- Returns:
- a new
Session
instance. - Throws:
ClientException
- if an internal error occurs.
-
openSession
public Session openSession() throws ClientException
Description copied from interface:Connection
Creates a newSession
instance for use by the client application. The returned session will be configured using default options and will take its timeout configuration values from those specified in the parentConnection
. The returnedSession
may not have been opened on the remote when it is returned. Some methods of theSession
can block until the remote fully opens the session, the user can wait for the remote to respond to the open request by calling theSession.openFuture()
method and using theFuture.get()
methods to wait for completion.- Specified by:
openSession
in interfaceConnection
- Returns:
- a new
Session
instance. - Throws:
ClientException
- if an internal error occurs.
-
openSession
public Session openSession(SessionOptions sessionOptions) throws ClientException
Description copied from interface:Connection
Creates a newSession
instance for use by the client application. The returnedSession
may not have been opened on the remote when it is returned. Some methods of theSession
can block until the remote fully opens the session, the user can wait for the remote to respond to the open request by calling theSession.openFuture()
method and using theFuture.get()
methods to wait for completion.- Specified by:
openSession
in interfaceConnection
- Parameters:
sessionOptions
- TheSessionOptions
that control properties of the created session.- Returns:
- a new
Session
instance. - Throws:
ClientException
- if an internal error occurs.
-
openReceiver
public Receiver openReceiver(java.lang.String address) throws ClientException
Description copied from interface:Connection
Creates a receiver used to consumer messages from the given node address. The returned receiver will be configured using default options and will take its timeout configuration values from those specified in the parentConnection
. The returned receiver may not have been opened on the remote when it is returned. Some methods of theReceiver
can block until the remote fully opens the receiver, the user can wait for the remote to respond to the open request by calling theLink.openFuture()
method and using theFuture.get()
methods to wait for completion.- Specified by:
openReceiver
in interfaceConnection
- Parameters:
address
- The source address to attach the consumer to.- Returns:
- the consumer.
- Throws:
ClientException
- if an internal error occurs.
-
openReceiver
public Receiver openReceiver(java.lang.String address, ReceiverOptions receiverOptions) throws ClientException
Description copied from interface:Connection
Creates a receiver used to consumer messages from the given node address. The returned receiver will be configured using the options provided in the givenReceiverOptions
instance. The returned receiver may not have been opened on the remote when it is returned. Some methods of theReceiver
can block until the remote fully opens the receiver, the user can wait for the remote to respond to the open request by calling theLink.openFuture()
method and using theFuture.get()
methods to wait for completion.- Specified by:
openReceiver
in interfaceConnection
- Parameters:
address
- The source address to attach the consumer to.receiverOptions
- The options for this receiver.- Returns:
- the newly created
Receiver
instance. - Throws:
ClientException
- if an internal error occurs.
-
openDurableReceiver
public Receiver openDurableReceiver(java.lang.String address, java.lang.String subscriptionName) throws ClientException
Description copied from interface:Connection
Creates a receiver used to consume messages from the given node address and configure it such that the remote create a durable node. The returned receiver will be configured using default options and will take its timeout configuration values from those specified in the parentConnection
. The returned receiver may not have been opened on the remote when it is returned. Some methods of theReceiver
can block until the remote fully opens the receiver, the user can wait for the remote to respond to the open request by calling theLink.openFuture()
method and using theFuture.get()
methods to wait for completion.- Specified by:
openDurableReceiver
in interfaceConnection
- Parameters:
address
- The source address to attach the consumer to.subscriptionName
- The name to give the subscription (link name).- Returns:
- the newly created
Receiver
instance. - Throws:
ClientException
- if an internal error occurs.
-
openDurableReceiver
public Receiver openDurableReceiver(java.lang.String address, java.lang.String subscriptionName, ReceiverOptions receiverOptions) throws ClientException
Description copied from interface:Connection
Creates a receiver used to consume messages from the given node address and configure it such that the remote create a durable node. The returned receiver will be configured using provided options. The returned receiver may not have been opened on the remote when it is returned. Some methods of theReceiver
can block until the remote fully opens the receiver, the user can wait for the remote to respond to the open request by calling theLink.openFuture()
method and using theFuture.get()
methods to wait for completion.- Specified by:
openDurableReceiver
in interfaceConnection
- Parameters:
address
- The source address to attach the consumer to.subscriptionName
- The name to give the subscription (link name).receiverOptions
- The options for this receiver.- Returns:
- the newly created
Receiver
instance. - Throws:
ClientException
- if an internal error occurs.
-
openDynamicReceiver
public Receiver openDynamicReceiver() throws ClientException
Description copied from interface:Connection
Creates a dynamic receiver used to consume messages from the given node address. The returned receiver will be configured using default options and will take its timeout configuration values from those specified in the parentConnection
. The returned receiver may not have been opened on the remote when it is returned. Some methods of theReceiver
can block until the remote fully opens the receiver, the user can wait for the remote to respond to the open request by calling theLink.openFuture()
method and using theFuture.get()
methods to wait for completion.- Specified by:
openDynamicReceiver
in interfaceConnection
- Returns:
- the newly created
Receiver
instance. - Throws:
ClientException
- if an internal error occurs.
-
openDynamicReceiver
public Receiver openDynamicReceiver(java.util.Map<java.lang.String,java.lang.Object> dynamicNodeProperties) throws ClientException
Description copied from interface:Connection
Creates a dynamic receiver used to consume messages from a dynamically generated node on the remote.. The returned receiver may not have been opened on the remote when it is returned. Some methods of theReceiver
can block until the remote fully opens the receiver, the user can wait for the remote to respond to the open request by calling theLink.openFuture()
method and using theFuture.get()
methods to wait for completion.- Specified by:
openDynamicReceiver
in interfaceConnection
- Parameters:
dynamicNodeProperties
- The dynamic node properties to be applied to the node created by the remote.- Returns:
- the newly created
Receiver
instance. - Throws:
ClientException
- if an internal error occurs.
-
openDynamicReceiver
public Receiver openDynamicReceiver(ReceiverOptions receiverOptions) throws ClientException
Description copied from interface:Connection
Creates a dynamic receiver used to consume messages from a dynamically generated node on the remote.. The returned receiver may not have been opened on the remote when it is returned. Some methods of theReceiver
can block until the remote fully opens the receiver, the user can wait for the remote to respond to the open request by calling theLink.openFuture()
method and using theFuture.get()
methods to wait for completion.- Specified by:
openDynamicReceiver
in interfaceConnection
- Parameters:
receiverOptions
- The options for this receiver.- Returns:
- the newly created
Receiver
instance. - Throws:
ClientException
- if an internal error occurs.
-
openDynamicReceiver
public Receiver openDynamicReceiver(java.util.Map<java.lang.String,java.lang.Object> dynamicNodeProperties, ReceiverOptions receiverOptions) throws ClientException
Description copied from interface:Connection
Creates a dynamic receiver used to consume messages from the given node address. The returned receiver may not have been opened on the remote when it is returned. Some methods of theReceiver
can block until the remote fully opens the receiver, the user can wait for the remote to respond to the open request by calling theLink.openFuture()
method and using theFuture.get()
methods to wait for completion.- Specified by:
openDynamicReceiver
in interfaceConnection
- Parameters:
dynamicNodeProperties
- The dynamic node properties to be applied to the node created by the remote.receiverOptions
- The options for this receiver.- Returns:
- the newly created
Receiver
instance. - Throws:
ClientException
- if an internal error occurs.
-
openStreamReceiver
public StreamReceiver openStreamReceiver(java.lang.String address) throws ClientException
Description copied from interface:Connection
Creates a streaming message receiver used to consume large messages from the given node address. The returnedStreamReceiver
will be configured using default options and will take its timeout configuration values from those specified in the parentConnection
. The returned stream receiver may not have been opened on the remote when it is returned. Some methods of theStreamReceiver
can block until the remote fully opens the receiver link, the user can wait for the remote to respond to the open request by calling theLink.openFuture()
method and using theFuture.get()
methods to wait for completion.- Specified by:
openStreamReceiver
in interfaceConnection
- Parameters:
address
- The source address to attach the consumer to.- Returns:
- the newly created
StreamReceiver
instance. - Throws:
ClientException
- if an internal error occurs.
-
openStreamReceiver
public StreamReceiver openStreamReceiver(java.lang.String address, StreamReceiverOptions receiverOptions) throws ClientException
Description copied from interface:Connection
Creates a streaming message receiver used to consume large messages from the given node address. The returned receiver will be configured using the options provided in the givenReceiverOptions
instance. The returnedStreamReceiver
may not have been opened on the remote when it is returned. Some methods of theStreamReceiver
can block until the remote fully opens the receiver link, the user can wait for the remote to respond to the open request by calling theLink.openFuture()
method and using theFuture.get()
methods to wait for completion.- Specified by:
openStreamReceiver
in interfaceConnection
- Parameters:
address
- The source address to attach the consumer to.receiverOptions
- The options for this receiver.- Returns:
- the newly created
StreamReceiver
instance. - Throws:
ClientException
- if an internal error occurs.
-
defaultSender
public Sender defaultSender() throws ClientException
Description copied from interface:Connection
Returns the default anonymous sender used by thisConnection
forConnection.send(Message)
calls. If the sender has not been created yet this call will initiate its creation and open with the remote peer.- Specified by:
defaultSender
in interfaceConnection
- Returns:
- the sender.
- Throws:
ClientException
- if an internal error occurs opening the default sender.ClientUnsupportedOperationException
- if the remote did not signal support for anonymous relays.
-
openSender
public Sender openSender(java.lang.String address) throws ClientException
Description copied from interface:Connection
Creates a sender used to send messages to the given node address. The returned sender will be configured using default options and will take its timeout configuration values from those specified in the parentConnection
. The returnedSender
may not have been opened on the remote when it is returned. Some methods of theSender
can block until the remote fully opens the sender, the user can wait for the remote to respond to the open request by calling theLink.openFuture()
method and using theFuture.get()
methods to wait for completion.- Specified by:
openSender
in interfaceConnection
- Parameters:
address
- The target address to attach to, cannot be null.- Returns:
- the sender.
- Throws:
ClientException
- if an internal error occurs.
-
openSender
public Sender openSender(java.lang.String address, SenderOptions senderOptions) throws ClientException
Description copied from interface:Connection
Creates a sender used to send messages to the given node address. The returnedSender
may not have been opened on the remote when it is returned. Some methods of theSender
can block until the remote fully opens the sender, the user can wait for the remote to respond to the open request by calling theLink.openFuture()
method and using theFuture.get()
methods to wait for completion.- Specified by:
openSender
in interfaceConnection
- Parameters:
address
- The target address to attach to, cannot be null.senderOptions
- The options for this sender.- Returns:
- the sender.
- Throws:
ClientException
- if an internal error occurs.
-
openAnonymousSender
public Sender openAnonymousSender() throws ClientException
Description copied from interface:Connection
Creates a sender that is established to the 'anonymous relay' and as such each message that is sent using this sender must specify an address in its destination address field. The returned sender will be configured using default options and will take its timeout configuration values from those specified in the parentConnection
. The returnedSender
may not have been opened on the remote when it is returned. Some methods of theSender
can block until the remote fully opens the sender, the user can wait for the remote to respond to the open request by calling theLink.openFuture()
method and using theFuture.get()
methods to wait for completion.- Specified by:
openAnonymousSender
in interfaceConnection
- Returns:
- the sender.
- Throws:
ClientException
- if an internal error occurs.ClientUnsupportedOperationException
- if the remote did not signal support for anonymous relays.
-
openAnonymousSender
public Sender openAnonymousSender(SenderOptions senderOptions) throws ClientException
Description copied from interface:Connection
Creates a sender that is established to the 'anonymous relay' and as such each message that is sent using this sender must specify an address in its destination address field. The returnedSender
may not have been opened on the remote when it is returned. Some methods of theSender
can block until the remote fully opens the sender, the user can wait for the remote to respond to the open request by calling theLink.openFuture()
method and using theFuture.get()
methods to wait for completion.- Specified by:
openAnonymousSender
in interfaceConnection
- Parameters:
senderOptions
- The options for this sender.- Returns:
- the sender.
- Throws:
ClientException
- if an internal error occurs.ClientUnsupportedOperationException
- if the remote did not signal support for anonymous relays.
-
openStreamSender
public StreamSender openStreamSender(java.lang.String address) throws ClientException
Description copied from interface:Connection
Creates a stream sender used to send large messages to the given node address. The returned sender will be configured using default options and will take its timeout configuration values from those specified in the parentConnection
. The returnedStreamSender
may not have been opened on the remote when it is returned. Some methods of theStreamSender
can block until the remote fully opens the sender, the user can wait for the remote to respond to the open request by calling theLink.openFuture()
method and using theFuture.get()
methods to wait for completion.- Specified by:
openStreamSender
in interfaceConnection
- Parameters:
address
- The target address to attach to, cannot be null.- Returns:
- the stream sender.
- Throws:
ClientException
- if an internal error occurs.
-
openStreamSender
public StreamSender openStreamSender(java.lang.String address, StreamSenderOptions senderOptions) throws ClientException
Description copied from interface:Connection
Creates a streaming sender used to send large messages to the given node address.The returned
StreamSender
may not have been opened on the remote when it is returned. Some methods of theStreamSender
can block until the remote fully opens the sender, the user can wait for the remote to respond to the open request by calling theLink.openFuture()
method and using theFuture.get()
methods to wait for completion.- Specified by:
openStreamSender
in interfaceConnection
- Parameters:
address
- The target address to attach to, cannot be null.senderOptions
- The options for this sender.- Returns:
- the sender.
- Throws:
ClientException
- if an internal error occurs.
-
send
public Tracker send(Message<?> message) throws ClientException
Description copied from interface:Connection
Sends the givenMessage
using the internal connection sender.The connection
Sender
is an anonymous AMQP sender which requires that the given message has a valid to value set.- Specified by:
send
in interfaceConnection
- Parameters:
message
- The message to send- Returns:
- a
Tracker
that allows the client to track settlement of the message. - Throws:
ClientException
- if an internal error occurs.
-
nextReceiver
public Receiver nextReceiver() throws ClientException
Description copied from interface:Connection
Waits indefinitely for a receiver created from the connection default session to have a delivery ready for receipt. The selection of the next receiver when more than one exists which has pending deliveries is based upon the configured value of theConnectionOptions.defaultNextReceiverPolicy()
.- Specified by:
nextReceiver
in interfaceConnection
- Returns:
- the next receiver that has a pending delivery available based on policy.
- Throws:
ClientException
- if an internal error occurs.
-
nextReceiver
public Receiver nextReceiver(long timeout, java.util.concurrent.TimeUnit unit) throws ClientException
Description copied from interface:Connection
Waits for the configured time interval for a receiver created from the connection default session to have a delivery ready for receipt. The selection of the next receiver when more than one exists which has pending deliveries is based upon the configured value of theConnectionOptions.defaultNextReceiverPolicy()
. If no receiver has an incoming delivery before the given timeout expires the method returns null.- Specified by:
nextReceiver
in interfaceConnection
- Parameters:
timeout
- The timeout value used to control how long the method waits for a newDelivery
to be available.unit
- The unit of time that the given timeout represents.- Returns:
- the next receiver that has a pending delivery available based on policy or null if the timeout is reached.
- Throws:
ClientException
- if an internal error occurs.
-
nextReceiver
public Receiver nextReceiver(NextReceiverPolicy policy) throws ClientException
Description copied from interface:Connection
Waits indefinitely for a receiver created from the connection default session to have a delivery ready for receipt. The selection of the next receiver when more than one exists which has pending deliveries is based upon the value of theNextReceiverPolicy
that is provided by the caller.- Specified by:
nextReceiver
in interfaceConnection
- Parameters:
policy
- The policy to apply when selecting the next receiver.- Returns:
- the next receiver that has a pending delivery available based on policy.
- Throws:
ClientException
- if an internal error occurs.
-
nextReceiver
public Receiver nextReceiver(NextReceiverPolicy policy, long timeout, java.util.concurrent.TimeUnit unit) throws ClientException
Description copied from interface:Connection
Waits for the configured time interval for a receiver created from the connection default session to have a delivery ready for receipt. The selection of the next receiver when more than one exists which has pending deliveries is based upon theNextReceiverPolicy
provided by the caller. If no receiver has an incoming delivery before the given timeout expires the method returns null.- Specified by:
nextReceiver
in interfaceConnection
- Parameters:
policy
- The policy to apply when selecting the next receiver.timeout
- The timeout value used to control how long the method waits for a newDelivery
to be available.unit
- The unit of time that the given timeout represents.- Returns:
- the next receiver that has a pending delivery available based on policy or null if the timeout is reached.
- Throws:
ClientException
- if an internal error occurs.
-
properties
public java.util.Map<java.lang.String,java.lang.Object> properties() throws ClientException
Description copied from interface:Connection
Returns the properties that the remote provided upon successfully opening theConnection
. If the open has not completed yet this method will block to await the open response which carries the remote properties. If the remote provides no properties this method will return null.- Specified by:
properties
in interfaceConnection
- Returns:
- any properties provided from the remote once the connection has successfully opened.
- Throws:
ClientException
- if an error occurs while obtaining theConnection
remote properties.
-
offeredCapabilities
public java.lang.String[] offeredCapabilities() throws ClientException
Description copied from interface:Connection
Returns the offered capabilities that the remote provided upon successfully opening theConnection
. If the open has not completed yet this method will block to await the open response which carries the remote offered capabilities. If the remote provides no capabilities this method will return null.- Specified by:
offeredCapabilities
in interfaceConnection
- Returns:
- any capabilities provided from the remote once the connection has successfully opened.
- Throws:
ClientException
- if an error occurs while obtaining theConnection
remote offered capabilities.
-
desiredCapabilities
public java.lang.String[] desiredCapabilities() throws ClientException
Description copied from interface:Connection
Returns the desired capabilities that the remote provided upon successfully opening theConnection
. If the open has not completed yet this method will block to await the open response which carries the remote desired capabilities. If the remote provides no capabilities this method will return null.- Specified by:
desiredCapabilities
in interfaceConnection
- Returns:
- any desired capabilities provided from the remote once the connection has successfully opened.
- Throws:
ClientException
- if an error occurs while obtaining theConnection
remote desired capabilities.
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
checkClosedOrFailed
protected void checkClosedOrFailed() throws ClientException
- Throws:
ClientException
-
-