Uses of Class
org.apache.qpid.protonj2.client.exceptions.ClientException

Packages that use ClientException

Package	Description
org.apache.qpid.protonj2.client
org.apache.qpid.protonj2.client.exceptions
org.apache.qpid.protonj2.client.futures
org.apache.qpid.protonj2.client.impl

Uses of ClientException in org.apache.qpid.protonj2.client

Methods in org.apache.qpid.protonj2.client that throw ClientException

Modifier and Type	Method	Description
StreamSenderMessage	StreamSenderMessage.abort()	Marks the currently streaming message as being aborted.
long	Message.absoluteExpiryTime()
Message<E>	Message.absoluteExpiryTime(long expiryTime)	Sets the absolute expiration time value to assign to this Message.
Delivery	Delivery.accept()	Accepts and settles the delivery.
StreamDelivery	StreamDelivery.accept()	Accepts and settles the delivery.
AdvancedMessage<E>	AdvancedMessage.addBodySection(Section<?> bodySection)	Adds the given Section to the internal collection of sections that will be sent to the remote peer when this message is encoded.
Receiver	Receiver.addCredit(int credits)	Adds credit to the Receiver link for use when there receiver has not been configured with a credit window.
StreamReceiver	StreamReceiver.addCredit(int credits)	Adds credit to the Receiver link for use when there receiver has not been configured with a credit window.
java.lang.String	Receiver.address()	Returns the address that the Receiver instance will be subscribed to.
java.lang.String	Sender.address()	Returns the address that the Sender instance will send Message objects to.
java.lang.Object	Message.annotation(java.lang.String key)	Returns the requested message annotation value from this Message if it exists or returns null otherwise.
Message<E>	Message.annotation(java.lang.String key, java.lang.Object value)	Sets the given message annotation value at the given key, replacing any previous value that was assigned to this Message.
MessageAnnotations	AdvancedMessage.annotations()	Return the current MessageAnnotations assigned to this message, if none was assigned yet then this method returns null.
AdvancedMessage<E>	AdvancedMessage.annotations(MessageAnnotations messageAnnotations)	Assign or replace the MessageAnnotations instance associated with this message.
java.util.Map<java.lang.String,java.lang.Object>	Delivery.annotations()	Decodes the Delivery payload and returns a Map containing a copy of any associated DeliveryAnnotations that were transmitted with the Message payload of this Delivery.
ApplicationProperties	AdvancedMessage.applicationProperties()	Return the current ApplicationProperties assigned to this message, if none was assigned yet then this method returns null.
AdvancedMessage<E>	AdvancedMessage.applicationProperties(ApplicationProperties applicationProperties)	Assign or replace the ApplicationProperties instance associated with this message.
Tracker	Tracker.awaitAccepted()	Waits if necessary for the remote to settle the sent delivery with an Accepted disposition unless it has either already been settled and accepted or the original delivery was sent settled in which case the remote will not send a Disposition back.
Tracker	Tracker.awaitAccepted(long timeout, java.util.concurrent.TimeUnit unit)	Waits if necessary for the remote to settle the sent delivery with an Accepted disposition unless it has either already been settled and accepted or the original delivery was sent settled in which case the remote will not send a Disposition back.
StreamTracker	StreamTracker.awaitSettlement()	Waits if necessary for the remote to settle the sent delivery unless it has either already been settled or the original delivery was sent settled in which case the remote will not send a Disposition back.
StreamTracker	StreamTracker.awaitSettlement(long timeout, java.util.concurrent.TimeUnit unit)	Waits if necessary for the remote to settle the sent delivery unless it has either already been settled or the original delivery was sent settled in which case the remote will not send a Disposition back.
Tracker	Tracker.awaitSettlement()	Waits if necessary for the remote to settle the sent delivery unless it has either already been settled or the original delivery was sent settled in which case the remote will not send a Disposition back.
Tracker	Tracker.awaitSettlement(long timeout, java.util.concurrent.TimeUnit unit)	Waits if necessary for the remote to settle the sent delivery unless it has either already been settled or the original delivery was sent settled in which case the remote will not send a Disposition back.
StreamSenderMessage	StreamSender.beginMessage()	Creates and returns a new StreamSenderMessage that can be used by the caller to perform streaming sends of large message payload data.
StreamSenderMessage	StreamSender.beginMessage(java.util.Map<java.lang.String,java.lang.Object> deliveryAnnotations)	Creates and returns a new StreamSenderMessage that can be used by the caller to perform streaming sends of large message payload data.
Session	Session.beginTransaction()	Opens a new transaction scoped to this Session if one is not already active.
E	Message.body()	Returns the body value that is conveyed in this message or null if no body was set locally or sent from the remote if this is an incoming message.
Message<E>	Message.body(E value)	Sets the body value that is to be conveyed to the remote when this message is sent.
java.io.OutputStream	StreamSenderMessage.body(OutputStreamOptions options)	Creates an OutputStream instance configured with the given options which will write the bytes as the payload of one or more AMQP Data sections based on the provided configuration..
java.util.Collection<Section<?>>	AdvancedMessage.bodySections()	Create and return an unmodifiable Collection that contains the Section instances currently assigned to this message.
AdvancedMessage<E>	AdvancedMessage.bodySections(java.util.Collection<Section<?>> sections)	Sets the body Section instances to use when encoding this message.
AdvancedMessage<E>	AdvancedMessage.clearBodySections()	Clears all current body Section elements from the AdvancedMessage.
Session	Session.commitTransaction()	Commit the currently active transaction in this Session.
StreamSenderMessage	StreamSenderMessage.complete()	Marks the currently streaming message as being complete.
Connection	Client.connect(java.lang.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(java.lang.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(java.lang.String host, int port, ConnectionOptions options)	Connect to the specified host and port, with given connection options.
Connection	Client.connect(java.lang.String host, ConnectionOptions options)	Connect to the specified host, using the default port, without credentials and with all connection options set to their defaults.
java.lang.String	Message.contentEncoding()
Message<?>	Message.contentEncoding(java.lang.String contentEncoding)	Sets the contentEncoding value to assign to this Message.
java.lang.String	Message.contentType()
Message<E>	Message.contentType(java.lang.String contentType)	Sets the contentType value to assign to this Message.
java.lang.Object	Message.correlationId()
Message<E>	Message.correlationId(java.lang.Object correlationId)	Sets the correlationId value to assign to this Message.
long	Message.creationTime()
Message<E>	Message.creationTime(long createTime)	Sets the creation time value to assign to this Message.
Sender	Connection.defaultSender()	Returns the default anonymous sender used by this Connection for Connection.send(Message) calls.
Session	Connection.defaultSession()	Returns the default Session instance that is used by this Connection to create the default anonymous connection Sender as well as creating those resources created from the Connection such as Sender and Receiver instances not married to a specific Session.
long	Message.deliveryCount()
Message<E>	Message.deliveryCount(long deliveryCount)	Sets the value to assign to the delivery count field of this Message.
java.lang.String[]	Connection.desiredCapabilities()	Returns the desired capabilities that the remote provided upon successfully opening the Connection.
java.lang.String[]	Receiver.desiredCapabilities()	Returns the desired capabilities that the remote provided upon successfully opening the Receiver.
java.lang.String[]	Sender.desiredCapabilities()	Returns the desired capabilities that the remote provided upon successfully opening the Sender.
java.lang.String[]	Session.desiredCapabilities()	Returns the desired capabilities that the remote provided upon successfully opening the Session.
Delivery	Delivery.disposition(DeliveryState state, boolean settle)	Updates the DeliveryState, and optionally settle the delivery as well.
StreamDelivery	StreamDelivery.disposition(DeliveryState state, boolean settle)	Updates the DeliveryState, and optionally settle the delivery as well.
StreamTracker	StreamTracker.disposition(DeliveryState state, boolean settle)	Updates the DeliveryState, and optionally settle the delivery as well.
Tracker	Tracker.disposition(DeliveryState state, boolean settle)	Updates the DeliveryState, and optionally settle the delivery as well.
java.util.concurrent.Future<Receiver>	Receiver.drain()	Requests the remote to drain previously granted credit for this Receiver link.
boolean	Message.durable()	For an message being sent this method returns the current state of the durable flag on the message.
Message<E>	Message.durable(boolean durable)	Controls if the message is marked as durable when sent.
ProtonBuffer	AdvancedMessage.encode(java.util.Map<java.lang.String,java.lang.Object> deliveryAnnotations)	Encodes the AdvancedMessage for transmission by the client.
boolean	Message.firstAcquirer()
Message<E>	Message.firstAcquirer(boolean firstAcquirer)	Sets the value to assign to the first acquirer field of this Message.
Footer	AdvancedMessage.footer()	Return the current Footer assigned to this message, if none was assigned yet then this method returns null.
AdvancedMessage<E>	AdvancedMessage.footer(Footer footer)	Assign or replace the Footer instance associated with this message.
java.lang.Object	Message.footer(java.lang.String key)	Returns the requested footer value from this Message if it exists or returns null otherwise.
Message<E>	Message.footer(java.lang.String key, java.lang.Object value)	Sets the given footer value at the given key, replacing any previous value that was assigned to this Message.
Message<E>	Message.forEachAnnotation(java.util.function.BiConsumer<java.lang.String,java.lang.Object> action)	Invokes the given BiConsumer on each message annotation entry carried in this Message.
AdvancedMessage<E>	AdvancedMessage.forEachBodySection(java.util.function.Consumer<Section<?>> consumer)	Performs the given action for each body Section of the AdvancedMessage until all sections have been presented to the given Consumer or the consumer throws an exception.
Message<E>	Message.forEachFooter(java.util.function.BiConsumer<java.lang.String,java.lang.Object> action)	Invokes the given BiConsumer on each footer entry carried in this Message.
Message<E>	Message.forEachProperty(java.util.function.BiConsumer<java.lang.String,java.lang.Object> action)	Invokes the given BiConsumer on each application property entry carried in this Message.
java.lang.String	Message.groupId()
Message<E>	Message.groupId(java.lang.String groupId)	Sets the groupId value to assign to this Message.
int	Message.groupSequence()
Message<E>	Message.groupSequence(int groupSequence)	Sets the group sequence value to assign to this Message.
boolean	Message.hasAnnotation(java.lang.String key)	Query the Message to determine if it carries the given message annotation key.
boolean	Message.hasAnnotations()	Query the Message to determine if it carries any message annotations.
boolean	Message.hasFooter(java.lang.String key)	Query the Message to determine if it carries the given footer key.
boolean	Message.hasFooters()	Query the Message to determine if it carries any footers.
boolean	Message.hasProperties()	Query the Message to determine if it carries any application properties.
boolean	Message.hasProperty(java.lang.String key)	Query the Message to determine if it carries the given application property key.
Header	AdvancedMessage.header()	Return the current Header assigned to this message, if none was assigned yet then this method returns null.
AdvancedMessage<E>	AdvancedMessage.header(Header header)	Assign or replace the Header instance associated with this message.
<E> Message<E>	Delivery.message()	Decode the Delivery payload and return an Message object.
StreamReceiverMessage	StreamDelivery.message()	Decode the Delivery payload and return an Message object.
int	AdvancedMessage.messageFormat()
AdvancedMessage<E>	AdvancedMessage.messageFormat(int messageFormat)	Sets the message format to use when the message is sent.
int	Delivery.messageFormat()	Gets the message format for the current delivery.
StreamSenderMessage	StreamSenderMessage.messageFormat(int messageFormat)	Sets the configured message format value that will be set on the first outgoing AMQP Transfer frame for the delivery that comprises this streamed message.
java.lang.Object	Message.messageId()
Message<E>	Message.messageId(java.lang.Object messageId)	Sets the message Id value to assign to this Message.
Delivery	Delivery.modified(boolean deliveryFailed, boolean undeliverableHere)	Modifies and settles the delivery.
StreamDelivery	StreamDelivery.modified(boolean deliveryFailed, boolean undeliverableHere)	Modifies and settles the delivery.
java.lang.String[]	Connection.offeredCapabilities()	Returns the offered capabilities that the remote provided upon successfully opening the Connection.
java.lang.String[]	Receiver.offeredCapabilities()	Returns the offered capabilities that the remote provided upon successfully opening the Receiver.
java.lang.String[]	Sender.offeredCapabilities()	Returns the offered capabilities that the remote provided upon successfully opening the Sender.
java.lang.String[]	Session.offeredCapabilities()	Returns the offered capabilities that the remote provided upon successfully opening the Session.
Sender	Connection.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	Connection.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.
Sender	Session.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	Session.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	Connection.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	Connection.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	Session.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	Session.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	Connection.openDynamicReceiver()	Creates a dynamic receiver used to consume messages from the given node address.
Receiver	Connection.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	Connection.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	Connection.openDynamicReceiver(ReceiverOptions receiverOptions)	Creates a dynamic receiver used to consume messages from a dynamically generated node on the remote..
Receiver	Session.openDynamicReceiver()	Creates a dynamic receiver used to consume messages from the given node address.
Receiver	Session.openDynamicReceiver(java.util.Map<java.lang.String,java.lang.Object> dynamicNodeProperties)	Creates a dynamic receiver used to consume messages from the given node address.
Receiver	Session.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	Session.openDynamicReceiver(ReceiverOptions receiverOptions)	Creates a dynamic receiver used to consume messages from the given node address.
Receiver	Connection.openReceiver(java.lang.String address)	Creates a receiver used to consumer messages from the given node address.
Receiver	Connection.openReceiver(java.lang.String address, ReceiverOptions receiverOptions)	Creates a receiver used to consumer messages from the given node address.
Receiver	Session.openReceiver(java.lang.String address)	Creates a receiver used to consume messages from the given node address.
Receiver	Session.openReceiver(java.lang.String address, ReceiverOptions receiverOptions)	Creates a receiver used to consume messages from the given node address.
Sender	Connection.openSender(java.lang.String address)	Creates a sender used to send messages to the given node address.
Sender	Connection.openSender(java.lang.String address, SenderOptions senderOptions)	Creates a sender used to send messages to the given node address.
Sender	Session.openSender(java.lang.String address)	Creates a sender used to send messages to the given node address.
Sender	Session.openSender(java.lang.String address, SenderOptions senderOptions)	Creates a sender used to send messages to the given node address.
Session	Connection.openSession()	Creates a new Session instance for use by the client application.
Session	Connection.openSession(SessionOptions options)	Creates a new Session instance for use by the client application.
StreamReceiver	Connection.openStreamReceiver(java.lang.String address)	Creates a streaming message receiver used to consume large messages from the given node address.
StreamReceiver	Connection.openStreamReceiver(java.lang.String address, StreamReceiverOptions receiverOptions)	Creates a streaming message receiver used to consume large messages from the given node address.
StreamSender	Connection.openStreamSender(java.lang.String address)	Creates a stream sender used to send large messages to the given node address.
StreamSender	Connection.openStreamSender(java.lang.String address, StreamSenderOptions senderOptions)	Creates a streaming sender used to send large messages to the given node address.
byte	Message.priority()
Message<E>	Message.priority(byte priority)	Sets the relative message priority.
Properties	AdvancedMessage.properties()	Return the current Properties assigned to this message, if none was assigned yet then this method returns null.
AdvancedMessage<E>	AdvancedMessage.properties(Properties properties)	Assign or replace the Properties instance associated with this message.
java.util.Map<java.lang.String,java.lang.Object>	Connection.properties()	Returns the properties that the remote provided upon successfully opening the Connection.
java.util.Map<java.lang.String,java.lang.Object>	Receiver.properties()	Returns the properties that the remote provided upon successfully opening the Receiver.
java.util.Map<java.lang.String,java.lang.Object>	Sender.properties()	Returns the properties that the remote provided upon successfully opening the Sender.
java.util.Map<java.lang.String,java.lang.Object>	Session.properties()	Returns the properties that the remote provided upon successfully opening the Session.
java.lang.Object	Message.property(java.lang.String key)	Returns the requested application property value from this Message if it exists or returns null otherwise.
Message<E>	Message.property(java.lang.String key, java.lang.Object value)	Sets the given application property value at the given key, replacing any previous value that was assigned to this Message.
long	Receiver.queuedDeliveries()	Returns the number of Deliveries that are currently held in the Receiver delivery queue.
java.io.InputStream	Delivery.rawInputStream()	Create and return an InputStream that reads the raw payload bytes of the given Delivery.
java.io.OutputStream	StreamSenderMessage.rawOutputStream()	Creates an OutputStream instance that writes the bytes given without additional encoding or transformation.
Delivery	Receiver.receive()	Blocking receive method that waits forever for the remote to provide a Delivery for consumption.
Delivery	Receiver.receive(long timeout, java.util.concurrent.TimeUnit unit)	Blocking receive method that waits the given time interval for the remote to provide a Delivery for consumption.
StreamDelivery	StreamReceiver.receive()	Blocking receive method that waits forever for the remote to provide a StreamReceiverMessage for consumption.
StreamDelivery	StreamReceiver.receive(long timeout, java.util.concurrent.TimeUnit unit)	Blocking receive method that waits the given time interval for the remote to provide a StreamReceiverMessage for consumption.
Delivery	Delivery.reject(java.lang.String condition, java.lang.String description)	Rejects and settles the delivery, sending supplied error information along with the rejection.
StreamDelivery	StreamDelivery.reject(java.lang.String condition, java.lang.String description)	Rejects and settles the delivery, sending supplied error information along with the rejection.
Delivery	Delivery.release()	Releases and settles the delivery.
StreamDelivery	StreamDelivery.release()	Releases and settles the delivery.
boolean	Delivery.remoteSettled()	Gets whether the delivery was settled by the remote peer yet.
DeliveryState	Delivery.remoteState()	Gets the current remote state for the delivery.
java.lang.Object	Message.removeAnnotation(java.lang.String key)	Removes the given message annotation from the values carried in the message currently, if none was present than this method returns null.
java.lang.Object	Message.removeFooter(java.lang.String key)	Removes the given footer from the values carried in the message currently, if none was present than this method returns null.
java.lang.Object	Message.removeProperty(java.lang.String key)	Removes the given application property from the values carried in the message currently, if none was present than this method returns null.
java.lang.String	Message.replyTo()
Message<E>	Message.replyTo(java.lang.String replyTo)	Sets the replyTo value to assign to this Message.
java.lang.String	Message.replyToGroupId()
Message<E>	Message.replyToGroupId(java.lang.String replyToGroupId)	Sets the replyTo group Id value to assign to this Message.
Session	Session.rollbackTransaction()	Roll back the currently active transaction in this Session.
Tracker	Connection.send(Message<?> message)	Sends the given Message using the internal connection sender.
Tracker	Sender.send(Message<?> message)	Send the given message immediately if there is credit available or blocks if the link has not yet been granted credit.
Tracker	Sender.send(Message<?> message, java.util.Map<java.lang.String,java.lang.Object> deliveryAnnotations)	Send the given message immediately if there is credit available or blocks if the link has not yet been granted credit.
Delivery	Delivery.settle()	Settles the delivery locally.
StreamDelivery	StreamDelivery.settle()	Settles the delivery locally.
StreamTracker	StreamTracker.settle()	Settles the delivery locally, if not auto-settling.
Tracker	Tracker.settle()	Settles the delivery locally, if not auto-settling.
boolean	Delivery.settled()
Source	Receiver.source()	Returns an immutable view of the remote Source object assigned to this receiver link.
Source	Sender.source()	Returns an immutable view of the remote Source object assigned to this sender link.
DeliveryState	Delivery.state()	Gets the current local state for the delivery.
java.lang.String	Message.subject()
Message<E>	Message.subject(java.lang.String subject)	Sets the subject value to assign to this Message.
Target	Receiver.target()	Returns an immutable view of the remote Target object assigned to this receiver link.
Target	Sender.target()	Returns an immutable view of the remote Target object assigned to this sender link.
long	Message.timeToLive()
Message<E>	Message.timeToLive(long timeToLive)	Sets the message time to live value.
java.lang.String	Message.to()
Message<E>	Message.to(java.lang.String to)	Sets the 'to' value to assign to this Message.
default AdvancedMessage<E>	Message.toAdvancedMessage()	Safely convert this Message instance into an AdvancedMessage reference which can offer more low level APIs to an experienced client user.
Delivery	Receiver.tryReceive()	Non-blocking receive method that either returns a message is one is immediately available or returns null if none is currently at hand.
StreamDelivery	StreamReceiver.tryReceive()	Non-blocking receive method that either returns a message is one is immediately available or returns null if none is currently at hand.
Tracker	Sender.trySend(Message<?> message)	Send the given message if credit is available or returns null if no credit has been granted to the link at the time of the send attempt.
Tracker	Sender.trySend(Message<?> message, java.util.Map<java.lang.String,java.lang.Object> deliveryAnnotations)	Send the given message if credit is available or returns null if no credit has been granted to the link at the time of the send attempt.
byte[]	Message.userId()
Message<E>	Message.userId(byte[] userId)	Sets the user Id value to assign to this Message.

Uses of ClientException in org.apache.qpid.protonj2.client.exceptions

Subclasses of ClientException in org.apache.qpid.protonj2.client.exceptions

Modifier and Type	Class	Description
class	ClientConnectionRedirectedException	A ClientIOException type that defines that the remote peer has requested that this connection be redirected to some alternative peer.
class	ClientConnectionRemotelyClosedException	Exception thrown when the remote peer actively closes the Connection by sending and AMQP Close frame or when the IO layer is disconnected due to some other reason such as a security error or transient network error.
class	ClientConnectionSecurityException	Connection level Security Exception used to indicate a security violation has occurred.
class	ClientConnectionSecuritySaslException	Security Exception used to indicate a security violation has occurred.
class	ClientDeliveryAbortedException	Thrown in cases where an action was requested that cannot be performed because the delivery being operated on has been aborted by the remote sender.
class	ClientDeliveryIsPartialException	Thrown in cases where an action was requested that cannot be performed because the delivery being operated on is only the partial Transfer payload.
class	ClientDeliveryStateException	Thrown from client API that deal with a Delivery or Tracker where the outcome that results from that API can affect whether the API call succeeded or failed.
class	ClientIdleTimeoutException	Thrown when the Provider fails a connection due to idle timeout.
class	ClientIllegalStateException
class	ClientIOException	Exception type that is thrown when the provider has encountered an unrecoverable error.
class	ClientLinkRedirectedException	A ClientLinkRemotelyClosedException type that defines that the remote peer has requested that this link be redirected to some alternative peer.
class	ClientLinkRemotelyClosedException	Root exception type for cases of remote closure or client created Sender or Receiver.
class	ClientMessageFormatViolationException	Exception thrown from Message instances when the body section specified violates the configure message format of the message that is being created.
class	ClientOperationTimedOutException	Indicates that an operation in the provider timed out waiting for completion
class	ClientResourceRemotelyClosedException	Root exception type for cases of remote closure or client created resources other than the Client Connection which will throw exceptions rooted from the ClientConnectionRemotelyClosedException to indicate a fatal connection level error that requires a new connection to be created.
class	ClientSendTimedOutException	Thrown when a message send operation times out in the Provider layer.
class	ClientSessionRemotelyClosedException	Root exception type for cases of remote closure or client created Session.
class	ClientTransactionDeclarationException	Thrown when a transaction declaration fails or is rejected by the remote.
class	ClientTransactionInDoubtException	Thrown when a transaction operation fails and state is now unknown.
class	ClientTransactionNotActiveException	Thrown when a client attempt to commit or roll-back when no transaction has been declared.
class	ClientTransactionRolledBackException	Thrown when a message send operation times out in the Provider layer.
class	ClientUnsupportedOperationException	Thrown when an action request is not supported through this provider.

Uses of ClientException in org.apache.qpid.protonj2.client.futures

Methods in org.apache.qpid.protonj2.client.futures with parameters of type ClientException

Modifier and Type	Method	Description
void	AsyncResult.failed(ClientException result)	If the operation fails this method is invoked with the Exception that caused the failure.
void	ClientFuture.failed(ClientException result)
void	NoOpAsyncResult.failed(ClientException result)

Uses of ClientException in org.apache.qpid.protonj2.client.impl

Fields in org.apache.qpid.protonj2.client.impl declared as ClientException

Modifier and Type	Field	Description
protected ClientException	ClientSender.failureCause

Methods in org.apache.qpid.protonj2.client.impl that return ClientException

Modifier and Type	Method	Description
ClientException	ClientOutgoingEnvelope.createSendTimedOutException()

Methods in org.apache.qpid.protonj2.client.impl with parameters of type ClientException

Modifier and Type	Method	Description
ClientOutgoingEnvelope	ClientOutgoingEnvelope.failed(ClientException exception)

Methods in org.apache.qpid.protonj2.client.impl that throw ClientException

Modifier and Type	Method	Description
long	ClientStreamReceiverMessage.absoluteExpiryTime()
Delivery	ClientDelivery.accept()
StreamDelivery	ClientStreamDelivery.accept()
Receiver	ClientReceiver.addCredit(int credits)
StreamReceiver	ClientStreamReceiver.addCredit(int credits)
java.lang.String	ClientReceiver.address()
java.lang.String	ClientStreamReceiver.address()
java.lang.Object	ClientStreamReceiverMessage.annotation(java.lang.String key)
java.util.Map<java.lang.String,java.lang.Object>	ClientDelivery.annotations()
java.util.Map<java.lang.String,java.lang.Object>	ClientStreamDelivery.annotations()
MessageAnnotations	ClientStreamReceiverMessage.annotations()
ApplicationProperties	ClientStreamReceiverMessage.applicationProperties()
Tracker	ClientNoOpTracker.awaitAccepted()
Tracker	ClientNoOpTracker.awaitAccepted(long timeout, java.util.concurrent.TimeUnit unit)
StreamTracker	ClientNoOpStreamTracker.awaitSettlement()
StreamTracker	ClientNoOpStreamTracker.awaitSettlement(long timeout, java.util.concurrent.TimeUnit unit)
Tracker	ClientNoOpTracker.awaitSettlement()
Tracker	ClientNoOpTracker.awaitSettlement(long timeout, java.util.concurrent.TimeUnit unit)
StreamTracker	ClientStreamTracker.awaitSettlement()
StreamTracker	ClientStreamTracker.awaitSettlement(long timeout, java.util.concurrent.TimeUnit unit)
org.apache.qpid.protonj2.client.impl.ClientStreamSenderMessage	ClientStreamSender.beginMessage()
org.apache.qpid.protonj2.client.impl.ClientStreamSenderMessage	ClientStreamSender.beginMessage(java.util.Map<java.lang.String,java.lang.Object> deliveryAnnotations)
Session	ClientSession.beginTransaction()
java.io.InputStream	ClientStreamReceiverMessage.body()
protected void	ClientConnection.checkClosedOrFailed()
protected void	ClientSession.checkClosedOrFailed()
Session	ClientSession.commitTransaction()
Connection	ClientInstance.connect(java.lang.String host)
Connection	ClientInstance.connect(java.lang.String host, int port)
Connection	ClientInstance.connect(java.lang.String host, int port, ConnectionOptions options)
Connection	ClientInstance.connect(java.lang.String host, ConnectionOptions options)
java.lang.String	ClientStreamReceiverMessage.contentEncoding()
java.lang.String	ClientStreamReceiverMessage.contentType()
static <E> AdvancedMessage<E>	ClientMessageSupport.convertMessage(Message<E> message)	Converts a Message instance into a ClientMessage instance either by cast or by construction of a new instance with a copy of the values carried in the given message.
java.lang.Object	ClientStreamReceiverMessage.correlationId()
long	ClientStreamReceiverMessage.creationTime()
static Message<?>	ClientMessageSupport.decodeMessage(ProtonBuffer buffer, java.util.function.Consumer<DeliveryAnnotations> daConsumer)
static Message<?>	ClientMessageSupport.decodeMessage(Decoder decoder, ProtonBuffer buffer, java.util.function.Consumer<DeliveryAnnotations> daConsumer)
static Message<?>	ClientMessageSupport.decodeMessage(Decoder decoder, DecoderState decoderState, ProtonBuffer buffer, java.util.function.Consumer<DeliveryAnnotations> daConsumer)
Sender	ClientConnection.defaultSender()
Session	ClientConnection.defaultSession()
long	ClientStreamReceiverMessage.deliveryCount()
java.lang.String[]	ClientConnection.desiredCapabilities()
java.lang.String[]	ClientReceiver.desiredCapabilities()
java.lang.String[]	ClientSession.desiredCapabilities()
java.lang.String[]	ClientStreamReceiver.desiredCapabilities()
Delivery	ClientDelivery.disposition(DeliveryState state, boolean settle)
StreamTracker	ClientNoOpStreamTracker.disposition(DeliveryState state, boolean settle)
Tracker	ClientNoOpTracker.disposition(DeliveryState state, boolean settle)
StreamDelivery	ClientStreamDelivery.disposition(DeliveryState state, boolean settle)
StreamTracker	ClientStreamTracker.disposition(DeliveryState state, boolean settle)
java.util.concurrent.Future<Receiver>	ClientReceiver.drain()
java.util.concurrent.Future<Receiver>	ClientStreamReceiver.drain()
boolean	ClientStreamReceiverMessage.durable()
ProtonBuffer	ClientMessage.encode(java.util.Map<java.lang.String,java.lang.Object> deliveryAnnotations)
static ProtonBuffer	ClientMessageSupport.encodeMessage(AdvancedMessage<?> message, java.util.Map<java.lang.String,java.lang.Object> deliveryAnnotations)
static ProtonBuffer	ClientMessageSupport.encodeMessage(Encoder encoder, ProtonBufferAllocator allocator, AdvancedMessage<?> message, java.util.Map<java.lang.String,java.lang.Object> deliveryAnnotations)
static ProtonBuffer	ClientMessageSupport.encodeMessage(Encoder encoder, EncoderState encoderState, ProtonBufferAllocator allocator, AdvancedMessage<?> message, java.util.Map<java.lang.String,java.lang.Object> deliveryAnnotations)
boolean	ClientStreamReceiverMessage.firstAcquirer()
Footer	ClientStreamReceiverMessage.footer()
java.lang.Object	ClientStreamReceiverMessage.footer(java.lang.String key)
StreamReceiverMessage	ClientStreamReceiverMessage.forEachAnnotation(java.util.function.BiConsumer<java.lang.String,java.lang.Object> action)
StreamReceiverMessage	ClientStreamReceiverMessage.forEachFooter(java.util.function.BiConsumer<java.lang.String,java.lang.Object> action)
StreamReceiverMessage	ClientStreamReceiverMessage.forEachProperty(java.util.function.BiConsumer<java.lang.String,java.lang.Object> action)
java.lang.String	ClientStreamReceiverMessage.groupId()
int	ClientStreamReceiverMessage.groupSequence()
boolean	ClientStreamReceiverMessage.hasAnnotation(java.lang.String key)
boolean	ClientStreamReceiverMessage.hasAnnotations()
boolean	ClientStreamReceiverMessage.hasFooter(java.lang.String key)
boolean	ClientStreamReceiverMessage.hasFooters()
boolean	ClientStreamReceiverMessage.hasProperties()
boolean	ClientStreamReceiverMessage.hasProperty(java.lang.String key)
Header	ClientStreamReceiverMessage.header()
<E> Message<E>	ClientDelivery.message()
ClientStreamReceiverMessage	ClientStreamDelivery.message()
int	ClientStreamReceiverMessage.messageFormat()
java.lang.Object	ClientStreamReceiverMessage.messageId()
Delivery	ClientDelivery.modified(boolean deliveryFailed, boolean undeliverableHere)
StreamDelivery	ClientStreamDelivery.modified(boolean deliveryFailed, boolean undeliverableHere)
java.lang.String[]	ClientConnection.offeredCapabilities()
java.lang.String[]	ClientReceiver.offeredCapabilities()
java.lang.String[]	ClientSession.offeredCapabilities()
java.lang.String[]	ClientStreamReceiver.offeredCapabilities()
Sender	ClientConnection.openAnonymousSender()
Sender	ClientConnection.openAnonymousSender(SenderOptions senderOptions)
Sender	ClientSession.openAnonymousSender()
Sender	ClientSession.openAnonymousSender(SenderOptions senderOptions)
Sender	ClientStreamSession.openAnonymousSender()
Sender	ClientStreamSession.openAnonymousSender(SenderOptions senderOptions)
Receiver	ClientConnection.openDurableReceiver(java.lang.String address, java.lang.String subscriptionName)
Receiver	ClientConnection.openDurableReceiver(java.lang.String address, java.lang.String subscriptionName, ReceiverOptions receiverOptions)
Receiver	ClientSession.openDurableReceiver(java.lang.String address, java.lang.String subscriptionName)
Receiver	ClientSession.openDurableReceiver(java.lang.String address, java.lang.String subscriptionName, ReceiverOptions receiverOptions)
Receiver	ClientStreamSession.openDurableReceiver(java.lang.String address, java.lang.String subscriptionName)
Receiver	ClientStreamSession.openDurableReceiver(java.lang.String address, java.lang.String subscriptionName, ReceiverOptions receiverOptions)
Receiver	ClientConnection.openDynamicReceiver()
Receiver	ClientConnection.openDynamicReceiver(java.util.Map<java.lang.String,java.lang.Object> dynamicNodeProperties)
Receiver	ClientConnection.openDynamicReceiver(java.util.Map<java.lang.String,java.lang.Object> dynamicNodeProperties, ReceiverOptions receiverOptions)
Receiver	ClientConnection.openDynamicReceiver(ReceiverOptions receiverOptions)
Receiver	ClientSession.openDynamicReceiver()
Receiver	ClientSession.openDynamicReceiver(java.util.Map<java.lang.String,java.lang.Object> dynamicNodeProperties)
Receiver	ClientSession.openDynamicReceiver(java.util.Map<java.lang.String,java.lang.Object> dynamicNodeProperties, ReceiverOptions receiverOptions)
Receiver	ClientSession.openDynamicReceiver(ReceiverOptions receiverOptions)
Receiver	ClientStreamSession.openDynamicReceiver()
Receiver	ClientStreamSession.openDynamicReceiver(java.util.Map<java.lang.String,java.lang.Object> dynamicNodeProperties)
Receiver	ClientStreamSession.openDynamicReceiver(java.util.Map<java.lang.String,java.lang.Object> dynamicNodeProperties, ReceiverOptions receiverOptions)
Receiver	ClientStreamSession.openDynamicReceiver(ReceiverOptions receiverOptions)
Receiver	ClientConnection.openReceiver(java.lang.String address)
Receiver	ClientConnection.openReceiver(java.lang.String address, ReceiverOptions receiverOptions)
Receiver	ClientSession.openReceiver(java.lang.String address)
Receiver	ClientSession.openReceiver(java.lang.String address, ReceiverOptions receiverOptions)
Receiver	ClientStreamSession.openReceiver(java.lang.String address)
Receiver	ClientStreamSession.openReceiver(java.lang.String address, ReceiverOptions receiverOptions)
Sender	ClientConnection.openSender(java.lang.String address)
Sender	ClientConnection.openSender(java.lang.String address, SenderOptions senderOptions)
Sender	ClientSession.openSender(java.lang.String address)
Sender	ClientSession.openSender(java.lang.String address, SenderOptions senderOptions)
Sender	ClientStreamSession.openSender(java.lang.String address)
Sender	ClientStreamSession.openSender(java.lang.String address, SenderOptions senderOptions)
Session	ClientConnection.openSession()
Session	ClientConnection.openSession(SessionOptions sessionOptions)
StreamReceiver	ClientConnection.openStreamReceiver(java.lang.String address)
StreamReceiver	ClientConnection.openStreamReceiver(java.lang.String address, StreamReceiverOptions receiverOptions)
StreamSender	ClientConnection.openStreamSender(java.lang.String address)
StreamSender	ClientConnection.openStreamSender(java.lang.String address, StreamSenderOptions senderOptions)
byte	ClientStreamReceiverMessage.priority()
java.util.Map<java.lang.String,java.lang.Object>	ClientConnection.properties()
java.util.Map<java.lang.String,java.lang.Object>	ClientReceiver.properties()
java.util.Map<java.lang.String,java.lang.Object>	ClientSession.properties()
java.util.Map<java.lang.String,java.lang.Object>	ClientStreamReceiver.properties()
Properties	ClientStreamReceiverMessage.properties()
java.lang.Object	ClientStreamReceiverMessage.property(java.lang.String key)
long	ClientStreamReceiver.queuedDeliveries()
java.io.InputStream	ClientDelivery.rawInputStream()
java.io.InputStream	ClientStreamDelivery.rawInputStream()
Delivery	ClientReceiver.receive()
Delivery	ClientReceiver.receive(long timeout, java.util.concurrent.TimeUnit units)
StreamDelivery	ClientStreamReceiver.receive()
StreamDelivery	ClientStreamReceiver.receive(long timeout, java.util.concurrent.TimeUnit unit)
Delivery	ClientDelivery.reject(java.lang.String condition, java.lang.String description)
StreamDelivery	ClientStreamDelivery.reject(java.lang.String condition, java.lang.String description)
Delivery	ClientDelivery.release()
StreamDelivery	ClientStreamDelivery.release()
java.lang.String	ClientStreamReceiverMessage.replyTo()
java.lang.String	ClientStreamReceiverMessage.replyToGroupId()
Session	ClientSession.rollbackTransaction()
Tracker	ClientConnection.send(Message<?> message)
StreamTracker	ClientStreamSender.send(Message<?> message)
StreamTracker	ClientStreamSender.send(Message<?> message, java.util.Map<java.lang.String,java.lang.Object> deliveryAnnotations)
Delivery	ClientDelivery.settle()
StreamTracker	ClientNoOpStreamTracker.settle()
Tracker	ClientNoOpTracker.settle()
StreamDelivery	ClientStreamDelivery.settle()
StreamTracker	ClientStreamTracker.settle()
Source	ClientReceiver.source()
Source	ClientStreamReceiver.source()
java.lang.String	ClientStreamReceiverMessage.subject()
Target	ClientReceiver.target()
Target	ClientStreamReceiver.target()
long	ClientStreamReceiverMessage.timeToLive()
java.lang.String	ClientStreamReceiverMessage.to()
Delivery	ClientReceiver.tryReceive()
StreamDelivery	ClientStreamReceiver.tryReceive()
StreamTracker	ClientStreamSender.trySend(Message<?> message)
StreamTracker	ClientStreamSender.trySend(Message<?> message, java.util.Map<java.lang.String,java.lang.Object> deliveryAnnotations)
byte[]	ClientStreamReceiverMessage.userId()