A B C D E F G H I K L M N O P Q R S T U V W X Z 
All Classes All Packages

A

abort() - Method in class org.apache.qpid.protonj2.client.impl.ClientOutgoingEnvelope
 
abort() - Method in interface org.apache.qpid.protonj2.client.StreamSenderMessage
Marks the currently streaming message as being aborted.
abort() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonOutgoingDelivery
 
abort() - Method in interface org.apache.qpid.protonj2.engine.OutgoingDelivery
Aborts the outgoing delivery if not already settled.
aborted() - Method in class org.apache.qpid.protonj2.client.impl.ClientOutgoingEnvelope
 
aborted() - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamDelivery
 
aborted() - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiverMessage
 
aborted() - Method in interface org.apache.qpid.protonj2.client.StreamDelivery
Check if the StreamDelivery has been marked as aborted by the remote sender.
aborted() - Method in interface org.apache.qpid.protonj2.client.StreamReceiverMessage
Check if the StreamDelivery that was assigned to this StreamReceiverMessage has been marked as aborted by the remote.
aborted() - Method in interface org.apache.qpid.protonj2.client.StreamSenderMessage
 
absoluteExpiryTime() - Method in class org.apache.qpid.protonj2.client.impl.ClientMessage
 
absoluteExpiryTime() - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiverMessage
 
absoluteExpiryTime() - Method in interface org.apache.qpid.protonj2.client.Message
 
absoluteExpiryTime(long) - Method in class org.apache.qpid.protonj2.client.impl.ClientMessage
 
absoluteExpiryTime(long) - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiverMessage
 
absoluteExpiryTime(long) - Method in interface org.apache.qpid.protonj2.client.Message
Sets the absolute expiration time value to assign to this Message.
AbstractArrayTypeDecoder - Class in org.apache.qpid.protonj2.codec.decoders.primitives
Base for the decoders of AMQP Array types that defaults to returning opaque Object values to match what the other decoders do.
AbstractArrayTypeDecoder() - Constructor for class org.apache.qpid.protonj2.codec.decoders.primitives.AbstractArrayTypeDecoder
 
AbstractBinaryTypeDecoder - Class in org.apache.qpid.protonj2.codec.decoders.primitives
Base class for the various Binary type decoders used to read AMQP Binary values.
AbstractBinaryTypeDecoder() - Constructor for class org.apache.qpid.protonj2.codec.decoders.primitives.AbstractBinaryTypeDecoder
 
AbstractDescribedListTypeEncoder<V> - Class in org.apache.qpid.protonj2.codec.encoders
Base class used for all Described Type objects that are represented as a List
AbstractDescribedListTypeEncoder() - Constructor for class org.apache.qpid.protonj2.codec.encoders.AbstractDescribedListTypeEncoder
 
AbstractDescribedMapTypeEncoder<K,​V,​M> - Class in org.apache.qpid.protonj2.codec.encoders
Base class used for all Described Type objects that are represented as a List
AbstractDescribedMapTypeEncoder() - Constructor for class org.apache.qpid.protonj2.codec.encoders.AbstractDescribedMapTypeEncoder
 
AbstractDescribedTypeDecoder<V> - Class in org.apache.qpid.protonj2.codec.decoders
Abstract base for all Described Type decoders which implements the generic methods common to all the implementations.
AbstractDescribedTypeDecoder() - Constructor for class org.apache.qpid.protonj2.codec.decoders.AbstractDescribedTypeDecoder
 
AbstractDescribedTypeEncoder<V> - Class in org.apache.qpid.protonj2.codec.encoders
Abstract DescribedType encoder implementation
AbstractDescribedTypeEncoder() - Constructor for class org.apache.qpid.protonj2.codec.encoders.AbstractDescribedTypeEncoder
 
AbstractListTypeDecoder - Class in org.apache.qpid.protonj2.codec.decoders.primitives
Base for the various List type decoders needed to read AMQP List values.
AbstractListTypeDecoder() - Constructor for class org.apache.qpid.protonj2.codec.decoders.primitives.AbstractListTypeDecoder
 
AbstractMapTypeDecoder - Class in org.apache.qpid.protonj2.codec.decoders.primitives
Base for the various Map type decoders used to read AMQP Map values.
AbstractMapTypeDecoder() - Constructor for class org.apache.qpid.protonj2.codec.decoders.primitives.AbstractMapTypeDecoder
 
AbstractMechanism - Class in org.apache.qpid.protonj2.engine.sasl.client
Base class for SASL Authentication Mechanism that implements the basic methods of a Mechanism class.
AbstractMechanism() - Constructor for class org.apache.qpid.protonj2.engine.sasl.client.AbstractMechanism
 
AbstractPrimitiveTypeDecoder<V> - Class in org.apache.qpid.protonj2.codec.decoders
Abstract base for all Described Type decoders which implements the generic methods common to all the implementations.
AbstractPrimitiveTypeDecoder() - Constructor for class org.apache.qpid.protonj2.codec.decoders.AbstractPrimitiveTypeDecoder
 
AbstractPrimitiveTypeEncoder<V> - Class in org.apache.qpid.protonj2.codec.encoders
Abstract implementation of the PrimitiveTypeEncoder that implements the common methods that most of the primitive type
AbstractPrimitiveTypeEncoder() - Constructor for class org.apache.qpid.protonj2.codec.encoders.AbstractPrimitiveTypeEncoder
 
AbstractStringTypeDecoder - Class in org.apache.qpid.protonj2.codec.decoders.primitives
Base for the various String type Decoders used to read AMQP String values.
AbstractStringTypeDecoder() - Constructor for class org.apache.qpid.protonj2.codec.decoders.primitives.AbstractStringTypeDecoder
 
AbstractSymbolTypeDecoder - Class in org.apache.qpid.protonj2.codec.decoders.primitives
Base class for the Symbol decoders used on AMQP Symbol types.
AbstractSymbolTypeDecoder() - Constructor for class org.apache.qpid.protonj2.codec.decoders.primitives.AbstractSymbolTypeDecoder
 
accept() - Method in interface org.apache.qpid.protonj2.client.Delivery
Accepts and settles the delivery.
accept() - Method in class org.apache.qpid.protonj2.client.impl.ClientDelivery
 
accept() - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamDelivery
 
accept() - Method in interface org.apache.qpid.protonj2.client.StreamDelivery
Accepts and settles the delivery.
accept(ProtonBuffer) - Method in interface org.apache.qpid.protonj2.engine.Engine
Provide data input for this Engine from some external source.
accepted() - Static method in interface org.apache.qpid.protonj2.client.DeliveryState
 
Accepted - Class in org.apache.qpid.protonj2.types.messaging
 
Accepted - org.apache.qpid.protonj2.types.transport.DeliveryState.DeliveryStateType
 
ACCEPTED - org.apache.qpid.protonj2.client.DeliveryState.Type
 
AcceptedTypeDecoder - Class in org.apache.qpid.protonj2.codec.decoders.messaging
Decoder of AMQP Accepted type values from a byte stream.
AcceptedTypeDecoder() - Constructor for class org.apache.qpid.protonj2.codec.decoders.messaging.AcceptedTypeDecoder
 
AcceptedTypeEncoder - Class in org.apache.qpid.protonj2.codec.encoders.messaging
Encoder of AMQP Accepted type values to a byte stream
AcceptedTypeEncoder() - Constructor for class org.apache.qpid.protonj2.codec.encoders.messaging.AcceptedTypeEncoder
 
ACTIVE - org.apache.qpid.protonj2.engine.ConnectionState
Indicates that the targeted end of the Connection (local or remote) is currently open.
ACTIVE - org.apache.qpid.protonj2.engine.LinkState
Indicates that the targeted end of the Link (local or remote) is currently open.
ACTIVE - org.apache.qpid.protonj2.engine.SessionState
Indicates that the targeted end of the Session (local or remote) is currently open.
add(ReconnectLocation) - Method in class org.apache.qpid.protonj2.client.util.ReconnectLocationPool
Adds a new entry to the pool if not already contained within.
add(UnsignedInteger) - Method in class org.apache.qpid.protonj2.types.UnsignedInteger
Adds the value of the given UnsignedInteger to this instance and return a new UnsignedInteger instance that represents the newly computed value.
addAdditionalHandlers(ChannelPipeline) - Method in class org.apache.qpid.protonj2.client.transport.TcpTransport
 
addAdditionalHandlers(ChannelPipeline) - Method in class org.apache.qpid.protonj2.client.transport.WebSocketTransport
 
addAll(Collection<? extends E>) - Method in class org.apache.qpid.protonj2.engine.util.RingQueue
 
addAll(List<ReconnectLocation>) - Method in class org.apache.qpid.protonj2.client.util.ReconnectLocationPool
Adds a list of new ReconnectLocation values to the pool if not already contained within.
addAllowedMechanism(String) - Method in class org.apache.qpid.protonj2.client.SaslOptions
Adds a mechanism to the list of allowed SASL mechanisms this client will use when selecting from the remote peers offered set of SASL mechanisms.
addBodySection(Section<?>) - Method in interface org.apache.qpid.protonj2.client.AdvancedMessage
Adds the given Section to the internal collection of sections that will be sent to the remote peer when this message is encoded.
addBodySection(Section<?>) - Method in class org.apache.qpid.protonj2.client.impl.ClientMessage
 
addBodySection(Section<?>) - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiverMessage
 
addCapacityAvailableHandler(EventHandler<TransactionController>) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonTransactionController
 
addCapacityAvailableHandler(EventHandler<TransactionController>) - Method in interface org.apache.qpid.protonj2.engine.TransactionController
Allows the caller to add an EventHandler that will be signaled when the underlying link for this TransactionController has been granted credit which would then allow for transaction Declared and Discharge commands to be sent to the remote Transactional Resource.
addCredit(int) - Method in class org.apache.qpid.protonj2.client.impl.ClientReceiver
 
addCredit(int) - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiver
 
addCredit(int) - Method in interface org.apache.qpid.protonj2.client.Receiver
Adds credit to the Receiver link for use when there receiver has not been configured with a credit window.
addCredit(int) - Method in interface org.apache.qpid.protonj2.client.StreamReceiver
Adds credit to the Receiver link for use when there receiver has not been configured with a credit window.
addCredit(int) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonReceiver
 
addCredit(int) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonTransactionManager
 
addCredit(int) - Method in interface org.apache.qpid.protonj2.engine.Receiver
Adds the given amount of credit for the Receiver.
addCredit(int) - Method in interface org.apache.qpid.protonj2.engine.TransactionManager
Adds the given amount of credit for the TransactionManager which allows the TransactionController to send Declare and Discharge requests to this manager.
addFirst(String, EngineHandler) - Method in interface org.apache.qpid.protonj2.engine.EnginePipeline
Adds the given handler to the front of the pipeline with the given name stored for later lookup or remove operations.
addFirst(String, EngineHandler) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEnginePipeline
 
addFirst(String, EngineHandler) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEnginePipelineProxy
 
addFirst(ReconnectLocation) - Method in class org.apache.qpid.protonj2.client.util.ReconnectLocationPool
Adds a new ReconnectLocation to the pool if not already contained within.
addLast(String, EngineHandler) - Method in interface org.apache.qpid.protonj2.engine.EnginePipeline
Adds the given handler to the end of the pipeline with the given name stored for later lookup or remove operations.
addLast(String, EngineHandler) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEnginePipeline
 
addLast(String, EngineHandler) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEnginePipelineProxy
 
addReconnectLocation(String, int) - Method in class org.apache.qpid.protonj2.client.ReconnectOptions
Adds an additional reconnection location that can be used when attempting to reconnect the client following a connection failure.
address() - Method in class org.apache.qpid.protonj2.client.impl.ClientReceiver
 
address() - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiver
 
address() - Method in interface org.apache.qpid.protonj2.client.Receiver
Returns the address that the Receiver instance will be subscribed to.
address() - Method in interface org.apache.qpid.protonj2.client.Sender
Returns the address that the Sender instance will send Message objects to.
address() - Method in interface org.apache.qpid.protonj2.client.Source
 
address() - Method in interface org.apache.qpid.protonj2.client.Target
 
ADDRESS - Static variable in class org.apache.qpid.protonj2.client.impl.ClientConstants
 
addWebSocketHeader(String, String) - Method in class org.apache.qpid.protonj2.client.TransportOptions
Additional headers to be passed along to the remote when performing a WebSocket based connect.
adjustIndexMarks(int) - Method in class org.apache.qpid.protonj2.buffer.ProtonAbstractBuffer
 
AdvancedMessage<E> - Interface in org.apache.qpid.protonj2.client
Advanced AMQP Message object that provides a thin abstraction to raw AMQP types
allocate() - Method in interface org.apache.qpid.protonj2.buffer.ProtonBufferAllocator
Create a new ProtonBuffer instance with default initial capacity.
allocate() - Method in class org.apache.qpid.protonj2.buffer.ProtonByteBufferAllocator
 
allocate() - Method in class org.apache.qpid.protonj2.buffer.ProtonNettyByteBufferAllocator
 
allocate(int) - Method in interface org.apache.qpid.protonj2.buffer.ProtonBufferAllocator
Create a new ProtonBuffer instance with the given initial capacity and the maximum capacity should be that of the underlying buffer implementations limit.
allocate(int) - Method in class org.apache.qpid.protonj2.buffer.ProtonByteBufferAllocator
 
allocate(int) - Method in class org.apache.qpid.protonj2.buffer.ProtonNettyByteBufferAllocator
 
allocate(int, int) - Method in interface org.apache.qpid.protonj2.buffer.ProtonBufferAllocator
Create a new ProtonBuffer instance with the given initial capacity and the maximum capacity should that of the value specified by the caller.
allocate(int, int) - Method in class org.apache.qpid.protonj2.buffer.ProtonByteBufferAllocator
 
allocate(int, int) - Method in class org.apache.qpid.protonj2.buffer.ProtonNettyByteBufferAllocator
 
allowedMechanisms() - Method in class org.apache.qpid.protonj2.client.SaslOptions
 
allowNativeIO() - Method in class org.apache.qpid.protonj2.client.TransportOptions
 
allowNativeIO(boolean) - Method in class org.apache.qpid.protonj2.client.TransportOptions
Determines if the a native IO implementation is preferred to the JDK based IO.
allowNativeSSL() - Method in class org.apache.qpid.protonj2.client.SslOptions
 
allowNativeSSL(boolean) - Method in class org.apache.qpid.protonj2.client.SslOptions
 
AMQP_FRAME_TYPE - Static variable in class org.apache.qpid.protonj2.engine.impl.ProtonFrameDecodingHandler
Frame type indicator for AMQP protocol frames.
AMQP_FRAME_TYPE - Static variable in class org.apache.qpid.protonj2.engine.impl.ProtonFrameEncodingHandler
Frame type indicator for AMQP protocol frames.
AMQP_FRAME_TYPE - Static variable in class org.apache.qpid.protonj2.engine.IncomingAMQPEnvelope
The AMQP Frame type marker value used when processing incoming frames.
AMQP_FRAME_TYPE - Static variable in class org.apache.qpid.protonj2.engine.OutgoingAMQPEnvelope
The frame type value to used when encoding the outgoing AMQP frame.
AMQP_HEADER_ENVELOPE - Static variable in class org.apache.qpid.protonj2.engine.HeaderEnvelope
A singleton instance of an AMQP header that can be used to avoid additional allocations.
AMQP_PERFORMATIVE_HANDLER - Static variable in class org.apache.qpid.protonj2.engine.impl.ProtonConstants
Engine handler that acts on AMQP performatives
AMQP_PROTOCOL_ID - Static variable in class org.apache.qpid.protonj2.types.transport.AMQPHeader
 
AmqpError - Interface in org.apache.qpid.protonj2.types.transport
List of Symbol constants that provide the defined AMQP Error space.
AMQPHeader - Class in org.apache.qpid.protonj2.types.transport
Represents the AMQP protocol handshake packet that is sent during the initial exchange with a remote peer.
AMQPHeader() - Constructor for class org.apache.qpid.protonj2.types.transport.AMQPHeader
 
AMQPHeader(byte[]) - Constructor for class org.apache.qpid.protonj2.types.transport.AMQPHeader
 
AMQPHeader(ProtonBuffer) - Constructor for class org.apache.qpid.protonj2.types.transport.AMQPHeader
 
AMQPHeader(ProtonBuffer, boolean) - Constructor for class org.apache.qpid.protonj2.types.transport.AMQPHeader
 
AMQPHeader.HeaderHandler<E> - Interface in org.apache.qpid.protonj2.types.transport
 
AMQPPerformativeEnvelopePool<E extends PerformativeEnvelope<Performative>> - Class in org.apache.qpid.protonj2.engine
Pool of PerformativeEnvelope instances used to reduce allocations on incoming performatives.
AMQPPerformativeEnvelopePool(Function<AMQPPerformativeEnvelopePool<E>, E>) - Constructor for class org.apache.qpid.protonj2.engine.AMQPPerformativeEnvelopePool
Create a new envelope pool using the default pool size.
AMQPPerformativeEnvelopePool(Function<AMQPPerformativeEnvelopePool<E>, E>, int) - Constructor for class org.apache.qpid.protonj2.engine.AMQPPerformativeEnvelopePool
Create a new envelope pool using the default pool size.
AmqpSequence<E> - Class in org.apache.qpid.protonj2.types.messaging
 
AmqpSequence - org.apache.qpid.protonj2.types.messaging.Section.SectionType
 
AmqpSequence(List<E>) - Constructor for class org.apache.qpid.protonj2.types.messaging.AmqpSequence
 
AmqpSequenceTypeDecoder - Class in org.apache.qpid.protonj2.codec.decoders.messaging
Decoder of AMQP Data type values from a byte stream.
AmqpSequenceTypeDecoder() - Constructor for class org.apache.qpid.protonj2.codec.decoders.messaging.AmqpSequenceTypeDecoder
 
AmqpSequenceTypeEncoder - Class in org.apache.qpid.protonj2.codec.encoders.messaging
Encoder of AMQP AmqpSequence type values to a byte stream.
AmqpSequenceTypeEncoder() - Constructor for class org.apache.qpid.protonj2.codec.encoders.messaging.AmqpSequenceTypeEncoder
 
AmqpValue<E> - Class in org.apache.qpid.protonj2.types.messaging
 
AmqpValue - org.apache.qpid.protonj2.types.messaging.Section.SectionType
 
AmqpValue(E) - Constructor for class org.apache.qpid.protonj2.types.messaging.AmqpValue
 
AmqpValueTypeDecoder - Class in org.apache.qpid.protonj2.codec.decoders.messaging
Decoder of AMQP Data type values from a byte stream.
AmqpValueTypeDecoder() - Constructor for class org.apache.qpid.protonj2.codec.decoders.messaging.AmqpValueTypeDecoder
 
AmqpValueTypeEncoder - Class in org.apache.qpid.protonj2.codec.encoders.messaging
Encoder of AMQP Value type values to a byte stream.
AmqpValueTypeEncoder() - Constructor for class org.apache.qpid.protonj2.codec.encoders.messaging.AmqpValueTypeEncoder
 
annotation(String) - Method in class org.apache.qpid.protonj2.client.impl.ClientMessage
 
annotation(String) - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiverMessage
 
annotation(String) - Method in interface org.apache.qpid.protonj2.client.Message
Returns the requested message annotation value from this Message if it exists or returns null otherwise.
annotation(String, Object) - Method in class org.apache.qpid.protonj2.client.impl.ClientMessage
 
annotation(String, Object) - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiverMessage
 
annotation(String, Object) - Method in interface org.apache.qpid.protonj2.client.Message
Sets the given message annotation value at the given key, replacing any previous value that was assigned to this Message.
annotations() - Method in interface org.apache.qpid.protonj2.client.AdvancedMessage
Return the current MessageAnnotations assigned to this message, if none was assigned yet then this method returns null.
annotations() - Method in interface org.apache.qpid.protonj2.client.Delivery
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.
annotations() - Method in class org.apache.qpid.protonj2.client.impl.ClientDelivery
 
annotations() - Method in class org.apache.qpid.protonj2.client.impl.ClientMessage
 
annotations() - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamDelivery
 
annotations() - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiverMessage
 
annotations(MessageAnnotations) - Method in interface org.apache.qpid.protonj2.client.AdvancedMessage
Assign or replace the MessageAnnotations instance associated with this message.
annotations(MessageAnnotations) - Method in class org.apache.qpid.protonj2.client.impl.ClientMessage
 
annotations(MessageAnnotations) - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiverMessage
 
ANONYMOUS - org.apache.qpid.protonj2.engine.sasl.client.SaslMechanisms
 
ANONYMOUS - Static variable in class org.apache.qpid.protonj2.engine.sasl.client.AnonymousMechanism
A singleton instance of the symbolic mechanism name.
ANONYMOUS_RELAY - Static variable in class org.apache.qpid.protonj2.client.impl.ClientConstants
 
AnonymousMechanism - Class in org.apache.qpid.protonj2.engine.sasl.client
Implements the Anonymous SASL authentication mechanism.
AnonymousMechanism() - Constructor for class org.apache.qpid.protonj2.engine.sasl.client.AnonymousMechanism
 
anonymousRelaySupported() - Method in class org.apache.qpid.protonj2.client.impl.ClientConnectionCapabilities
 
append(byte[]) - Method in class org.apache.qpid.protonj2.buffer.ProtonCompositeBuffer
Appends the given byte array to the end of the buffer segments that comprise this composite ProtonBuffer instance.
append(byte[], int, int) - Method in class org.apache.qpid.protonj2.buffer.ProtonCompositeBuffer
Appends the given byte array to the end of the buffer segments that comprise this composite ProtonBuffer instance.
append(ProtonBuffer) - Method in class org.apache.qpid.protonj2.buffer.ProtonCompositeBuffer
Appends the given ProtonBuffer to the end of the buffer segments that comprise this composite ProtonBuffer instance.
applicationProperties() - Method in interface org.apache.qpid.protonj2.client.AdvancedMessage
Return the current ApplicationProperties assigned to this message, if none was assigned yet then this method returns null.
applicationProperties() - Method in class org.apache.qpid.protonj2.client.impl.ClientMessage
 
applicationProperties() - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiverMessage
 
applicationProperties(ApplicationProperties) - Method in interface org.apache.qpid.protonj2.client.AdvancedMessage
Assign or replace the ApplicationProperties instance associated with this message.
applicationProperties(ApplicationProperties) - Method in class org.apache.qpid.protonj2.client.impl.ClientMessage
 
applicationProperties(ApplicationProperties) - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiverMessage
 
ApplicationProperties - Class in org.apache.qpid.protonj2.types.messaging
 
ApplicationProperties - org.apache.qpid.protonj2.types.messaging.Section.SectionType
 
ApplicationProperties(Map<String, ?>) - Constructor for class org.apache.qpid.protonj2.types.messaging.ApplicationProperties
 
ApplicationPropertiesTypeDecoder - Class in org.apache.qpid.protonj2.codec.decoders.messaging
Decoder of AMQP ApplicationProperties types from a byte stream
ApplicationPropertiesTypeDecoder() - Constructor for class org.apache.qpid.protonj2.codec.decoders.messaging.ApplicationPropertiesTypeDecoder
 
ApplicationPropertiesTypeEncoder - Class in org.apache.qpid.protonj2.codec.encoders.messaging
Encoder of AMQP ApplicationProperties type values to a byte stream.
ApplicationPropertiesTypeEncoder() - Constructor for class org.apache.qpid.protonj2.codec.encoders.messaging.ApplicationPropertiesTypeEncoder
 
areDeliveriesStillActive() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonLink
 
ARRAY32 - Static variable in interface org.apache.qpid.protonj2.codec.EncodingCodes
 
Array32TypeDecoder - Class in org.apache.qpid.protonj2.codec.decoders.primitives
Decoder of AMQP Arrays from a byte stream.
Array32TypeDecoder() - Constructor for class org.apache.qpid.protonj2.codec.decoders.primitives.Array32TypeDecoder
 
ARRAY8 - Static variable in interface org.apache.qpid.protonj2.codec.EncodingCodes
 
Array8TypeDecoder - Class in org.apache.qpid.protonj2.codec.decoders.primitives
Decoder of AMQP Arrays from a byte stream.
Array8TypeDecoder() - Constructor for class org.apache.qpid.protonj2.codec.decoders.primitives.Array8TypeDecoder
 
arrayCopy() - Method in class org.apache.qpid.protonj2.types.Binary
 
ArrayTypeEncoder - Class in org.apache.qpid.protonj2.codec.encoders.primitives
Encoder of AMQP Array types to a byte stream.
ArrayTypeEncoder() - Constructor for class org.apache.qpid.protonj2.codec.encoders.primitives.ArrayTypeEncoder
 
asByteBuffer() - Method in class org.apache.qpid.protonj2.types.Binary
 
asBytes() - Method in class org.apache.qpid.protonj2.types.Decimal128
 
asProtonBuffer() - Method in class org.apache.qpid.protonj2.types.Binary
 
AsyncResult<V> - Interface in org.apache.qpid.protonj2.client.futures
Defines a result interface for Asynchronous operations.
AT_LEAST_ONCE - org.apache.qpid.protonj2.client.DeliveryMode
 
AT_MOST_ONCE - org.apache.qpid.protonj2.client.DeliveryMode
 
Attach - Class in org.apache.qpid.protonj2.types.transport
 
Attach() - Constructor for class org.apache.qpid.protonj2.types.transport.Attach
 
ATTACH - org.apache.qpid.protonj2.types.transport.Performative.PerformativeType
 
Attachments - Interface in org.apache.qpid.protonj2.engine
Attachments API used to associate specific data with AMQP Resources
AttachTypeDecoder - Class in org.apache.qpid.protonj2.codec.decoders.transport
Decoder of AMQP Attach type values from a byte stream.
AttachTypeDecoder() - Constructor for class org.apache.qpid.protonj2.codec.decoders.transport.AttachTypeDecoder
 
AttachTypeEncoder - Class in org.apache.qpid.protonj2.codec.encoders.transport
Encoder of AMQP Attach type values to a byte stream.
AttachTypeEncoder() - Constructor for class org.apache.qpid.protonj2.codec.encoders.transport.AttachTypeEncoder
 
AUTH - org.apache.qpid.protonj2.types.security.SaslCode
 
AUTHENTICATED - org.apache.qpid.protonj2.engine.EngineSaslDriver.SaslState
Authentication succeeded
AUTHENTICATING - org.apache.qpid.protonj2.engine.EngineSaslDriver.SaslState
Engine started and set configuration in use
AUTHENTICATION_FAILED - org.apache.qpid.protonj2.engine.EngineSaslDriver.SaslState
Authentication failed
autoAccept() - Method in class org.apache.qpid.protonj2.client.ReceiverOptions
 
autoAccept(boolean) - Method in class org.apache.qpid.protonj2.client.ReceiverOptions
Controls if the created Receiver will automatically accept the deliveries that have been received by the application (default is true).
autoAccept(boolean) - Method in class org.apache.qpid.protonj2.client.StreamReceiverOptions
 
autoSettle() - Method in class org.apache.qpid.protonj2.client.ReceiverOptions
 
autoSettle() - Method in class org.apache.qpid.protonj2.client.SenderOptions
Get whether the Sender is auto settling deliveries.
autoSettle(boolean) - Method in class org.apache.qpid.protonj2.client.ReceiverOptions
Controls if the created Receiver will automatically settle the deliveries that have been received by the application (default is true).
autoSettle(boolean) - Method in class org.apache.qpid.protonj2.client.SenderOptions
Sets whether sent deliveries should be automatically locally-settled once they have become remotely-settled by the receiving peer.
autoSettle(boolean) - Method in class org.apache.qpid.protonj2.client.StreamReceiverOptions
 
autoSettle(boolean) - Method in class org.apache.qpid.protonj2.client.StreamSenderOptions
 
available() - Method in class org.apache.qpid.protonj2.buffer.ProtonBufferInputStream
 
available() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonIncomingDelivery
 
available() - Method in interface org.apache.qpid.protonj2.engine.IncomingDelivery
Returns the number of bytes currently available for reading form this delivery, which may not be complete yet.
awaitAccepted() - Method in class org.apache.qpid.protonj2.client.impl.ClientNoOpTracker
 
awaitAccepted() - Method in interface org.apache.qpid.protonj2.client.Tracker
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.
awaitAccepted(long, TimeUnit) - Method in class org.apache.qpid.protonj2.client.impl.ClientNoOpTracker
 
awaitAccepted(long, TimeUnit) - Method in interface org.apache.qpid.protonj2.client.Tracker
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.
awaitConnect() - Method in class org.apache.qpid.protonj2.client.transport.TcpTransport
 
awaitConnect() - Method in interface org.apache.qpid.protonj2.client.transport.Transport
Waits interruptibly for the Transport to connect to the remote that was indicated in the Transport.connect(String, int, TransportListener) call.
awaitSettlement() - Method in class org.apache.qpid.protonj2.client.impl.ClientNoOpStreamTracker
 
awaitSettlement() - Method in class org.apache.qpid.protonj2.client.impl.ClientNoOpTracker
 
awaitSettlement() - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamTracker
 
awaitSettlement() - Method in interface org.apache.qpid.protonj2.client.StreamTracker
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.
awaitSettlement() - Method in interface org.apache.qpid.protonj2.client.Tracker
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.
awaitSettlement(long, TimeUnit) - Method in class org.apache.qpid.protonj2.client.impl.ClientNoOpStreamTracker
 
awaitSettlement(long, TimeUnit) - Method in class org.apache.qpid.protonj2.client.impl.ClientNoOpTracker
 
awaitSettlement(long, TimeUnit) - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamTracker
 
awaitSettlement(long, TimeUnit) - Method in interface org.apache.qpid.protonj2.client.StreamTracker
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.
awaitSettlement(long, TimeUnit) - Method in interface org.apache.qpid.protonj2.client.Tracker
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.
awaitTermination(ExecutorService, long) - Static method in class org.apache.qpid.protonj2.client.util.ThreadPoolUtils
Awaits the termination of the thread pool.

B

BALANCED - Static variable in class org.apache.qpid.protonj2.client.futures.ClientFutureFactory
Names a future type that uses a balanced spin then wait for the operation outcome.
BalancedClientFuture<V> - Class in org.apache.qpid.protonj2.client.futures
A more balanced implementation of a ClientFuture that works better on some platforms such as windows where the thread park and atomic operations used by a more aggressive implementation could result in poor performance.
BalancedClientFuture() - Constructor for class org.apache.qpid.protonj2.client.futures.BalancedClientFuture
Create a new BalancedClientFuture instance with no assigned ClientSynchronization.
BalancedClientFuture(ClientSynchronization<V>) - Constructor for class org.apache.qpid.protonj2.client.futures.BalancedClientFuture
Create a new BalancedClientFuture instance with the assigned ClientSynchronization.
begin(ClientFuture<Session>) - Method in interface org.apache.qpid.protonj2.client.impl.ClientTransactionContext
Begin a new transaction if one is not already in play.
Begin - Class in org.apache.qpid.protonj2.types.transport
 
Begin() - Constructor for class org.apache.qpid.protonj2.types.transport.Begin
 
BEGIN - org.apache.qpid.protonj2.types.transport.Performative.PerformativeType
 
beginMessage() - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamSender
 
beginMessage() - Method in interface org.apache.qpid.protonj2.client.StreamSender
Creates and returns a new StreamSenderMessage that can be used by the caller to perform streaming sends of large message payload data.
beginMessage(Map<String, Object>) - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamSender
 
beginMessage(Map<String, Object>) - Method in interface org.apache.qpid.protonj2.client.StreamSender
Creates and returns a new StreamSenderMessage that can be used by the caller to perform streaming sends of large message payload data.
beginTransaction() - Method in class org.apache.qpid.protonj2.client.impl.ClientSession
 
beginTransaction() - Method in interface org.apache.qpid.protonj2.client.Session
Opens a new transaction scoped to this Session if one is not already active.
BeginTypeDecoder - Class in org.apache.qpid.protonj2.codec.decoders.transport
Decoder of AMQP Begin type values from a byte stream
BeginTypeDecoder() - Constructor for class org.apache.qpid.protonj2.codec.decoders.transport.BeginTypeDecoder
 
BeginTypeEncoder - Class in org.apache.qpid.protonj2.codec.encoders.transport
Encoder of AMQP Begin type values to a byte stream.
BeginTypeEncoder() - Constructor for class org.apache.qpid.protonj2.codec.encoders.transport.BeginTypeEncoder
 
bigIntegerValue() - Method in class org.apache.qpid.protonj2.types.UnsignedLong
 
Binary - Class in org.apache.qpid.protonj2.types
 
Binary() - Constructor for class org.apache.qpid.protonj2.types.Binary
 
Binary(byte[]) - Constructor for class org.apache.qpid.protonj2.types.Binary
 
Binary(byte[], int, int) - Constructor for class org.apache.qpid.protonj2.types.Binary
 
Binary(ProtonBuffer) - Constructor for class org.apache.qpid.protonj2.types.Binary
 
Binary32TypeDecoder - Class in org.apache.qpid.protonj2.codec.decoders.primitives
Decoder of AMQP Binary values from a byte stream.
Binary32TypeDecoder() - Constructor for class org.apache.qpid.protonj2.codec.decoders.primitives.Binary32TypeDecoder
 
Binary8TypeDecoder - Class in org.apache.qpid.protonj2.codec.decoders.primitives
Decoder of AMQP Binary values with length less than 255 from a byte stream.
Binary8TypeDecoder() - Constructor for class org.apache.qpid.protonj2.codec.decoders.primitives.Binary8TypeDecoder
 
BinaryTypeDecoder - Interface in org.apache.qpid.protonj2.codec.decoders.primitives
Base for all Binary type value decoders.
BinaryTypeEncoder - Class in org.apache.qpid.protonj2.codec.encoders.primitives
Encoder of AMQP Binary type values to a byte stream.
BinaryTypeEncoder() - Constructor for class org.apache.qpid.protonj2.codec.encoders.primitives.BinaryTypeEncoder
 
body() - Method in class org.apache.qpid.protonj2.client.impl.ClientMessage
 
body() - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiverMessage
 
body() - Method in interface org.apache.qpid.protonj2.client.Message
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.
body(E) - Method in class org.apache.qpid.protonj2.client.impl.ClientMessage
 
body(E) - Method in interface org.apache.qpid.protonj2.client.Message
Sets the body value that is to be conveyed to the remote when this message is sent.
body(InputStream) - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiverMessage
 
body(OutputStreamOptions) - Method in interface org.apache.qpid.protonj2.client.StreamSenderMessage
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..
bodyLength() - Method in class org.apache.qpid.protonj2.client.OutputStreamOptions
 
bodyLength(int) - Method in class org.apache.qpid.protonj2.client.OutputStreamOptions
Sets the overall stream size for this associated OutputStream that the options are applied to.
bodySections() - Method in interface org.apache.qpid.protonj2.client.AdvancedMessage
Create and return an unmodifiable Collection that contains the Section instances currently assigned to this message.
bodySections() - Method in class org.apache.qpid.protonj2.client.impl.ClientMessage
 
bodySections() - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiverMessage
 
bodySections(Collection<Section<?>>) - Method in interface org.apache.qpid.protonj2.client.AdvancedMessage
Sets the body Section instances to use when encoding this message.
bodySections(Collection<Section<?>>) - Method in class org.apache.qpid.protonj2.client.impl.ClientMessage
 
bodySections(Collection<Section<?>>) - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiverMessage
 
BOOLEAN - Static variable in interface org.apache.qpid.protonj2.codec.EncodingCodes
 
BOOLEAN_FALSE - Static variable in interface org.apache.qpid.protonj2.codec.EncodingCodes
 
BOOLEAN_TRUE - Static variable in interface org.apache.qpid.protonj2.codec.EncodingCodes
 
BooleanFalseTypeDecoder - Class in org.apache.qpid.protonj2.codec.decoders.primitives
Decoder of AMQP Boolean False values from a byte stream.
BooleanFalseTypeDecoder() - Constructor for class org.apache.qpid.protonj2.codec.decoders.primitives.BooleanFalseTypeDecoder
 
BooleanTrueTypeDecoder - Class in org.apache.qpid.protonj2.codec.decoders.primitives
Decoder of AMQP Boolean True values from a byte stream.
BooleanTrueTypeDecoder() - Constructor for class org.apache.qpid.protonj2.codec.decoders.primitives.BooleanTrueTypeDecoder
 
BooleanTypeDecoder - Class in org.apache.qpid.protonj2.codec.decoders.primitives
Decoder of AMQP Boolean values from a byte stream.
BooleanTypeDecoder() - Constructor for class org.apache.qpid.protonj2.codec.decoders.primitives.BooleanTypeDecoder
 
BooleanTypeEncoder - Class in org.apache.qpid.protonj2.codec.encoders.primitives
Encoder of AMQP Boolean True types to a byte stream.
BooleanTypeEncoder() - Constructor for class org.apache.qpid.protonj2.codec.encoders.primitives.BooleanTypeEncoder
 
bootstrap - Variable in class org.apache.qpid.protonj2.client.transport.TcpTransport
 
BYTE - Static variable in interface org.apache.qpid.protonj2.codec.EncodingCodes
 
BYTES - Static variable in class org.apache.qpid.protonj2.types.Decimal128
The number of bytes used to represent a Decimal128 value in two's complement binary form.
BYTES - Static variable in class org.apache.qpid.protonj2.types.Decimal32
The number of bytes used to represent a Decimal128 value in two's complement binary form.
BYTES - Static variable in class org.apache.qpid.protonj2.types.Decimal64
The number of bytes used to represent a Decimal128 value in two's complement binary form.
ByteTypeDecoder - Class in org.apache.qpid.protonj2.codec.decoders.primitives
Decoder of AMQP Bytes from a byte stream.
ByteTypeDecoder() - Constructor for class org.apache.qpid.protonj2.codec.decoders.primitives.ByteTypeDecoder
 
ByteTypeEncoder - Class in org.apache.qpid.protonj2.codec.encoders.primitives
Encoder of AMQP byte type value to a byte stream.
ByteTypeEncoder() - Constructor for class org.apache.qpid.protonj2.codec.encoders.primitives.ByteTypeEncoder
 
byteValue() - Method in enum org.apache.qpid.protonj2.types.security.SaslCode
 
byteValue() - Method in enum org.apache.qpid.protonj2.types.transport.ReceiverSettleMode
 
byteValue() - Method in enum org.apache.qpid.protonj2.types.transport.SenderSettleMode
 
byteValue() - Method in class org.apache.qpid.protonj2.types.UnsignedByte
 

C

cancel(boolean) - Method in class org.apache.qpid.protonj2.client.futures.ClientFuture
 
CANCELLED - Static variable in class org.apache.qpid.protonj2.client.futures.ClientFuture
 
capabilities() - Method in interface org.apache.qpid.protonj2.client.Source
 
capabilities() - Method in interface org.apache.qpid.protonj2.client.Target
 
capabilities() - Method in class org.apache.qpid.protonj2.client.TerminusOptions
 
capabilities(String...) - Method in class org.apache.qpid.protonj2.client.TerminusOptions
 
capacity() - Method in interface org.apache.qpid.protonj2.buffer.ProtonBuffer
 
capacity() - Method in class org.apache.qpid.protonj2.buffer.ProtonByteBuffer
 
capacity() - Method in class org.apache.qpid.protonj2.buffer.ProtonCompositeBuffer
 
capacity() - Method in class org.apache.qpid.protonj2.buffer.ProtonDuplicatedBuffer
 
capacity() - Method in class org.apache.qpid.protonj2.buffer.ProtonNettyByteBuffer
 
capacity() - Method in class org.apache.qpid.protonj2.buffer.ProtonNioByteBuffer
 
capacity() - Method in class org.apache.qpid.protonj2.buffer.ProtonSlicedBuffer
 
capacity(int) - Method in interface org.apache.qpid.protonj2.buffer.ProtonBuffer
Adjusts the capacity of this buffer.
capacity(int) - Method in class org.apache.qpid.protonj2.buffer.ProtonByteBuffer
 
capacity(int) - Method in class org.apache.qpid.protonj2.buffer.ProtonCompositeBuffer
 
capacity(int) - Method in class org.apache.qpid.protonj2.buffer.ProtonDuplicatedBuffer
 
capacity(int) - Method in class org.apache.qpid.protonj2.buffer.ProtonNettyByteBuffer
 
capacity(int) - Method in class org.apache.qpid.protonj2.buffer.ProtonNioByteBuffer
 
capacity(int) - Method in class org.apache.qpid.protonj2.buffer.ProtonSlicedBuffer
 
ceilingEntry(UnsignedInteger) - Method in class org.apache.qpid.protonj2.engine.util.SplayMap
 
ceilingKey(UnsignedInteger) - Method in class org.apache.qpid.protonj2.engine.util.SplayMap
 
CHALLENGE - org.apache.qpid.protonj2.types.security.SaslPerformative.SaslPerformativeType
 
channel - Variable in class org.apache.qpid.protonj2.client.transport.TcpTransport
 
CHANNEL_MAX - Static variable in class org.apache.qpid.protonj2.engine.impl.ProtonConstants
The maximum value for AMQP channels as defined by the specification.
channelActive(ChannelHandlerContext) - Method in class org.apache.qpid.protonj2.client.transport.TcpTransport.NettyDefaultHandler
 
channelInactive(ChannelHandlerContext) - Method in class org.apache.qpid.protonj2.client.transport.TcpTransport.NettyDefaultHandler
 
channelMax() - Method in class org.apache.qpid.protonj2.client.ConnectionOptions
 
channelMax(int) - Method in class org.apache.qpid.protonj2.client.ConnectionOptions
Configure the channel maximum value for the new Connection created with these options.
channelRead0(ChannelHandlerContext, ByteBuf) - Method in class org.apache.qpid.protonj2.client.transport.TcpTransport.NettyTcpTransportHandler
 
channelRegistered(ChannelHandlerContext) - Method in class org.apache.qpid.protonj2.client.transport.TcpTransport.NettyDefaultHandler
 
CHAR - Static variable in interface org.apache.qpid.protonj2.codec.EncodingCodes
 
CharacterTypeDecoder - Class in org.apache.qpid.protonj2.codec.decoders.primitives
Decoder of AMQP Character from a byte stream.
CharacterTypeDecoder() - Constructor for class org.apache.qpid.protonj2.codec.decoders.primitives.CharacterTypeDecoder
 
CharacterTypeEncoder - Class in org.apache.qpid.protonj2.codec.encoders.primitives
Encoder of AMQP Character type values to a byte stream.
CharacterTypeEncoder() - Constructor for class org.apache.qpid.protonj2.codec.encoders.primitives.CharacterTypeEncoder
 
checkClosedOrFailed() - Method in class org.apache.qpid.protonj2.client.impl.ClientConnection
 
checkClosedOrFailed() - Method in class org.apache.qpid.protonj2.client.impl.ClientSession
 
checkConnected() - Method in class org.apache.qpid.protonj2.client.transport.TcpTransport
 
checkDestinationIndex(int, int, int, int) - Method in class org.apache.qpid.protonj2.buffer.ProtonAbstractBuffer
 
checkIndex(int, int) - Method in class org.apache.qpid.protonj2.buffer.ProtonAbstractBuffer
 
checkIsExpectedType(Class<?>, StreamTypeDecoder<?>) - Static method in class org.apache.qpid.protonj2.codec.decoders.AbstractDescribedTypeDecoder
 
checkIsExpectedType(Class<?>, TypeDecoder<?>) - Static method in class org.apache.qpid.protonj2.codec.decoders.AbstractDescribedTypeDecoder
 
checkIsExpectedTypeAndCast(Class<?>, StreamTypeDecoder<?>) - Static method in class org.apache.qpid.protonj2.codec.decoders.AbstractDescribedTypeDecoder
 
checkIsExpectedTypeAndCast(Class<?>, TypeDecoder<?>) - Static method in class org.apache.qpid.protonj2.codec.decoders.AbstractDescribedTypeDecoder
 
checkLinkOperable(String) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonLink
 
checkNewCapacity(int) - Method in class org.apache.qpid.protonj2.buffer.ProtonAbstractBuffer
 
checkNotClosed(String) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonLink
 
checkNotOpened(String) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonLink
 
checkReadableBytes(int) - Method in class org.apache.qpid.protonj2.buffer.ProtonAbstractBuffer
 
checkSourceIndex(int, int, int, int) - Method in class org.apache.qpid.protonj2.buffer.ProtonAbstractBuffer
 
chooseClientAlias(String[], Principal[], Socket) - Method in class org.apache.qpid.protonj2.client.transport.X509AliasKeyManager
 
chooseEngineClientAlias(String[], Principal[], SSLEngine) - Method in class org.apache.qpid.protonj2.client.transport.X509AliasKeyManager
 
chooseEngineServerAlias(String, Principal[], SSLEngine) - Method in class org.apache.qpid.protonj2.client.transport.X509AliasKeyManager
 
chooseServerAlias(String, Principal[], Socket) - Method in class org.apache.qpid.protonj2.client.transport.X509AliasKeyManager
 
claimAvailableBytes() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonIncomingDelivery
 
claimAvailableBytes() - Method in interface org.apache.qpid.protonj2.engine.IncomingDelivery
Marks all available bytes as being claimed by the caller meaning that available byte count value can be returned to the session which can expand the session incoming window to allow more bytes to be sent from the remote peer.
clear() - Method in class org.apache.qpid.protonj2.buffer.ProtonAbstractBuffer
 
clear() - Method in interface org.apache.qpid.protonj2.buffer.ProtonBuffer
Reset the read and write offsets to zero and clears the position markers if set previously, this method is not required to reset the data previously written to this buffer.
clear() - Method in class org.apache.qpid.protonj2.buffer.ProtonNettyByteBuffer
 
clear() - Method in interface org.apache.qpid.protonj2.client.util.DeliveryQueue
Clears the Queue of any queued Delivery values.
clear() - Method in class org.apache.qpid.protonj2.client.util.FifoDeliveryQueue
 
clear() - Method in interface org.apache.qpid.protonj2.engine.Attachments
 
clear() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonAttachments
 
clear() - Method in class org.apache.qpid.protonj2.engine.util.LinkedSplayMap
 
clear() - Method in class org.apache.qpid.protonj2.engine.util.RingQueue
 
clear() - Method in class org.apache.qpid.protonj2.engine.util.SplayMap
 
clearAborted() - Method in class org.apache.qpid.protonj2.types.transport.Transfer
 
clearAbsoluteExpiryTime() - Method in class org.apache.qpid.protonj2.types.messaging.Properties
 
clearAvailable() - Method in class org.apache.qpid.protonj2.types.transport.Flow
 
clearBatchable() - Method in class org.apache.qpid.protonj2.types.transport.Disposition
 
clearBatchable() - Method in class org.apache.qpid.protonj2.types.transport.Transfer
 
clearBodySections() - Method in interface org.apache.qpid.protonj2.client.AdvancedMessage
Clears all current body Section elements from the AdvancedMessage.
clearBodySections() - Method in class org.apache.qpid.protonj2.client.impl.ClientMessage
 
clearBodySections() - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiverMessage
 
clearCreationTime() - Method in class org.apache.qpid.protonj2.types.messaging.Properties
 
clearDeliveryCount() - Method in class org.apache.qpid.protonj2.types.messaging.Header
 
clearDeliveryCount() - Method in class org.apache.qpid.protonj2.types.transport.Flow
 
clearDeliveryId() - Method in class org.apache.qpid.protonj2.types.transport.Transfer
 
clearDeliveryTag() - Method in class org.apache.qpid.protonj2.types.transport.Transfer
 
clearDrain() - Method in class org.apache.qpid.protonj2.types.transport.Flow
 
clearDurable() - Method in class org.apache.qpid.protonj2.types.messaging.Header
 
clearEcho() - Method in class org.apache.qpid.protonj2.types.transport.Flow
 
clearFirst() - Method in class org.apache.qpid.protonj2.types.transport.Disposition
 
clearFirstAcquirer() - Method in class org.apache.qpid.protonj2.types.messaging.Header
 
clearGroupSequence() - Method in class org.apache.qpid.protonj2.types.messaging.Properties
 
clearHandle() - Method in class org.apache.qpid.protonj2.types.transport.Flow
 
clearHandle() - Method in class org.apache.qpid.protonj2.types.transport.Transfer
 
clearIncomingWindow() - Method in class org.apache.qpid.protonj2.types.transport.Flow
 
clearLast() - Method in class org.apache.qpid.protonj2.types.transport.Disposition
 
clearLinkCredit() - Method in class org.apache.qpid.protonj2.types.transport.Flow
 
clearMessageFormat() - Method in class org.apache.qpid.protonj2.types.transport.Transfer
 
clearMore() - Method in class org.apache.qpid.protonj2.types.transport.Transfer
 
clearNextIncomingId() - Method in class org.apache.qpid.protonj2.types.transport.Flow
 
clearNextOutgoingId() - Method in class org.apache.qpid.protonj2.types.transport.Flow
 
clearOutgoingWindow() - Method in class org.apache.qpid.protonj2.types.transport.Flow
 
clearPriority() - Method in class org.apache.qpid.protonj2.types.messaging.Header
 
clearProperties() - Method in class org.apache.qpid.protonj2.types.transport.Flow
 
clearRcvSettleMode() - Method in class org.apache.qpid.protonj2.types.transport.Transfer
 
clearResume() - Method in class org.apache.qpid.protonj2.types.transport.Transfer
 
clearRole() - Method in class org.apache.qpid.protonj2.types.transport.Disposition
 
clearSettled() - Method in class org.apache.qpid.protonj2.types.transport.Disposition
 
clearSettled() - Method in class org.apache.qpid.protonj2.types.transport.Transfer
 
clearState() - Method in class org.apache.qpid.protonj2.types.transport.Disposition
 
clearState() - Method in class org.apache.qpid.protonj2.types.transport.Transfer
 
clearTimeToLive() - Method in class org.apache.qpid.protonj2.types.messaging.Header
 
client() - Method in interface org.apache.qpid.protonj2.client.Connection
 
client() - Method in class org.apache.qpid.protonj2.client.impl.ClientConnection
 
client() - Method in class org.apache.qpid.protonj2.client.impl.ClientReceiver
 
client() - Method in class org.apache.qpid.protonj2.client.impl.ClientSession
 
client() - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiver
 
client() - Method in interface org.apache.qpid.protonj2.client.Receiver
 
client() - Method in interface org.apache.qpid.protonj2.client.Sender
 
client() - Method in interface org.apache.qpid.protonj2.client.Session
 
client() - Method in interface org.apache.qpid.protonj2.engine.EngineSaslDriver
Configure this EngineSaslDriver to operate in client mode and return the associated SaslClientContext instance that should be used to complete the SASL negotiation with the server end.
client() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEngineNoOpSaslDriver
 
Client - Interface in org.apache.qpid.protonj2.client
The Container that hosts AMQP Connections
CLIENT - org.apache.qpid.protonj2.engine.sasl.SaslContext.Role
 
ClientAccepted() - Constructor for class org.apache.qpid.protonj2.client.impl.ClientDeliveryState.ClientAccepted
 
ClientConnection - Class in org.apache.qpid.protonj2.client.impl
A Connection implementation that uses the Proton engine for AMQP protocol support.
ClientConnectionCapabilities - Class in org.apache.qpid.protonj2.client.impl
Tracks available known capabilities for the connection to allow the client to know what features are supported on the current connection.
ClientConnectionCapabilities() - Constructor for class org.apache.qpid.protonj2.client.impl.ClientConnectionCapabilities
 
ClientConnectionRedirectedException - Exception in org.apache.qpid.protonj2.client.exceptions
A ClientIOException type that defines that the remote peer has requested that this connection be redirected to some alternative peer.
ClientConnectionRedirectedException(String, ClientRedirect, ErrorCondition) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientConnectionRedirectedException
Creates a new connection redirect exception with the provided redirection information.
ClientConnectionRemotelyClosedException - Exception in org.apache.qpid.protonj2.client.exceptions
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.
ClientConnectionRemotelyClosedException(String) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientConnectionRemotelyClosedException
Creates a new connection remotely closed exception.
ClientConnectionRemotelyClosedException(String, Throwable) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientConnectionRemotelyClosedException
Creates a new connection remotely closed exception.
ClientConnectionRemotelyClosedException(String, Throwable, ErrorCondition) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientConnectionRemotelyClosedException
Creates a new connection remotely closed exception.
ClientConnectionRemotelyClosedException(String, ErrorCondition) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientConnectionRemotelyClosedException
Creates a new connection remotely closed exception.
ClientConnectionSecurityException - Exception in org.apache.qpid.protonj2.client.exceptions
Connection level Security Exception used to indicate a security violation has occurred.
ClientConnectionSecurityException(String) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientConnectionSecurityException
Creates a new connection security exception.
ClientConnectionSecurityException(String, Throwable) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientConnectionSecurityException
Creates a new connection security exception.
ClientConnectionSecurityException(String, Throwable, ErrorCondition) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientConnectionSecurityException
Creates a new connection security exception.
ClientConnectionSecurityException(String, ErrorCondition) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientConnectionSecurityException
Creates a new connection security exception.
ClientConnectionSecuritySaslException - Exception in org.apache.qpid.protonj2.client.exceptions
Security Exception used to indicate a security violation has occurred.
ClientConnectionSecuritySaslException(String) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientConnectionSecuritySaslException
Create a new instance of the connection SASL security exception
ClientConnectionSecuritySaslException(String, boolean) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientConnectionSecuritySaslException
Create a new instance of the connection SASL security exception
ClientConnectionSecuritySaslException(String, boolean, Throwable) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientConnectionSecuritySaslException
Create a new instance of the connection SASL security exception
ClientConnectionSecuritySaslException(String, Throwable) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientConnectionSecuritySaslException
Create a new instance of the connection SASL security exception
ClientConstants - Class in org.apache.qpid.protonj2.client.impl
Constants that are used throughout the client implementation.
ClientConstants() - Constructor for class org.apache.qpid.protonj2.client.impl.ClientConstants
 
ClientDelivery - Class in org.apache.qpid.protonj2.client.impl
Client inbound delivery object.
ClientDeliveryAbortedException - Exception in org.apache.qpid.protonj2.client.exceptions
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.
ClientDeliveryAbortedException(String) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientDeliveryAbortedException
Creates a new delivery aborted exception.
ClientDeliveryAbortedException(String, Throwable) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientDeliveryAbortedException
Creates a new delivery aborted exception.
ClientDeliveryIsPartialException - Exception in org.apache.qpid.protonj2.client.exceptions
Thrown in cases where an action was requested that cannot be performed because the delivery being operated on is only the partial Transfer payload.
ClientDeliveryIsPartialException(String) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientDeliveryIsPartialException
Creates a new delivery is partial exception.
ClientDeliveryIsPartialException(String, Throwable) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientDeliveryIsPartialException
Creates a new delivery is partial exception.
ClientDeliveryState - Class in org.apache.qpid.protonj2.client.impl
Client internal implementation of a DeliveryState type.
ClientDeliveryState() - Constructor for class org.apache.qpid.protonj2.client.impl.ClientDeliveryState
 
ClientDeliveryState.ClientAccepted - Class in org.apache.qpid.protonj2.client.impl
Client defined Accepted delivery state definition
ClientDeliveryState.ClientModified - Class in org.apache.qpid.protonj2.client.impl
Client defined Modified delivery state definition
ClientDeliveryState.ClientRejected - Class in org.apache.qpid.protonj2.client.impl
Client defined Rejected delivery state definition
ClientDeliveryState.ClientReleased - Class in org.apache.qpid.protonj2.client.impl
Client defined Released delivery state definition
ClientDeliveryState.ClientTransactional - Class in org.apache.qpid.protonj2.client.impl
Client defined TransactionalState delivery state definition
ClientDeliveryStateException - Exception in org.apache.qpid.protonj2.client.exceptions
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.
ClientDeliveryStateException(String, Throwable, DeliveryState) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientDeliveryStateException
Create a new instance of the client delivery state error.
ClientDeliveryStateException(String, DeliveryState) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientDeliveryStateException
Create a new instance of the client delivery state error.
ClientErrorCondition - Class in org.apache.qpid.protonj2.client.impl
Client implementation of the ErrorCondition type that wraps a Proton specific AMQP ErrorCondition.
ClientErrorCondition(String, String, Map<String, Object>) - Constructor for class org.apache.qpid.protonj2.client.impl.ClientErrorCondition
Create a new ClientErrorCondition instance with the given error information
ClientErrorCondition(ErrorCondition) - Constructor for class org.apache.qpid.protonj2.client.impl.ClientErrorCondition
Create a new ClientErrorCondition that is a copy of the provided instance.
ClientException - Exception in org.apache.qpid.protonj2.client.exceptions
Represents a non-fatal exception that occurs from a Client Connection or one of its resources.
ClientException(String) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientException
Creates a new client exception.
ClientException(String, Throwable) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientException
Creates a new client exception.
ClientFuture<V> - Class in org.apache.qpid.protonj2.client.futures
Asynchronous Client Future class.
ClientFuture(ClientSynchronization<V>) - Constructor for class org.apache.qpid.protonj2.client.futures.ClientFuture
 
ClientFutureFactory - Class in org.apache.qpid.protonj2.client.futures
Factory for client future instances that will create specific versions based on configuration.
ClientFutureFactory() - Constructor for class org.apache.qpid.protonj2.client.futures.ClientFutureFactory
 
ClientIdleTimeoutException - Exception in org.apache.qpid.protonj2.client.exceptions
Thrown when the Provider fails a connection due to idle timeout.
ClientIdleTimeoutException(String) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientIdleTimeoutException
Creates a new connection idle timeout exception.
ClientIdleTimeoutException(String, Throwable) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientIdleTimeoutException
Creates a new connection idle timeout exception.
ClientIllegalStateException - Exception in org.apache.qpid.protonj2.client.exceptions
 
ClientIllegalStateException(String) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientIllegalStateException
Creates a new connection illegal state exception.
ClientIllegalStateException(String, Throwable) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientIllegalStateException
Creates a new connection illegal state exception.
ClientInstance - Class in org.apache.qpid.protonj2.client.impl
Container of Connection instances that are all created with the same container parent and therefore share the same container Id.
ClientIOException - Exception in org.apache.qpid.protonj2.client.exceptions
Exception type that is thrown when the provider has encountered an unrecoverable error.
ClientIOException(String) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientIOException
Creates a new connection I/O exception.
ClientIOException(String, Throwable) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientIOException
Creates a new connection I/O exception.
ClientLinkRedirectedException - Exception in org.apache.qpid.protonj2.client.exceptions
A ClientLinkRemotelyClosedException type that defines that the remote peer has requested that this link be redirected to some alternative peer.
ClientLinkRedirectedException(String, ClientRedirect, ErrorCondition) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientLinkRedirectedException
Create a new instance of the link redirected exception
ClientLinkRemotelyClosedException - Exception in org.apache.qpid.protonj2.client.exceptions
Root exception type for cases of remote closure or client created Sender or Receiver.
ClientLinkRemotelyClosedException(String) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientLinkRemotelyClosedException
Creates a new link remotely closed exception.
ClientLinkRemotelyClosedException(String, Throwable) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientLinkRemotelyClosedException
Creates a new link remotely closed exception.
ClientLinkRemotelyClosedException(String, Throwable, ErrorCondition) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientLinkRemotelyClosedException
Creates a new link remotely closed exception.
ClientLinkRemotelyClosedException(String, ErrorCondition) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientLinkRemotelyClosedException
Creates a new link remotely closed exception.
ClientMessage<E> - Class in org.apache.qpid.protonj2.client.impl
Client provided AdvancedMessage implementation that is used when sending messages from a ClientSender or when decoding an AMQP Transfer for which all frames have arrived.
ClientMessageFormatViolationException - Exception in org.apache.qpid.protonj2.client.exceptions
Exception thrown from Message instances when the body section specified violates the configure message format of the message that is being created.
ClientMessageFormatViolationException(String) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientMessageFormatViolationException
Creates a new connection message format violation exception.
ClientMessageFormatViolationException(String, Throwable) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientMessageFormatViolationException
Creates a new connection message format violation exception.
ClientMessageSupport - Class in org.apache.qpid.protonj2.client.impl
Support methods dealing with Message types and encode or decode operations.
ClientMessageSupport() - Constructor for class org.apache.qpid.protonj2.client.impl.ClientMessageSupport
 
ClientModified(boolean, boolean) - Constructor for class org.apache.qpid.protonj2.client.impl.ClientDeliveryState.ClientModified
Create a new instance with the given outcome values.
ClientModified(boolean, boolean, Map<String, Object>) - Constructor for class org.apache.qpid.protonj2.client.impl.ClientDeliveryState.ClientModified
Create a new instance with the given outcome values.
ClientNoOpStreamTracker - Class in org.apache.qpid.protonj2.client.impl
A dummy Tracker instance that always indicates remote settlement and acceptance for StreamSender instances.
ClientNoOpTracker - Class in org.apache.qpid.protonj2.client.impl
A dummy Tracker instance that always indicates remote settlement and acceptance.
ClientOperationTimedOutException - Exception in org.apache.qpid.protonj2.client.exceptions
Indicates that an operation in the provider timed out waiting for completion
ClientOperationTimedOutException(String) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientOperationTimedOutException
Creates a new connection operation timed out exception.
ClientOperationTimedOutException(String, Throwable) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientOperationTimedOutException
Creates a new connection operation timed out exception.
ClientOptions - Class in org.apache.qpid.protonj2.client
Container Options for customizing the behavior of the Container
ClientOptions() - Constructor for class org.apache.qpid.protonj2.client.ClientOptions
Create a new ClientOptions instance with defaults set for all options.
ClientOptions(ClientOptions) - Constructor for class org.apache.qpid.protonj2.client.ClientOptions
Create a new ClientOptions instance that copies the configuration from the specified source options.
ClientOutgoingEnvelope - Class in org.apache.qpid.protonj2.client.impl
Tracking object used to manage the life-cycle of a send of message payload to the remote which can be stalled either for link or session credit limits.
ClientOutgoingEnvelope(ClientSender, OutgoingDelivery, int, ProtonBuffer, boolean, ClientFuture<Tracker>) - Constructor for class org.apache.qpid.protonj2.client.impl.ClientOutgoingEnvelope
Create a new In-flight Send instance that is a continuation on an existing delivery.
ClientReceiver - Class in org.apache.qpid.protonj2.client.impl
Client Receiver implementation.
ClientRedirect - Class in org.apache.qpid.protonj2.client.impl
Encapsulates the AMQP Redirect Map
ClientRejected(String, String) - Constructor for class org.apache.qpid.protonj2.client.impl.ClientDeliveryState.ClientRejected
Create a new Rejected outcome with the given description of the rejection cause.
ClientRejected(String, String, Map<String, Object>) - Constructor for class org.apache.qpid.protonj2.client.impl.ClientDeliveryState.ClientRejected
Create a new Rejected outcome with the given description of the rejection cause.
ClientReleased() - Constructor for class org.apache.qpid.protonj2.client.impl.ClientDeliveryState.ClientReleased
 
ClientResourceRemotelyClosedException - Exception in org.apache.qpid.protonj2.client.exceptions
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.
ClientResourceRemotelyClosedException(String) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientResourceRemotelyClosedException
Creates a new resource remotely closed exception.
ClientResourceRemotelyClosedException(String, Throwable) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientResourceRemotelyClosedException
Creates a new resource remotely closed exception.
ClientResourceRemotelyClosedException(String, Throwable, ErrorCondition) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientResourceRemotelyClosedException
Creates a new resource remotely closed exception.
ClientResourceRemotelyClosedException(String, ErrorCondition) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientResourceRemotelyClosedException
Creates a new resource remotely closed exception.
ClientSendTimedOutException - Exception in org.apache.qpid.protonj2.client.exceptions
Thrown when a message send operation times out in the Provider layer.
ClientSendTimedOutException(String) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientSendTimedOutException
Creates a new connection send timed out exception.
ClientSession - Class in org.apache.qpid.protonj2.client.impl
Client implementation of the Session API.
ClientSessionRemotelyClosedException - Exception in org.apache.qpid.protonj2.client.exceptions
Root exception type for cases of remote closure or client created Session.
ClientSessionRemotelyClosedException(String) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientSessionRemotelyClosedException
Creates a new session remotely closed exception.
ClientSessionRemotelyClosedException(String, Throwable) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientSessionRemotelyClosedException
Creates a new session remotely closed exception.
ClientSessionRemotelyClosedException(String, Throwable, ErrorCondition) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientSessionRemotelyClosedException
Creates a new session remotely closed exception.
ClientSessionRemotelyClosedException(String, ErrorCondition) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientSessionRemotelyClosedException
Creates a new session remotely closed exception.
ClientStreamDelivery - Class in org.apache.qpid.protonj2.client.impl
A StreamDelivery implementation that provides the mechanics of reading message types from an incoming split framed transfer.
ClientStreamReceiver - Class in org.apache.qpid.protonj2.client.impl
Client implementation of a StreamReceiver.
ClientStreamReceiverMessage - Class in org.apache.qpid.protonj2.client.impl
Streamed message delivery context used to request reads of possible split framed Transfer payload's that comprise a single large overall message.
ClientStreamSender - Class in org.apache.qpid.protonj2.client.impl
Client implementation of a StreamSender.
ClientStreamSession - Class in org.apache.qpid.protonj2.client.impl
A specialized ClientSession that is the parent of a ClientStreamSender or ClientStreamReceiver and cannot create any further resources as the lifetime of the session is tied to the child StreamSender or StreamReceiver.
ClientStreamTracker - Class in org.apache.qpid.protonj2.client.impl
StreamTracker implementation that relies on the ClientTracker to handle the basic OutgoingDelivery management.
ClientSynchronization<V> - Interface in org.apache.qpid.protonj2.client.futures
Synchronization callback interface used to execute state updates or similar tasks in the thread context where the associated Future is managed.
ClientTransactionContext - Interface in org.apache.qpid.protonj2.client.impl
Base for a Transaction Context used in ClientSession instances to mask from the senders and receivers the work of deciding transaction specific behaviors.
ClientTransactionDeclarationException - Exception in org.apache.qpid.protonj2.client.exceptions
Thrown when a transaction declaration fails or is rejected by the remote.
ClientTransactionDeclarationException(String) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientTransactionDeclarationException
Creates a new transaction declaration exception.
ClientTransactionDeclarationException(String, Throwable) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientTransactionDeclarationException
Creates a new transaction declaration exception.
ClientTransactionInDoubtException - Exception in org.apache.qpid.protonj2.client.exceptions
Thrown when a transaction operation fails and state is now unknown.
ClientTransactionInDoubtException(String) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientTransactionInDoubtException
Creates a new transaction in doubt exception.
ClientTransactionInDoubtException(String, Throwable) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientTransactionInDoubtException
Creates a new transaction in doubt exception.
ClientTransactionNotActiveException - Exception in org.apache.qpid.protonj2.client.exceptions
Thrown when a client attempt to commit or roll-back when no transaction has been declared.
ClientTransactionNotActiveException(String) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientTransactionNotActiveException
Creates a new transaction not active exception.
ClientTransactionNotActiveException(String, Throwable) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientTransactionNotActiveException
Creates a new transaction not active exception.
ClientTransactionRolledBackException - Exception in org.apache.qpid.protonj2.client.exceptions
Thrown when a message send operation times out in the Provider layer.
ClientTransactionRolledBackException(String) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientTransactionRolledBackException
Creates a new transaction rolled back exception.
ClientTransactionRolledBackException(String, Throwable) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientTransactionRolledBackException
Creates a new transaction rolled back exception.
ClientUnsupportedOperationException - Exception in org.apache.qpid.protonj2.client.exceptions
Thrown when an action request is not supported through this provider.
ClientUnsupportedOperationException(String) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientUnsupportedOperationException
Creates a new unsupported operation exception.
ClientUnsupportedOperationException(String, Throwable) - Constructor for exception org.apache.qpid.protonj2.client.exceptions.ClientUnsupportedOperationException
Creates a new unsupported operation exception.
clone() - Method in class org.apache.qpid.protonj2.client.ClientOptions
 
clone() - Method in class org.apache.qpid.protonj2.client.ConnectionOptions
 
clone() - Method in class org.apache.qpid.protonj2.client.OutputStreamOptions
 
clone() - Method in class org.apache.qpid.protonj2.client.ReceiverOptions
 
clone() - Method in class org.apache.qpid.protonj2.client.SaslOptions
 
clone() - Method in class org.apache.qpid.protonj2.client.SenderOptions
 
clone() - Method in class org.apache.qpid.protonj2.client.SessionOptions
 
clone() - Method in class org.apache.qpid.protonj2.client.SourceOptions
 
clone() - Method in class org.apache.qpid.protonj2.client.SslOptions
 
clone() - Method in class org.apache.qpid.protonj2.client.StreamReceiverOptions
 
clone() - Method in class org.apache.qpid.protonj2.client.StreamSenderOptions
 
clone() - Method in class org.apache.qpid.protonj2.client.TargetOptions
 
clone() - Method in class org.apache.qpid.protonj2.client.TransportOptions
 
close() - Method in class org.apache.qpid.protonj2.buffer.ProtonBufferInputStream
 
close() - Method in class org.apache.qpid.protonj2.buffer.ProtonBufferOutputStream
 
close() - Method in interface org.apache.qpid.protonj2.client.Client
Closes all currently open Connection instances created by this client.
close() - Method in interface org.apache.qpid.protonj2.client.Connection
Requests a close of the Connection at the remote and waits until the Connection has been fully closed or until the configured ConnectionOptions.closeTimeout() is exceeded.
close() - Method in class org.apache.qpid.protonj2.client.impl.ClientConnection
 
close() - Method in class org.apache.qpid.protonj2.client.impl.ClientInstance
 
close() - Method in class org.apache.qpid.protonj2.client.impl.ClientReceiver
 
close() - Method in class org.apache.qpid.protonj2.client.impl.ClientSession
 
close() - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiver
 
close() - Method in interface org.apache.qpid.protonj2.client.Receiver
Requests a close of the Receiver at the remote and waits until the Receiver has been fully closed or until the configured ReceiverOptions.closeTimeout() is exceeded.
close() - Method in interface org.apache.qpid.protonj2.client.Sender
Requests a close of the Sender at the remote and waits until the Sender has been fully closed or until the configured SenderOptions.closeTimeout() is exceeded.
close() - Method in interface org.apache.qpid.protonj2.client.Session
Requests a close of the Session at the remote and waits until the Session has been fully closed or until the configured SessionOptions.closeTimeout() is exceeded.
close() - Method in class org.apache.qpid.protonj2.client.transport.TcpTransport
 
close() - Method in interface org.apache.qpid.protonj2.client.transport.Transport
Close the Transport, no additional send operations are accepted.
close() - Method in interface org.apache.qpid.protonj2.client.util.DeliveryQueue
Closes the Delivery Queue.
close() - Method in class org.apache.qpid.protonj2.client.util.FifoDeliveryQueue
 
close() - Method in interface org.apache.qpid.protonj2.engine.Endpoint
Close the end point locally and send the closing performative immediately if possible or holds it until the Connection / Engine state allows it.
close() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonConnection
 
close() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonLink
 
close() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonSession
 
close() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonTransactionController
 
close() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonTransactionManager
 
close(ErrorCondition) - Method in interface org.apache.qpid.protonj2.client.Connection
Requests a close of the Connection at the remote and waits until the Connection has been fully closed or until the configured ConnectionOptions.closeTimeout() is exceeded.
close(ErrorCondition) - Method in class org.apache.qpid.protonj2.client.impl.ClientConnection
 
close(ErrorCondition) - Method in class org.apache.qpid.protonj2.client.impl.ClientReceiver
 
close(ErrorCondition) - Method in class org.apache.qpid.protonj2.client.impl.ClientSession
 
close(ErrorCondition) - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiver
 
close(ErrorCondition) - Method in interface org.apache.qpid.protonj2.client.Receiver
Requests a close of the Receiver at the remote and waits until the Receiver has been fully closed or until the configured ReceiverOptions.closeTimeout() is exceeded.
close(ErrorCondition) - Method in interface org.apache.qpid.protonj2.client.Sender
Requests a close of the Sender at the remote and waits until the Sender has been fully closed or until the configured SenderOptions.closeTimeout() is exceeded.
close(ErrorCondition) - Method in interface org.apache.qpid.protonj2.client.Session
Requests a close of the Session at the remote and waits until the Session has been fully closed or until the configured SessionOptions.closeTimeout() is exceeded.
Close - Class in org.apache.qpid.protonj2.types.transport
Defines an AMQP Close performative used to end AMQP Connection instances.
Close() - Constructor for class org.apache.qpid.protonj2.types.transport.Close
 
CLOSE - org.apache.qpid.protonj2.types.transport.Performative.PerformativeType
 
closeAsync() - Method in interface org.apache.qpid.protonj2.client.Client
Closes all currently open Connection instances created by this client.
closeAsync() - Method in interface org.apache.qpid.protonj2.client.Connection
Requests a close of the Connection at the remote and returns a Future that will be completed once the Connection has been fully closed.
closeAsync() - Method in class org.apache.qpid.protonj2.client.impl.ClientConnection
 
closeAsync() - Method in class org.apache.qpid.protonj2.client.impl.ClientInstance
 
closeAsync() - Method in class org.apache.qpid.protonj2.client.impl.ClientReceiver
 
closeAsync() - Method in class org.apache.qpid.protonj2.client.impl.ClientSession
 
closeAsync() - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiver
 
closeAsync() - Method in interface org.apache.qpid.protonj2.client.Receiver
Requests a close of the Receiver link at the remote and returns a Future that will be completed once the link has been closed.
closeAsync() - Method in interface org.apache.qpid.protonj2.client.Sender
Requests a close of the Sender link at the remote and returns a Future that will be completed once the link has been closed.
closeAsync() - Method in interface org.apache.qpid.protonj2.client.Session
Requests a close of the Session at the remote and returns a Future that will be completed once the session has been remotely closed or an error occurs.
closeAsync(ErrorCondition) - Method in interface org.apache.qpid.protonj2.client.Connection
Requests a close of the Connection at the remote and returns a Future that will be completed once the Connection has been fully closed.
closeAsync(ErrorCondition) - Method in class org.apache.qpid.protonj2.client.impl.ClientConnection
 
closeAsync(ErrorCondition) - Method in class org.apache.qpid.protonj2.client.impl.ClientReceiver
 
closeAsync(ErrorCondition) - Method in class org.apache.qpid.protonj2.client.impl.ClientSession
 
closeAsync(ErrorCondition) - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiver
 
closeAsync(ErrorCondition) - Method in interface org.apache.qpid.protonj2.client.Receiver
Requests a close of the Receiver link at the remote and returns a Future that will be completed once the link has been closed.
closeAsync(ErrorCondition) - Method in interface org.apache.qpid.protonj2.client.Sender
Requests a close of the Sender link at the remote and returns a Future that will be completed once the link has been closed.
closeAsync(ErrorCondition) - Method in interface org.apache.qpid.protonj2.client.Session
Requests a close of the Session at the remote and returns a Future that will be completed once the session has been remotely closed or an error occurs.
closed - Variable in class org.apache.qpid.protonj2.client.transport.TcpTransport
 
CLOSED - org.apache.qpid.protonj2.engine.ConnectionState
Indicates that the targeted end of the Connection (local or remote) has been closed.
CLOSED - org.apache.qpid.protonj2.engine.LinkState
Indicates that the targeted end of the Link (local or remote) has been closed.
CLOSED - org.apache.qpid.protonj2.engine.SessionState
Indicates that the targeted end of the Session (local or remote) has been closed.
closeHandler(EventHandler<E>) - Method in interface org.apache.qpid.protonj2.engine.Endpoint
Sets a EventHandler for when an AMQP Close frame is received from the remote peer.
closeHandler(EventHandler<E>) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEndpoint
 
closeTimeout() - Method in class org.apache.qpid.protonj2.client.ConnectionOptions
 
closeTimeout() - Method in class org.apache.qpid.protonj2.client.ReceiverOptions
 
closeTimeout() - Method in class org.apache.qpid.protonj2.client.SenderOptions
 
closeTimeout() - Method in class org.apache.qpid.protonj2.client.SessionOptions
 
closeTimeout(long) - Method in class org.apache.qpid.protonj2.client.ConnectionOptions
Configures the timeout used when awaiting a response from the remote that a request to close a resource such as a Connection, Session, Sender or Receiver h as been honored.
closeTimeout(long) - Method in class org.apache.qpid.protonj2.client.ReceiverOptions
Configures the timeout used when awaiting a response from the remote that a request to close the Receiver link.
closeTimeout(long) - Method in class org.apache.qpid.protonj2.client.SenderOptions
Configures the timeout used when awaiting a response from the remote that a request to close the Sender link.
closeTimeout(long) - Method in class org.apache.qpid.protonj2.client.SessionOptions
Configures the timeout used when awaiting a response from the remote that a request to close a Session as been honored.
closeTimeout(long) - Method in class org.apache.qpid.protonj2.client.StreamReceiverOptions
 
closeTimeout(long) - Method in class org.apache.qpid.protonj2.client.StreamSenderOptions
 
closeTimeout(long, TimeUnit) - Method in class org.apache.qpid.protonj2.client.ConnectionOptions
Configures the timeout used when awaiting a response from the remote that a request to close a resource such as a Connection, Session, Sender or Receiver h as been honored.
closeTimeout(long, TimeUnit) - Method in class org.apache.qpid.protonj2.client.ReceiverOptions
Configures the timeout used when awaiting a response from the remote that a request to close the Receiver link.
closeTimeout(long, TimeUnit) - Method in class org.apache.qpid.protonj2.client.SenderOptions
Configures the timeout used when awaiting a response from the remote that a request to close the Sender link.
closeTimeout(long, TimeUnit) - Method in class org.apache.qpid.protonj2.client.SessionOptions
Configures the timeout used when awaiting a response from the remote that a request to close a resource such as a Session, Sender or Receiver h as been honored.
closeTimeout(long, TimeUnit) - Method in class org.apache.qpid.protonj2.client.StreamReceiverOptions
 
closeTimeout(long, TimeUnit) - Method in class org.apache.qpid.protonj2.client.StreamSenderOptions
 
CloseTypeDecoder - Class in org.apache.qpid.protonj2.codec.decoders.transport
Decoder of AMQP Close type values from a byte stream
CloseTypeDecoder() - Constructor for class org.apache.qpid.protonj2.codec.decoders.transport.CloseTypeDecoder
 
CloseTypeEncoder - Class in org.apache.qpid.protonj2.codec.encoders.transport
Encoder of AMQP Close type values to a byte stream/
CloseTypeEncoder() - Constructor for class org.apache.qpid.protonj2.codec.encoders.transport.CloseTypeEncoder
 
CodecFactory - Class in org.apache.qpid.protonj2.codec
Factory Class used to create new instances of AMQP type Encoder and Decoder instances registered in the factory.
commit(ClientFuture<Session>, boolean) - Method in interface org.apache.qpid.protonj2.client.impl.ClientTransactionContext
Commits the current transaction if one is active and is not failed into a roll-back only state.
COMMIT - org.apache.qpid.protonj2.engine.Transaction.DischargeState
The transaction has been committed and cannot be rolled back.
commitTransaction() - Method in class org.apache.qpid.protonj2.client.impl.ClientSession
 
commitTransaction() - Method in interface org.apache.qpid.protonj2.client.Session
Commit the currently active transaction in this Session.
comparator() - Method in class org.apache.qpid.protonj2.engine.util.SplayMap
 
compare(byte, byte) - Static method in class org.apache.qpid.protonj2.types.UnsignedByte
Compares two short values numerically treating the values as unsigned.
compare(int, int) - Static method in class org.apache.qpid.protonj2.types.UnsignedInteger
Compares two integer values numerically treating the values as unsigned.
compare(long, long) - Static method in class org.apache.qpid.protonj2.types.UnsignedInteger
Compares two long values numerically treating the values as unsigned.
compare(long, long) - Static method in class org.apache.qpid.protonj2.types.UnsignedLong
Compares two long values numerically treating the values as unsigned.
compare(short, short) - Static method in class org.apache.qpid.protonj2.types.UnsignedShort
Compares two short values numerically treating the values as unsigned.
compareTo(byte) - Method in class org.apache.qpid.protonj2.types.UnsignedByte
Compares the give byte value to this unsigned byte numerically treating the given value as unsigned.
compareTo(int) - Method in class org.apache.qpid.protonj2.engine.util.DeliveryIdTracker
Compares the tracked delivery id value to the int given, if no value is being tracked this method returns -1.
compareTo(int) - Method in class org.apache.qpid.protonj2.engine.util.SequenceNumber
Compares the sequence number value to the primitive Integer given.
compareTo(int) - Method in class org.apache.qpid.protonj2.types.UnsignedInteger
Compares the give integer value to this unsigned integer numerically treating the given value as unsigned.
compareTo(long) - Method in class org.apache.qpid.protonj2.types.UnsignedInteger
Compares the give long value to this unsigned integer numerically treating the given value as unsigned.
compareTo(long) - Method in class org.apache.qpid.protonj2.types.UnsignedLong
Compares the give long value to this UnsignedLong numerically treating the given value as unsigned.
compareTo(short) - Method in class org.apache.qpid.protonj2.types.UnsignedShort
Compares the give short value to this unsigned short numerically treating the given value as unsigned.
compareTo(Number) - Method in class org.apache.qpid.protonj2.engine.util.DeliveryIdTracker
Compares the tracked delivery id value to the Number given, if no value is being tracked this method returns -1.
compareTo(Number) - Method in class org.apache.qpid.protonj2.engine.util.SequenceNumber
Compares the sequence number value to the Number given.
compareTo(ProtonBuffer) - Method in class org.apache.qpid.protonj2.buffer.ProtonAbstractBuffer
 
compareTo(ProtonBuffer) - Method in interface org.apache.qpid.protonj2.buffer.ProtonBuffer
Compares the remaining content of the current buffer with the remaining content of the given buffer, which must not be null.
compareTo(ProtonBuffer) - Method in class org.apache.qpid.protonj2.buffer.ProtonNettyByteBuffer
 
compareTo(DeliveryIdTracker) - Method in class org.apache.qpid.protonj2.engine.util.DeliveryIdTracker
 
compareTo(SequenceNumber) - Method in class org.apache.qpid.protonj2.engine.util.SequenceNumber
 
compareTo(Symbol) - Method in class org.apache.qpid.protonj2.types.Symbol
 
compareTo(UnsignedByte) - Method in class org.apache.qpid.protonj2.types.UnsignedByte
 
compareTo(UnsignedInteger) - Method in class org.apache.qpid.protonj2.types.UnsignedInteger
 
compareTo(UnsignedLong) - Method in class org.apache.qpid.protonj2.types.UnsignedLong
 
compareTo(UnsignedShort) - Method in class org.apache.qpid.protonj2.types.UnsignedShort
 
complete() - Method in interface org.apache.qpid.protonj2.client.StreamSenderMessage
Marks the currently streaming message as being complete.
complete(Void) - Method in class org.apache.qpid.protonj2.client.futures.NoOpAsyncResult
 
complete(V) - Method in interface org.apache.qpid.protonj2.client.futures.AsyncResult
If the operation succeeds the resulting value produced is set to null and the waiting parties are signaled.
complete(V) - Method in class org.apache.qpid.protonj2.client.futures.ClientFuture
 
completed() - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamDelivery
 
completed() - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiverMessage
 
completed() - Method in interface org.apache.qpid.protonj2.client.StreamDelivery
Check if the StreamDelivery has been marked as complete by the remote sender.
completed() - Method in interface org.apache.qpid.protonj2.client.StreamReceiverMessage
Check if the StreamDelivery that was assigned to this StreamReceiverMessage has been marked as complete by the remote.
completed() - Method in interface org.apache.qpid.protonj2.client.StreamSenderMessage
 
completedFuture(T) - Static method in class org.apache.qpid.protonj2.client.futures.ClientFutureFactory
Creates and returns a Future type that is already marked completed and will return the provided result to any caller that requests the future's outcome.
completeSendOnClose() - Method in class org.apache.qpid.protonj2.client.OutputStreamOptions
 
completeSendOnClose(boolean) - Method in class org.apache.qpid.protonj2.client.OutputStreamOptions
Configures if the close of the OutputStream should result in a completion of the parent StreamSenderMessage (default is true).
COMPLETING - Static variable in class org.apache.qpid.protonj2.client.futures.ClientFuture
 
condition() - Method in interface org.apache.qpid.protonj2.client.ErrorCondition
 
condition() - Method in class org.apache.qpid.protonj2.client.impl.ClientErrorCondition
 
configuration() - Method in interface org.apache.qpid.protonj2.engine.Engine
Gets the Configuration for this engine.
configuration() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEngine
 
CONFIGURATION - org.apache.qpid.protonj2.client.DurabilityMode
 
CONFIGURATION - org.apache.qpid.protonj2.types.messaging.TerminusDurability
 
connect(String) - Method in interface org.apache.qpid.protonj2.client.Client
Connect to the specified host, using the default port, without credentials and with all connection options set to their defaults.
connect(String) - Method in class org.apache.qpid.protonj2.client.impl.ClientInstance
 
connect(String, int) - Method in interface org.apache.qpid.protonj2.client.Client
Connect to the specified host and port, without credentials and with all connection options set to their defaults.
connect(String, int) - Method in class org.apache.qpid.protonj2.client.impl.ClientInstance
 
connect(String, int, ConnectionOptions) - Method in interface org.apache.qpid.protonj2.client.Client
Connect to the specified host and port, with given connection options.
connect(String, int, ConnectionOptions) - Method in class org.apache.qpid.protonj2.client.impl.ClientInstance
 
connect(String, int, TransportListener) - Method in class org.apache.qpid.protonj2.client.transport.TcpTransport
 
connect(String, int, TransportListener) - Method in interface org.apache.qpid.protonj2.client.transport.Transport
Performs the connect operation for the implemented Transport type such as a TCP socket connection, SSL/TLS handshake etc.
connect(String, ConnectionOptions) - Method in interface org.apache.qpid.protonj2.client.Client
Connect to the specified host, using the default port, without credentials and with all connection options set to their defaults.
connect(String, ConnectionOptions) - Method in class org.apache.qpid.protonj2.client.impl.ClientInstance
 
connected - Variable in class org.apache.qpid.protonj2.client.transport.TcpTransport
 
connectedHandler() - Method in class org.apache.qpid.protonj2.client.ConnectionOptions
 
connectedHandler(BiConsumer<Connection, ConnectionEvent>) - Method in class org.apache.qpid.protonj2.client.ConnectionOptions
Configures a handler that will be notified when a Connection has established.
connectedLatch - Variable in class org.apache.qpid.protonj2.client.transport.TcpTransport
 
connection - Variable in class org.apache.qpid.protonj2.engine.impl.ProtonLink
 
connection() - Method in class org.apache.qpid.protonj2.client.impl.ClientReceiver
 
connection() - Method in class org.apache.qpid.protonj2.client.impl.ClientSession
 
connection() - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiver
 
connection() - Method in interface org.apache.qpid.protonj2.client.Receiver
 
connection() - Method in interface org.apache.qpid.protonj2.client.Sender
 
connection() - Method in interface org.apache.qpid.protonj2.client.Session
 
connection() - Method in interface org.apache.qpid.protonj2.engine.Engine
Gets the Connection instance that is associated with this Engine instance.
connection() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEngine
 
Connection - Interface in org.apache.qpid.protonj2.client
Top level Connection object that can be used as a stand alone API for sending messages and creating Receiver instances for message consumption.
Connection - Interface in org.apache.qpid.protonj2.engine
AMQP Connection state container
CONNECTION_CLOSE - org.apache.qpid.protonj2.client.ExpiryPolicy
 
CONNECTION_CLOSE - org.apache.qpid.protonj2.types.messaging.TerminusExpiryPolicy
 
CONNECTION_FORCED - Static variable in interface org.apache.qpid.protonj2.types.transport.ConnectionError
An operator intervened to close the connection for some reason.
CONNECTION_OPEN_FAILED - Static variable in class org.apache.qpid.protonj2.client.impl.ClientConstants
 
ConnectionError - Interface in org.apache.qpid.protonj2.types.transport
 
ConnectionEvent - Class in org.apache.qpid.protonj2.client
An event object that accompanies events fired to handlers configured in the ConnectionOptions which are signaled during specific Connection event points.
ConnectionEvent(String, int) - Constructor for class org.apache.qpid.protonj2.client.ConnectionEvent
Creates the event object with all immutable data provided.
ConnectionOptions - Class in org.apache.qpid.protonj2.client
Options that control the behaviour of the Connection created from them.
ConnectionOptions() - Constructor for class org.apache.qpid.protonj2.client.ConnectionOptions
Create a new ConnectionOptions instance configured with default configuration settings.
ConnectionOptions(ConnectionOptions) - Constructor for class org.apache.qpid.protonj2.client.ConnectionOptions
Creates a ConnectionOptions instance that is a copy of the given instance.
ConnectionState - Enum in org.apache.qpid.protonj2.engine
Represents the state of an AMQP Connection.
connectTimeout() - Method in class org.apache.qpid.protonj2.client.TransportOptions
 
connectTimeout(int) - Method in class org.apache.qpid.protonj2.client.TransportOptions
A transport layer connection timeout value that controls how long a connection attempt can block before giving up and throwing a connection error.
CONSERVATIVE - Static variable in class org.apache.qpid.protonj2.client.futures.ClientFutureFactory
Names a future type that uses a conservative wait for the operation outcome.
ConservativeClientFuture<V> - Class in org.apache.qpid.protonj2.client.futures
A more conservative implementation of a ClientFuture that is better on some platforms or resource constrained hardware where high CPU usage can be more counter productive than other variants that might spin or otherwise avoid entry into states requiring thread signaling.
ConservativeClientFuture() - Constructor for class org.apache.qpid.protonj2.client.futures.ConservativeClientFuture
Create a new ConservativeClientFuture instance with no assigned ClientSynchronization.
ConservativeClientFuture(ClientSynchronization<V>) - Constructor for class org.apache.qpid.protonj2.client.futures.ConservativeClientFuture
Create a new ConservativeClientFuture instance with the assigned ClientSynchronization.
CONTAINER_ID - Static variable in class org.apache.qpid.protonj2.client.impl.ClientConstants
 
containerId() - Method in interface org.apache.qpid.protonj2.client.Client
 
containerId() - Method in class org.apache.qpid.protonj2.client.impl.ClientInstance
 
contains(Object) - Method in class org.apache.qpid.protonj2.engine.util.RingQueue
 
containsKey(int) - Method in class org.apache.qpid.protonj2.engine.util.SplayMap
Searches the map using the given primitive integer key value which will be treated internally as an unsigned value when comparing against keys in the mapping.
containsKey(Object) - Method in class org.apache.qpid.protonj2.engine.util.SplayMap
 
containsKey(String) - Method in interface org.apache.qpid.protonj2.engine.Attachments
Checks if the given key has a value mapped to it in this Attachments instance.
containsKey(String) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonAttachments
 
containsValue(Object) - Method in class org.apache.qpid.protonj2.engine.util.SplayMap
 
contentEncoding() - Method in class org.apache.qpid.protonj2.client.impl.ClientMessage
 
contentEncoding() - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiverMessage
 
contentEncoding() - Method in interface org.apache.qpid.protonj2.client.Message
 
contentEncoding(String) - Method in class org.apache.qpid.protonj2.client.impl.ClientMessage
 
contentEncoding(String) - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiverMessage
 
contentEncoding(String) - Method in interface org.apache.qpid.protonj2.client.Message
Sets the contentEncoding value to assign to this Message.
contentType() - Method in class org.apache.qpid.protonj2.client.impl.ClientMessage
 
contentType() - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiverMessage
 
contentType() - Method in interface org.apache.qpid.protonj2.client.Message
 
contentType(String) - Method in class org.apache.qpid.protonj2.client.impl.ClientMessage
 
contentType(String) - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiverMessage
 
contentType(String) - Method in interface org.apache.qpid.protonj2.client.Message
Sets the contentType value to assign to this Message.
contextProtocol() - Method in class org.apache.qpid.protonj2.client.SslOptions
 
contextProtocol(String) - Method in class org.apache.qpid.protonj2.client.SslOptions
The protocol value to use when creating an SSLContext via SSLContext.getInstance(protocol).
convertMessage(Message<E>) - Static method in class org.apache.qpid.protonj2.client.impl.ClientMessageSupport
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.
coordinator(String) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonSession
 
coordinator(String) - Method in interface org.apache.qpid.protonj2.engine.Session
Create a new TransactionController using the provided name.
Coordinator - Class in org.apache.qpid.protonj2.types.transactions
 
Coordinator() - Constructor for class org.apache.qpid.protonj2.types.transactions.Coordinator
 
CoordinatorTypeDecoder - Class in org.apache.qpid.protonj2.codec.decoders.transactions
Decoder of AMQP Coordinator type values from a byte stream.
CoordinatorTypeDecoder() - Constructor for class org.apache.qpid.protonj2.codec.decoders.transactions.CoordinatorTypeDecoder
 
CoordinatorTypeEncoder - Class in org.apache.qpid.protonj2.codec.encoders.transactions
Encoder of AMQP Coordinator type values to a byte stream.
CoordinatorTypeEncoder() - Constructor for class org.apache.qpid.protonj2.codec.encoders.transactions.CoordinatorTypeEncoder
 
copy() - Method in class org.apache.qpid.protonj2.buffer.ProtonAbstractBuffer
 
copy() - Method in interface org.apache.qpid.protonj2.buffer.ProtonBuffer
Create a deep copy of the readable bytes of this ProtonBuffer, the returned buffer can be modified without affecting the contents or position markers of this instance.
copy() - Method in class org.apache.qpid.protonj2.buffer.ProtonNettyByteBuffer
 
copy() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonSequentialTagGenerator.ProtonNumericDeliveryTag
 
copy() - Method in class org.apache.qpid.protonj2.types.Binary
 
copy() - Method in interface org.apache.qpid.protonj2.types.DeliveryTag
Create a copy of this delivery tag, the copy should account for any underlying pooling of tags that the tag source's implementation is using.
copy() - Method in class org.apache.qpid.protonj2.types.DeliveryTag.ProtonDeliveryTag
 
copy() - Method in class org.apache.qpid.protonj2.types.messaging.AmqpSequence
 
copy() - Method in class org.apache.qpid.protonj2.types.messaging.AmqpValue
 
copy() - Method in class org.apache.qpid.protonj2.types.messaging.ApplicationProperties
 
copy() - Method in class org.apache.qpid.protonj2.types.messaging.Data
 
copy() - Method in class org.apache.qpid.protonj2.types.messaging.DeliveryAnnotations
 
copy() - Method in class org.apache.qpid.protonj2.types.messaging.Footer
 
copy() - Method in class org.apache.qpid.protonj2.types.messaging.Header
 
copy() - Method in class org.apache.qpid.protonj2.types.messaging.MessageAnnotations
 
copy() - Method in class org.apache.qpid.protonj2.types.messaging.Properties
 
copy() - Method in class org.apache.qpid.protonj2.types.messaging.Source
 
copy() - Method in class org.apache.qpid.protonj2.types.messaging.Target
 
copy() - Method in interface org.apache.qpid.protonj2.types.messaging.Terminus
 
copy() - Method in class org.apache.qpid.protonj2.types.security.SaslChallenge
 
copy() - Method in class org.apache.qpid.protonj2.types.security.SaslInit
 
copy() - Method in class org.apache.qpid.protonj2.types.security.SaslMechanisms
 
copy() - Method in class org.apache.qpid.protonj2.types.security.SaslOutcome
 
copy() - Method in interface org.apache.qpid.protonj2.types.security.SaslPerformative
 
copy() - Method in class org.apache.qpid.protonj2.types.security.SaslResponse
 
copy() - Method in class org.apache.qpid.protonj2.types.transactions.Coordinator
 
copy() - Method in class org.apache.qpid.protonj2.types.transport.Attach
 
copy() - Method in class org.apache.qpid.protonj2.types.transport.Begin
 
copy() - Method in class org.apache.qpid.protonj2.types.transport.Close
 
copy() - Method in class org.apache.qpid.protonj2.types.transport.Detach
 
copy() - Method in class org.apache.qpid.protonj2.types.transport.Disposition
 
copy() - Method in class org.apache.qpid.protonj2.types.transport.End
 
copy() - Method in class org.apache.qpid.protonj2.types.transport.ErrorCondition
 
copy() - Method in class org.apache.qpid.protonj2.types.transport.Flow
 
copy() - Method in class org.apache.qpid.protonj2.types.transport.Open
 
copy() - Method in interface org.apache.qpid.protonj2.types.transport.Performative
 
copy() - Method in class org.apache.qpid.protonj2.types.transport.Transfer
 
copy(int, int) - Method in class org.apache.qpid.protonj2.buffer.ProtonAbstractBuffer
 
copy(int, int) - Method in interface org.apache.qpid.protonj2.buffer.ProtonBuffer
Returns a copy of this buffer's sub-region.
copy(int, int) - Method in class org.apache.qpid.protonj2.buffer.ProtonByteBuffer
 
copy(int, int) - Method in class org.apache.qpid.protonj2.buffer.ProtonCompositeBuffer
 
copy(int, int) - Method in class org.apache.qpid.protonj2.buffer.ProtonDuplicatedBuffer
 
copy(int, int) - Method in class org.apache.qpid.protonj2.buffer.ProtonNettyByteBuffer
 
copy(int, int) - Method in class org.apache.qpid.protonj2.buffer.ProtonNioByteBuffer
 
copy(int, int) - Method in class org.apache.qpid.protonj2.buffer.ProtonSlicedBuffer
 
COPY - org.apache.qpid.protonj2.client.DistributionMode
 
COPY - Static variable in class org.apache.qpid.protonj2.client.impl.ClientConstants
 
copyInto(ClientOptions) - Method in class org.apache.qpid.protonj2.client.ClientOptions
Copy all options from this ClientOptions instance into the instance provided.
copyInto(ConnectionOptions) - Method in class org.apache.qpid.protonj2.client.ConnectionOptions
Copy all options from this ConnectionOptions instance into the instance provided.
copyInto(OutputStreamOptions) - Method in class org.apache.qpid.protonj2.client.OutputStreamOptions
Copy all options from this OutputStreamOptions instance into the instance provided.
copyInto(ReceiverOptions) - Method in class org.apache.qpid.protonj2.client.ReceiverOptions
Copy all options from this ReceiverOptions instance into the instance provided.
copyInto(ReceiverOptions) - Method in class org.apache.qpid.protonj2.client.StreamReceiverOptions
 
copyInto(ReconnectOptions) - Method in class org.apache.qpid.protonj2.client.ReconnectOptions
Copy all options from this ReconnectOptions instance into the instance provided.
copyInto(SaslOptions) - Method in class org.apache.qpid.protonj2.client.SaslOptions
Copy all configuration into the given SaslOptions from this instance.
copyInto(SenderOptions) - Method in class org.apache.qpid.protonj2.client.SenderOptions
Copy all options from this SenderOptions instance into the instance provided.
copyInto(SessionOptions) - Method in class org.apache.qpid.protonj2.client.SessionOptions
Copy all options from this SessionOptions instance into the instance provided.
copyInto(SourceOptions) - Method in class org.apache.qpid.protonj2.client.SourceOptions
Copy all options from this SourceOptions instance into the instance provided.
copyInto(SslOptions) - Method in class org.apache.qpid.protonj2.client.SslOptions
Copy all configuration into the given SslOptions from this instance.
copyInto(StreamReceiverOptions) - Method in class org.apache.qpid.protonj2.client.StreamReceiverOptions
Copy all options from this StreamReceiverOptions instance into the instance provided.
copyInto(StreamSenderOptions) - Method in class org.apache.qpid.protonj2.client.StreamSenderOptions
Copy all options from this StreamSenderOptions instance into the instance provided.
copyInto(TargetOptions) - Method in class org.apache.qpid.protonj2.client.TargetOptions
 
copyInto(TerminusOptions<E>) - Method in class org.apache.qpid.protonj2.client.TerminusOptions
 
copyInto(TransportOptions) - Method in class org.apache.qpid.protonj2.client.TransportOptions
Copy all configuration into the given TransportOptions from this instance.
correlationId() - Method in class org.apache.qpid.protonj2.client.impl.ClientMessage
 
correlationId() - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiverMessage
 
correlationId() - Method in interface org.apache.qpid.protonj2.client.Message
 
correlationId(Object) - Method in class org.apache.qpid.protonj2.client.impl.ClientMessage
 
correlationId(Object) - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiverMessage
 
correlationId(Object) - Method in interface org.apache.qpid.protonj2.client.Message
Sets the correlationId value to assign to this Message.
CRAM_MD5 - org.apache.qpid.protonj2.engine.sasl.client.SaslMechanisms
 
CRAM_MD5 - Static variable in class org.apache.qpid.protonj2.engine.sasl.client.CramMD5Mechanism
A singleton instance of the symbolic mechanism name.
CramMD5Mechanism - Class in org.apache.qpid.protonj2.engine.sasl.client
Implements the SASL CRAM-MD5 authentication Mechanism.
CramMD5Mechanism() - Constructor for class org.apache.qpid.protonj2.engine.sasl.client.CramMD5Mechanism
 
create() - Static method in interface org.apache.qpid.protonj2.client.AdvancedMessage
Creates a new AdvancedMessage instance using the library default implementation.
create() - Static method in interface org.apache.qpid.protonj2.client.Client
 
create() - Static method in class org.apache.qpid.protonj2.client.impl.ClientInstance
 
create() - Static method in class org.apache.qpid.protonj2.client.impl.ClientMessage
Creates an empty ClientMessage instance.
create() - Static method in interface org.apache.qpid.protonj2.client.Message
Create and return an Message that will carry no body Section unless one is assigned by the caller.
create() - Static method in class org.apache.qpid.protonj2.codec.decoders.ProtonDecoderFactory
 
create() - Static method in class org.apache.qpid.protonj2.codec.decoders.ProtonStreamDecoderFactory
 
create() - Static method in class org.apache.qpid.protonj2.codec.encoders.ProtonEncoderFactory
 
create(byte[]) - Static method in interface org.apache.qpid.protonj2.client.Message
Create and return an Message that will wrap the given byte array in an Data section.
create(E) - Static method in interface org.apache.qpid.protonj2.client.Message
Create and return an Message that will wrap the given Object in an AmqpValue section.
create(String) - Static method in class org.apache.qpid.protonj2.client.futures.ClientFutureFactory
Create a new ClientFutureFactory instance based on the given type name.
create(String, String) - Static method in interface org.apache.qpid.protonj2.client.ErrorCondition
Create an error condition object using the supplied values.
create(String, String, Map<String, Object>) - Static method in interface org.apache.qpid.protonj2.client.ErrorCondition
Create an error condition object using the supplied values.
create(Throwable) - Static method in class org.apache.qpid.protonj2.client.util.IOExceptionSupport
Checks the given cause to determine if it's already an IOException type and if not creates a new IOException to wrap it.
create(List<E>) - Static method in interface org.apache.qpid.protonj2.client.Message
Create and return an Message that will wrap the given List in an AmqpSequence section.
create(Map<K, V>) - Static method in interface org.apache.qpid.protonj2.client.Message
Create and return an Message that will wrap the given Map in an AmqpValue section.
create(ClientOptions) - Static method in interface org.apache.qpid.protonj2.client.Client
Create a new Client instance using provided configuration options.
create(ClientOptions) - Static method in class org.apache.qpid.protonj2.client.impl.ClientInstance
 
create(Section<V>) - Static method in class org.apache.qpid.protonj2.client.impl.ClientMessage
Creates an ClientMessage instance with the given body Section value.
createAdvancedMessage() - Static method in class org.apache.qpid.protonj2.client.impl.ClientMessage
Creates an empty ClientMessage instance.
createChannelHandler() - Method in class org.apache.qpid.protonj2.client.transport.TcpTransport
 
createChannelHandler() - Method in class org.apache.qpid.protonj2.client.transport.WebSocketTransport
 
createEngine() - Method in interface org.apache.qpid.protonj2.engine.EngineFactory
Create a new Engine instance with a SASL authentication layer added.
createEngine() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEngineFactory
 
createFailedException(String, Throwable) - Static method in class org.apache.qpid.protonj2.engine.exceptions.ProtonExceptionSupport
Creates a new instance of an EngineFailedException that either wraps the given cause if it is not an instance of an EngineFailedException or creates a new copy of the given EngineFailedException in order to produce a meaningful stack trace for the caller of which of their calls failed due to the engine state being failed.
createFailedException(Throwable) - Static method in class org.apache.qpid.protonj2.engine.exceptions.ProtonExceptionSupport
Checks the given cause to determine if it's already an ProtonException type and if not creates a new ProtonException to wrap it.
createFuture() - Method in class org.apache.qpid.protonj2.client.futures.ClientFutureFactory
 
createFuture(ClientSynchronization<V>) - Method in class org.apache.qpid.protonj2.client.futures.ClientFutureFactory
 
createGenerator() - Method in enum org.apache.qpid.protonj2.engine.impl.ProtonDeliveryTagGenerator.BUILTIN
 
createGroup(int, ThreadFactory) - Static method in class org.apache.qpid.protonj2.client.transport.EpollSupport
 
createGroup(int, ThreadFactory) - Static method in class org.apache.qpid.protonj2.client.transport.IOUringSupport
 
createGroup(int, ThreadFactory) - Static method in class org.apache.qpid.protonj2.client.transport.KQueueSupport
 
createJdkSslContext(SslOptions) - Static method in class org.apache.qpid.protonj2.client.transport.SslSupport
Create a new SSLContext using the options specific in the given TransportOptions instance.
createJdkSslEngine(String, int, SSLContext, SslOptions) - Static method in class org.apache.qpid.protonj2.client.transport.SslSupport
Create a new JDK SSLEngine instance in client mode from the given SSLContext and TransportOptions instances.
createLoggerWrapper(String) - Method in class org.apache.qpid.protonj2.logging.NoOpProtonLoggerFactory
 
createLoggerWrapper(String) - Method in class org.apache.qpid.protonj2.logging.ProtonLoggerFactory
 
createLoggerWrapper(String) - Method in class org.apache.qpid.protonj2.logging.Slf4JLoggerFactory
 
createMechanism() - Method in enum org.apache.qpid.protonj2.engine.sasl.client.SaslMechanisms
Creates the object that implements the SASL Mechanism represented by this enumeration.
createMechanism(Symbol, SaslCredentialsProvider) - Method in class org.apache.qpid.protonj2.engine.sasl.client.SaslMechanismSelector
Using the given Mechanism name and the provided credentials create and configure a Mechanism for evaluation by the selector.
createNonSaslEngine() - Method in interface org.apache.qpid.protonj2.engine.EngineFactory
Create a new Engine instance that handles only raw AMQP with no SASL layer enabled.
createNonSaslEngine() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEngineFactory
 
createNoOpTracker() - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamSender
 
createOpenSslContext(SslOptions) - Static method in class org.apache.qpid.protonj2.client.transport.SslSupport
Create a new Netty SslContext using the options specific in the given TransportOptions instance.
createOpenSslEngine(ByteBufAllocator, String, int, SslContext, SslOptions) - Static method in class org.apache.qpid.protonj2.client.transport.SslSupport
Create a new OpenSSL SSLEngine instance in client mode from the given SSLContext and TransportOptions instances.
createSasl() - Static method in class org.apache.qpid.protonj2.codec.decoders.ProtonDecoderFactory
 
createSasl() - Static method in class org.apache.qpid.protonj2.codec.decoders.ProtonStreamDecoderFactory
 
createSasl() - Static method in class org.apache.qpid.protonj2.codec.encoders.ProtonEncoderFactory
 
createSectionFromValue(E) - Static method in class org.apache.qpid.protonj2.client.impl.ClientMessageSupport
 
createSendTimedOutException() - Method in class org.apache.qpid.protonj2.client.impl.ClientOutgoingEnvelope
 
createSslHandler(ByteBufAllocator, String, int, SslOptions) - Static method in class org.apache.qpid.protonj2.client.transport.SslSupport
Creates a Netty SslHandler instance for use in Transports that require an SSL encoder / decoder.
createTracker(OutgoingDelivery) - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamSender
 
createUnfailableFuture() - Method in class org.apache.qpid.protonj2.client.futures.ClientFutureFactory
 
createUnfailableFuture(ClientSynchronization<V>) - Method in class org.apache.qpid.protonj2.client.futures.ClientFutureFactory
 
creationTime() - Method in class org.apache.qpid.protonj2.client.impl.ClientMessage
 
creationTime() - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiverMessage
 
creationTime() - Method in interface org.apache.qpid.protonj2.client.Message
 
creationTime(long) - Method in class org.apache.qpid.protonj2.client.impl.ClientMessage
 
creationTime(long) - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiverMessage
 
creationTime(long) - Method in interface org.apache.qpid.protonj2.client.Message
Sets the creation time value to assign to this Message.
creditStateUpdateHandler(EventHandler<L>) - Method in interface org.apache.qpid.protonj2.engine.Link
Handler for link credit updates that occur after a remote Flow arrives.
creditStateUpdateHandler(EventHandler<Receiver>) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonReceiver
 
creditStateUpdateHandler(EventHandler<Sender>) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonSender
 
creditWindow() - Method in class org.apache.qpid.protonj2.client.ReceiverOptions
 
creditWindow(int) - Method in class org.apache.qpid.protonj2.client.ReceiverOptions
A credit window value that will be used to maintain an window of credit for Receiver instances that are created.
creditWindow(int) - Method in class org.apache.qpid.protonj2.client.StreamReceiverOptions
 
current() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonSender
 
current() - Method in interface org.apache.qpid.protonj2.engine.Sender
Gets the current OutgoingDelivery for this Sender if one is available.

D

Data - Class in org.apache.qpid.protonj2.types.messaging
 
Data - org.apache.qpid.protonj2.types.messaging.Section.SectionType
 
Data(byte[]) - Constructor for class org.apache.qpid.protonj2.types.messaging.Data
 
Data(byte[], int, int) - Constructor for class org.apache.qpid.protonj2.types.messaging.Data
 
Data(ProtonBuffer) - Constructor for class org.apache.qpid.protonj2.types.messaging.Data
 
Data(Binary) - Constructor for class org.apache.qpid.protonj2.types.messaging.Data
 
DataTypeDecoder - Class in org.apache.qpid.protonj2.codec.decoders.messaging
Decoder of AMQP Data type values from a byte stream.
DataTypeDecoder() - Constructor for class org.apache.qpid.protonj2.codec.decoders.messaging.DataTypeDecoder
 
DataTypeEncoder - Class in org.apache.qpid.protonj2.codec.encoders.messaging
Encoder of AMQP Data type values to a byte stream.
DataTypeEncoder() - Constructor for class org.apache.qpid.protonj2.codec.encoders.messaging.DataTypeEncoder
 
debug(String) - Method in class org.apache.qpid.protonj2.logging.NoOpProtonLogger
 
debug(String) - Method in interface org.apache.qpid.protonj2.logging.ProtonLogger
 
debug(String) - Method in class org.apache.qpid.protonj2.logging.Slf4JLoggerWrapper
 
debug(String, Object) - Method in class org.apache.qpid.protonj2.logging.NoOpProtonLogger
 
debug(String, Object) - Method in interface org.apache.qpid.protonj2.logging.ProtonLogger
 
debug(String, Object) - Method in class org.apache.qpid.protonj2.logging.Slf4JLoggerWrapper
 
debug(String, Object...) - Method in class org.apache.qpid.protonj2.logging.NoOpProtonLogger
 
debug(String, Object...) - Method in interface org.apache.qpid.protonj2.logging.ProtonLogger
 
debug(String, Object...) - Method in class org.apache.qpid.protonj2.logging.Slf4JLoggerWrapper
 
debug(String, Object, Object) - Method in class org.apache.qpid.protonj2.logging.NoOpProtonLogger
 
debug(String, Object, Object) - Method in interface org.apache.qpid.protonj2.logging.ProtonLogger
 
debug(String, Object, Object) - Method in class org.apache.qpid.protonj2.logging.Slf4JLoggerWrapper
 
Decimal128 - Class in org.apache.qpid.protonj2.types
 
Decimal128(byte[]) - Constructor for class org.apache.qpid.protonj2.types.Decimal128
 
Decimal128(long, long) - Constructor for class org.apache.qpid.protonj2.types.Decimal128
 
Decimal128(BigDecimal) - Constructor for class org.apache.qpid.protonj2.types.Decimal128
 
DECIMAL128 - Static variable in interface org.apache.qpid.protonj2.codec.EncodingCodes
 
Decimal128TypeDecoder - Class in org.apache.qpid.protonj2.codec.decoders.primitives
Decoder of AMQP Decimal128 values from a byte stream
Decimal128TypeDecoder() - Constructor for class org.apache.qpid.protonj2.codec.decoders.primitives.Decimal128TypeDecoder
 
Decimal128TypeEncoder - Class in org.apache.qpid.protonj2.codec.encoders.primitives
Encoder of AMQP Decimal128 type values to a byte stream
Decimal128TypeEncoder() - Constructor for class org.apache.qpid.protonj2.codec.encoders.primitives.Decimal128TypeEncoder
 
Decimal32 - Class in org.apache.qpid.protonj2.types
 
Decimal32(int) - Constructor for class org.apache.qpid.protonj2.types.Decimal32
 
Decimal32(BigDecimal) - Constructor for class org.apache.qpid.protonj2.types.Decimal32
 
DECIMAL32 - Static variable in interface org.apache.qpid.protonj2.codec.EncodingCodes
 
Decimal32TypeDecoder - Class in org.apache.qpid.protonj2.codec.decoders.primitives
Decoder of AMQP Decimal32 values from a byte stream
Decimal32TypeDecoder() - Constructor for class org.apache.qpid.protonj2.codec.decoders.primitives.Decimal32TypeDecoder
 
Decimal32TypeEncoder - Class in org.apache.qpid.protonj2.codec.encoders.primitives
Encoder of AMQP Decimal32 type values to a byte stream
Decimal32TypeEncoder() - Constructor for class org.apache.qpid.protonj2.codec.encoders.primitives.Decimal32TypeEncoder
 
Decimal64 - Class in org.apache.qpid.protonj2.types
 
Decimal64(long) - Constructor for class org.apache.qpid.protonj2.types.Decimal64
 
Decimal64(BigDecimal) - Constructor for class org.apache.qpid.protonj2.types.Decimal64
 
DECIMAL64 - Static variable in interface org.apache.qpid.protonj2.codec.EncodingCodes
 
Decimal64TypeDecoder - Class in org.apache.qpid.protonj2.codec.decoders.primitives
Decoder of AMQP Decimal64 values from a byte stream
Decimal64TypeDecoder() - Constructor for class org.apache.qpid.protonj2.codec.decoders.primitives.Decimal64TypeDecoder
 
Decimal64TypeEncoder - Class in org.apache.qpid.protonj2.codec.encoders.primitives
Encoder of AMQP Decimal64 type values to a byte stream
Decimal64TypeEncoder() - Constructor for class org.apache.qpid.protonj2.codec.encoders.primitives.Decimal64TypeEncoder
 
declare() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonTransactionController
 
declare() - Method in interface org.apache.qpid.protonj2.engine.TransactionController
Request that the remote TransactionManager declare a new transaction and respond with a new transaction Id for that transaction.
declare(Transaction<TransactionController>) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonTransactionController
 
declare(Transaction<TransactionController>) - Method in interface org.apache.qpid.protonj2.engine.TransactionController
Request that the remote TransactionManager declare a new transaction and respond with a new transaction Id for that transaction.
Declare - Class in org.apache.qpid.protonj2.types.transactions
 
Declare() - Constructor for class org.apache.qpid.protonj2.types.transactions.Declare
 
DECLARE_FAILED - org.apache.qpid.protonj2.engine.TransactionState
A Transaction is considered failed in the TransactionManager responds with an error to the Declare action.
declared(Transaction<TransactionManager>, byte[]) - Method in interface org.apache.qpid.protonj2.engine.TransactionManager
Respond to a previous Declare request from the remote TransactionController indicating that the requested transaction has been successfully declared and that deliveries can now be enlisted in that transaction.
declared(Transaction<TransactionManager>, Binary) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonTransactionManager
 
declared(Transaction<TransactionManager>, Binary) - Method in interface org.apache.qpid.protonj2.engine.TransactionManager
Respond to a previous Declare request from the remote TransactionController indicating that the requested transaction has been successfully declared and that deliveries can now be enlisted in that transaction.
Declared - Class in org.apache.qpid.protonj2.types.transactions
 
Declared - org.apache.qpid.protonj2.types.transport.DeliveryState.DeliveryStateType
 
Declared() - Constructor for class org.apache.qpid.protonj2.types.transactions.Declared
 
DECLARED - org.apache.qpid.protonj2.engine.TransactionState
A Transaction is considered declared once the TransactionManager has responded in the affirmative and assigned a transaction Id.
declaredHandler(EventHandler<Transaction<TransactionController>>) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonTransactionController
 
declaredHandler(EventHandler<Transaction<TransactionController>>) - Method in interface org.apache.qpid.protonj2.engine.TransactionController
Called when the TransactionManager end of the link has responded to a previous Declare request and the transaction can now be used to enroll deliveries into the active transaction.
DeclaredTypeDecoder - Class in org.apache.qpid.protonj2.codec.decoders.transactions
Decoder of AMQP Declared types from a byte stream.
DeclaredTypeDecoder() - Constructor for class org.apache.qpid.protonj2.codec.decoders.transactions.DeclaredTypeDecoder
 
DeclaredTypeEncoder - Class in org.apache.qpid.protonj2.codec.encoders.transactions
Encoder of AMQP Declared type values to a byte stream.
DeclaredTypeEncoder() - Constructor for class org.apache.qpid.protonj2.codec.encoders.transactions.DeclaredTypeEncoder
 
declareFailed(Transaction<TransactionManager>, ErrorCondition) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonTransactionManager
 
declareFailed(Transaction<TransactionManager>, ErrorCondition) - Method in interface org.apache.qpid.protonj2.engine.TransactionManager
Respond to a previous Declare request from the remote TransactionController indicating that the requested transaction declaration has failed and is not active.
declareFailureHandler(EventHandler<Transaction<TransactionController>>) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonTransactionController
 
declareFailureHandler(EventHandler<Transaction<TransactionController>>) - Method in interface org.apache.qpid.protonj2.engine.TransactionController
Called when the TransactionManager end of the link responds to a Transaction declaration with an Rejected outcome indicating that the transaction could not be successfully declared.
declareHandler(EventHandler<Transaction<TransactionManager>>) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonTransactionManager
 
declareHandler(EventHandler<Transaction<TransactionManager>>) - Method in interface org.apache.qpid.protonj2.engine.TransactionManager
Called when the TransactionController end of the link has requested a new transaction be declared using the information provided in the given Declare instance.
DeclareTypeDecoder - Class in org.apache.qpid.protonj2.codec.decoders.transactions
Decoder of AMQP Declare type values from a byte stream
DeclareTypeDecoder() - Constructor for class org.apache.qpid.protonj2.codec.decoders.transactions.DeclareTypeDecoder
 
DeclareTypeEncoder - Class in org.apache.qpid.protonj2.codec.encoders.transactions
Encoder of AMQP Declare type values to a byte stream.
DeclareTypeEncoder() - Constructor for class org.apache.qpid.protonj2.codec.encoders.transactions.DeclareTypeEncoder
 
DECLARING - org.apache.qpid.protonj2.engine.TransactionState
A Transaction is considered declaring once a Declare command has been sent to the remote but before any response has been received which assigns the transaction ID.
DECODE_ERROR - Static variable in interface org.apache.qpid.protonj2.types.transport.AmqpError
Data could not be decoded.
DecodeEOFException - Exception in org.apache.qpid.protonj2.codec
Exception thrown when a type decoder fails due to some unrecoverable error or violation of AMQP type specifications for an incoming encoded byte sequence.
DecodeEOFException() - Constructor for exception org.apache.qpid.protonj2.codec.DecodeEOFException
Creates a generic DecodeEOFException with no cause or error description set.
DecodeEOFException(String) - Constructor for exception org.apache.qpid.protonj2.codec.DecodeEOFException
Creates a DecodeEOFException with the given error message.
DecodeEOFException(String, Throwable) - Constructor for exception org.apache.qpid.protonj2.codec.DecodeEOFException
Creates a DecodeEOFException with the given error message and assigned root cause exception.
DecodeEOFException(Throwable) - Constructor for exception org.apache.qpid.protonj2.codec.DecodeEOFException
Creates a DecodeEOFException with the given assigned root cause exception.
DecodeException - Exception in org.apache.qpid.protonj2.codec
Exception thrown when a type decoder fails due to some unrecoverable error or violation of AMQP type specifications for an incoming encoded byte sequence.
DecodeException() - Constructor for exception org.apache.qpid.protonj2.codec.DecodeException
Creates a generic DecodeException with no cause or error description set.
DecodeException(String) - Constructor for exception org.apache.qpid.protonj2.codec.DecodeException
Creates a DecodeException with the given error message.
DecodeException(String, Throwable) - Constructor for exception org.apache.qpid.protonj2.codec.DecodeException
Creates a DecodeException with the given error message and assigned root cause exception.
DecodeException(Throwable) - Constructor for exception org.apache.qpid.protonj2.codec.DecodeException
Creates a DecodeException with the given assigned root cause exception.
decodeMessage(ProtonBuffer, Consumer<DeliveryAnnotations>) - Static method in class org.apache.qpid.protonj2.client.impl.ClientMessageSupport
 
decodeMessage(Decoder, ProtonBuffer, Consumer<DeliveryAnnotations>) - Static method in class org.apache.qpid.protonj2.client.impl.ClientMessageSupport
 
decodeMessage(Decoder, DecoderState, ProtonBuffer, Consumer<DeliveryAnnotations>) - Static method in class org.apache.qpid.protonj2.client.impl.ClientMessageSupport
 
Decoder - Interface in org.apache.qpid.protonj2.codec
Decode AMQP types from a byte stream
DecoderState - Interface in org.apache.qpid.protonj2.codec
Retains state of decode either between calls or across decode iterations
decodeUTF8(InputStream) - Method in interface org.apache.qpid.protonj2.codec.decoders.UTF8StreamDecoder
Decodes a String from the given UTF8 Bytes.
decodeUTF8(InputStream, int) - Method in class org.apache.qpid.protonj2.codec.decoders.ProtonStreamDecoderState
 
decodeUTF8(InputStream, int) - Method in interface org.apache.qpid.protonj2.codec.StreamDecoderState
Given a stream that will provide UTF-8 encoded bytes, decode and return the String that represents that UTF-8 value.
decodeUTF8(ProtonBuffer, int) - Method in class org.apache.qpid.protonj2.codec.decoders.ProtonDecoderState
 
decodeUTF8(ProtonBuffer, int) - Method in interface org.apache.qpid.protonj2.codec.decoders.UTF8Decoder
Decodes a String from the given UTF8 Bytes advancing the buffer read index by the given length value once complete.
decodeUTF8(ProtonBuffer, int) - Method in interface org.apache.qpid.protonj2.codec.DecoderState
Given a set of UTF-8 encoded bytes decode and return the String that represents that UTF-8 value.
decorateOutgoingFlow(Flow) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonLink
 
decorateOutgoingFlow(Flow) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonReceiver
 
decorateOutgoingFlow(Flow) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonSender
 
decrement() - Method in class org.apache.qpid.protonj2.engine.util.SequenceNumber
Subtract one to the sequence value.
DEFAULT - Static variable in class org.apache.qpid.protonj2.buffer.ProtonByteBufferAllocator
Default ProtonByteBufferAllocator instance that uses defaults for all configuration when creating new ProtonByteBuffer instances.
DEFAULT - Static variable in class org.apache.qpid.protonj2.buffer.ProtonNettyByteBufferAllocator
A default instance of the ProtonNettyByteBufferAllocator that uses default configurations.
DEFAULT_ALLOW_NATIVE_IO - Static variable in class org.apache.qpid.protonj2.client.TransportOptions
 
DEFAULT_ALLOW_NATIVE_SSL - Static variable in class org.apache.qpid.protonj2.client.SslOptions
 
DEFAULT_CAPACITY - Static variable in class org.apache.qpid.protonj2.buffer.ProtonByteBuffer
The default initial capacity used for the underlying byte array.
DEFAULT_CHANNEL_MAX - Static variable in class org.apache.qpid.protonj2.client.ConnectionOptions
 
DEFAULT_CLOSE_TIMEOUT - Static variable in class org.apache.qpid.protonj2.client.ConnectionOptions
 
DEFAULT_COMPLETE_SEND_ON_CLOSE - Static variable in class org.apache.qpid.protonj2.client.OutputStreamOptions
Defines the default value for the complete parent StreamSenderMessage on close option
DEFAULT_CONNECT_TIMEOUT - Static variable in class org.apache.qpid.protonj2.client.TransportOptions
 
DEFAULT_CONTEXT_PROTOCOL - Static variable in class org.apache.qpid.protonj2.client.SslOptions
 
DEFAULT_DELIVERY_COUNT - Static variable in class org.apache.qpid.protonj2.types.messaging.Header
 
DEFAULT_DESIRED_CAPABILITIES - Static variable in class org.apache.qpid.protonj2.client.ConnectionOptions
 
DEFAULT_DISABLED_PROTOCOLS - Static variable in class org.apache.qpid.protonj2.client.SslOptions
 
DEFAULT_DRAIN_TIMEOUT - Static variable in class org.apache.qpid.protonj2.client.ConnectionOptions
 
DEFAULT_DURABILITY - Static variable in class org.apache.qpid.protonj2.types.messaging.Header
 
DEFAULT_FIRST_ACQUIRER - Static variable in class org.apache.qpid.protonj2.types.messaging.Header
 
DEFAULT_IDLE_TIMEOUT - Static variable in class org.apache.qpid.protonj2.client.ConnectionOptions
 
DEFAULT_LOCAL_PORT - Static variable in class org.apache.qpid.protonj2.client.TransportOptions
 
DEFAULT_MAX_AMQP_FRAME_SIZE - Static variable in class org.apache.qpid.protonj2.engine.impl.ProtonConstants
The default AMQP max frame size used by the engine and connection if none is set by the client or remote peer.
DEFAULT_MAX_FRAME_SIZE - Static variable in class org.apache.qpid.protonj2.client.ConnectionOptions
 
DEFAULT_MAX_NUM_POOLED_TAGS - Static variable in class org.apache.qpid.protonj2.engine.impl.ProtonPooledTagGenerator
The default number of pooled transfer tags for this generator.
DEFAULT_MAX_POOL_SIZE - Static variable in class org.apache.qpid.protonj2.engine.AMQPPerformativeEnvelopePool
The default maximum pool size to use if not otherwise configured.
DEFAULT_MAX_RECONNECT_DELAY - Static variable in class org.apache.qpid.protonj2.client.ReconnectOptions
 
DEFAULT_MAXIMUM_CAPACITY - Static variable in class org.apache.qpid.protonj2.buffer.ProtonByteBuffer
The default maximum capacity that this buffer can grow to.
DEFAULT_MAXIMUM_CAPACITY - Static variable in class org.apache.qpid.protonj2.buffer.ProtonCompositeBuffer
The default maximum capacity for a composite ProtonBuffer.
DEFAULT_NATIVEIO_PREFERENCES - Static variable in class org.apache.qpid.protonj2.client.TransportOptions
 
DEFAULT_OPEN_TIMEOUT - Static variable in class org.apache.qpid.protonj2.client.ConnectionOptions
 
DEFAULT_PENDING_WRITES_BUFFER_SIZE - Static variable in class org.apache.qpid.protonj2.client.StreamSenderOptions
Defines the default pending write buffering size which is used to control how much outgoing data can be buffered for local writing before the sender has back pressured applied to avoid out of memory conditions due to overly large pending batched writes.
DEFAULT_PREFIX - Static variable in class org.apache.qpid.protonj2.client.util.IdGenerator
The default Id prefix applied to all new Id values rendered from an IdGenerator.
DEFAULT_PRIORITY - Static variable in class org.apache.qpid.protonj2.types.messaging.Header
 
DEFAULT_READ_BUFFER_SIZE - Static variable in class org.apache.qpid.protonj2.client.StreamReceiverOptions
Defines the default read buffering size which is used to control how much incoming data can be buffered before the remote has back pressured applied to avoid out of memory conditions.
DEFAULT_RECEIVE_BUFFER_SIZE - Static variable in class org.apache.qpid.protonj2.client.TransportOptions
 
DEFAULT_RECEIVER_OUTCOME - Static variable in class org.apache.qpid.protonj2.client.SourceOptions
The default AMQP Outcome that will be specified for all new Receiver instances.
DEFAULT_RECONNECT_BACKOFF_MULTIPLIER - Static variable in class org.apache.qpid.protonj2.client.ReconnectOptions
 
DEFAULT_RECONNECT_DELAY - Static variable in class org.apache.qpid.protonj2.client.ReconnectOptions
 
DEFAULT_RECONNECT_ENABLED - Static variable in class org.apache.qpid.protonj2.client.ReconnectOptions
 
DEFAULT_REQUEST_TIMEOUT - Static variable in class org.apache.qpid.protonj2.client.ConnectionOptions
 
DEFAULT_SASL_ENABLED - Static variable in class org.apache.qpid.protonj2.client.SaslOptions
The client default configuration value for SASL enabled state (default is true)
DEFAULT_SEND_BUFFER_SIZE - Static variable in class org.apache.qpid.protonj2.client.TransportOptions
 
DEFAULT_SEND_TIMEOUT - Static variable in class org.apache.qpid.protonj2.client.ConnectionOptions
 
DEFAULT_SESSION_INCOMING_CAPACITY - Static variable in class org.apache.qpid.protonj2.client.SessionOptions
The default Session configured incoming capacity limit to provide to the remote
DEFAULT_SESSION_OUTGOING_CAPACITY - Static variable in class org.apache.qpid.protonj2.client.SessionOptions
The default Session configured outgoing capacity to apply to local pending writes.
DEFAULT_SHUTDOWN_AWAIT_TERMINATION - Static variable in class org.apache.qpid.protonj2.client.util.ThreadPoolUtils
Default thread pool shutdown timeout used to await graceful shutdown.
DEFAULT_SO_LINGER - Static variable in class org.apache.qpid.protonj2.client.TransportOptions
 
DEFAULT_SO_TIMEOUT - Static variable in class org.apache.qpid.protonj2.client.TransportOptions
 
DEFAULT_SSL_PORT - Static variable in class org.apache.qpid.protonj2.client.SslOptions
 
DEFAULT_STORE_TYPE - Static variable in class org.apache.qpid.protonj2.client.SslOptions
 
DEFAULT_TCP_KEEP_ALIVE - Static variable in class org.apache.qpid.protonj2.client.TransportOptions
 
DEFAULT_TCP_NO_DELAY - Static variable in class org.apache.qpid.protonj2.client.TransportOptions
 
DEFAULT_TCP_PORT - Static variable in class org.apache.qpid.protonj2.client.TransportOptions
 
DEFAULT_TIME_TO_LIVE - Static variable in class org.apache.qpid.protonj2.types.messaging.Header
 
DEFAULT_TRACE_BYTES - Static variable in class org.apache.qpid.protonj2.client.TransportOptions
 
DEFAULT_TRAFFIC_CLASS - Static variable in class org.apache.qpid.protonj2.client.TransportOptions
 
DEFAULT_TRUST_ALL - Static variable in class org.apache.qpid.protonj2.client.SslOptions
 
DEFAULT_USE_RECONNECT_BACKOFF - Static variable in class org.apache.qpid.protonj2.client.ReconnectOptions
 
DEFAULT_USE_WEBSOCKETS - Static variable in class org.apache.qpid.protonj2.client.TransportOptions
 
DEFAULT_VERIFY_HOST - Static variable in class org.apache.qpid.protonj2.client.SslOptions
 
DEFAULT_WARN_AFTER_RECONNECT_ATTEMPTS - Static variable in class org.apache.qpid.protonj2.client.ReconnectOptions
 
DEFAULT_WEBSOCKET_MAX_FRAME_SIZE - Static variable in class org.apache.qpid.protonj2.client.TransportOptions
 
defaultOutcome() - Method in interface org.apache.qpid.protonj2.client.Source
 
defaultOutcome() - Method in class org.apache.qpid.protonj2.client.SourceOptions
 
defaultOutcome(DeliveryState) - Method in class org.apache.qpid.protonj2.client.SourceOptions
 
defaultSender() - Method in interface org.apache.qpid.protonj2.client.Connection
Returns the default anonymous sender used by this Connection for Connection.send(Message) calls.
defaultSender() - Method in class org.apache.qpid.protonj2.client.impl.ClientConnection
 
defaultSession() - Method in interface org.apache.qpid.protonj2.client.Connection
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.
defaultSession() - Method in class org.apache.qpid.protonj2.client.impl.ClientConnection
 
defaultSslPort() - Method in class org.apache.qpid.protonj2.client.SslOptions
 
defaultSslPort(int) - Method in class org.apache.qpid.protonj2.client.SslOptions
Sets the default AMQP SSL port that should be used if the user did not provide a port value.
defaultTcpPort() - Method in class org.apache.qpid.protonj2.client.TransportOptions
 
defaultTcpPort(int) - Method in class org.apache.qpid.protonj2.client.TransportOptions
The default unsecured connection port to use when none has been specified by the user.
DELAYED_DELIVERY - Static variable in class org.apache.qpid.protonj2.client.impl.ClientConstants
 
delete(SplayMap.SplayedEntry<E>) - Method in class org.apache.qpid.protonj2.engine.util.SplayMap
 
DeleteOnClose - Class in org.apache.qpid.protonj2.types.messaging
 
DeleteOnCloseTypeDecoder - Class in org.apache.qpid.protonj2.codec.decoders.messaging
Decoder of AMQP DeleteOnClose type values from a byte stream
DeleteOnCloseTypeDecoder() - Constructor for class org.apache.qpid.protonj2.codec.decoders.messaging.DeleteOnCloseTypeDecoder
 
DeleteOnCloseTypeEncoder - Class in org.apache.qpid.protonj2.codec.encoders.messaging
Encoder of AMQP DeleteOnClose type values to a byte stream.
DeleteOnCloseTypeEncoder() - Constructor for class org.apache.qpid.protonj2.codec.encoders.messaging.DeleteOnCloseTypeEncoder
 
DeleteOnNoLinks - Class in org.apache.qpid.protonj2.types.messaging
 
DeleteOnNoLinksOrMessages - Class in org.apache.qpid.protonj2.types.messaging
 
DeleteOnNoLinksOrMessagesTypeDecoder - Class in org.apache.qpid.protonj2.codec.decoders.messaging
Decoder of AMQP DeleteOnNoLinksOrMessages type values from a byte stream
DeleteOnNoLinksOrMessagesTypeDecoder() - Constructor for class org.apache.qpid.protonj2.codec.decoders.messaging.DeleteOnNoLinksOrMessagesTypeDecoder
 
DeleteOnNoLinksOrMessagesTypeEncoder - Class in org.apache.qpid.protonj2.codec.encoders.messaging
Encoder of AMQP DeleteOnNoLinksOrMessages type values to a byte stream
DeleteOnNoLinksOrMessagesTypeEncoder() - Constructor for class org.apache.qpid.protonj2.codec.encoders.messaging.DeleteOnNoLinksOrMessagesTypeEncoder
 
DeleteOnNoLinksTypeDecoder - Class in org.apache.qpid.protonj2.codec.decoders.messaging
Decoder of AMQP DeleteOnNoLinks type values from a byte stream
DeleteOnNoLinksTypeDecoder() - Constructor for class org.apache.qpid.protonj2.codec.decoders.messaging.DeleteOnNoLinksTypeDecoder
 
DeleteOnNoLinksTypeEncoder - Class in org.apache.qpid.protonj2.codec.encoders.messaging
Encoder of AMQP DeleteOnNoLinks type values to a byte stream
DeleteOnNoLinksTypeEncoder() - Constructor for class org.apache.qpid.protonj2.codec.encoders.messaging.DeleteOnNoLinksTypeEncoder
 
DeleteOnNoMessages - Class in org.apache.qpid.protonj2.types.messaging
 
DeleteOnNoMessagesTypeDecoder - Class in org.apache.qpid.protonj2.codec.decoders.messaging
Decoder of AMQP DeleteOnNoLinks type values from a byte stream
DeleteOnNoMessagesTypeDecoder() - Constructor for class org.apache.qpid.protonj2.codec.decoders.messaging.DeleteOnNoMessagesTypeDecoder
 
DeleteOnNoMessagesTypeEncoder - Class in org.apache.qpid.protonj2.codec.encoders.messaging
Encoder of AMQP DeleteOnNoMessages type values to a byte stream
DeleteOnNoMessagesTypeEncoder() - Constructor for class org.apache.qpid.protonj2.codec.encoders.messaging.DeleteOnNoMessagesTypeEncoder
 
delivery() - Method in class org.apache.qpid.protonj2.client.impl.ClientOutgoingEnvelope
 
delivery() - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiverMessage
 
delivery() - Method in interface org.apache.qpid.protonj2.client.StreamReceiverMessage
 
Delivery - Interface in org.apache.qpid.protonj2.client
Incoming Delivery type that provides access to the message and the delivery data along with methods for settling the delivery when processing completes.
deliveryAbortedHandler(EventHandler<IncomingDelivery>) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonIncomingDelivery
 
deliveryAbortedHandler(EventHandler<IncomingDelivery>) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonReceiver
 
deliveryAbortedHandler(EventHandler<IncomingDelivery>) - Method in interface org.apache.qpid.protonj2.engine.IncomingDelivery
Handler for aborted deliveries that is called if this delivery is aborted by the Sender.
deliveryAbortedHandler(EventHandler<IncomingDelivery>) - Method in interface org.apache.qpid.protonj2.engine.Receiver
Handler for aborted deliveries that is called for each aborted in-progress delivery.
DeliveryAnnotations - Class in org.apache.qpid.protonj2.types.messaging
 
DeliveryAnnotations - org.apache.qpid.protonj2.types.messaging.Section.SectionType
 
DeliveryAnnotations(Map<Symbol, ?>) - Constructor for class org.apache.qpid.protonj2.types.messaging.DeliveryAnnotations
 
DeliveryAnnotationsTypeDecoder - Class in org.apache.qpid.protonj2.codec.decoders.messaging
Decoder of AMQP Delivery Annotations type values from a byte stream.
DeliveryAnnotationsTypeDecoder() - Constructor for class org.apache.qpid.protonj2.codec.decoders.messaging.DeliveryAnnotationsTypeDecoder
 
DeliveryAnnotationsTypeEncoder - Class in org.apache.qpid.protonj2.codec.encoders.messaging
Encoder of AMQP DeliveryAnnotations type values to a byte stream.
DeliveryAnnotationsTypeEncoder() - Constructor for class org.apache.qpid.protonj2.codec.encoders.messaging.DeliveryAnnotationsTypeEncoder
 
deliveryCount() - Method in class org.apache.qpid.protonj2.client.impl.ClientMessage
 
deliveryCount() - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiverMessage
 
deliveryCount() - Method in interface org.apache.qpid.protonj2.client.Message
 
deliveryCount(long) - Method in class org.apache.qpid.protonj2.client.impl.ClientMessage
 
deliveryCount(long) - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiverMessage
 
deliveryCount(long) - Method in interface org.apache.qpid.protonj2.client.Message
Sets the value to assign to the delivery count field of this Message.
deliveryDelaySupported() - Method in class org.apache.qpid.protonj2.client.impl.ClientConnectionCapabilities
 
DeliveryIdTracker - Class in org.apache.qpid.protonj2.engine.util
Tracker of Delivery ID values, implements a sequence number and provides ability to keep an not set state for use when allowing for set / not set tracking.
DeliveryIdTracker() - Constructor for class org.apache.qpid.protonj2.engine.util.DeliveryIdTracker
Create a new Delivery Id tracker with initial state.
DeliveryIdTracker(int) - Constructor for class org.apache.qpid.protonj2.engine.util.DeliveryIdTracker
Create a new Delivery Id tracker with initial state.
deliveryMode() - Method in class org.apache.qpid.protonj2.client.ReceiverOptions
 
deliveryMode() - Method in class org.apache.qpid.protonj2.client.SenderOptions
 
deliveryMode(DeliveryMode) - Method in class org.apache.qpid.protonj2.client.ReceiverOptions
Sets the DeliveryMode value to assign to newly created Receiver instances.
deliveryMode(DeliveryMode) - Method in class org.apache.qpid.protonj2.client.SenderOptions
Sets the DeliveryMode value to assign to newly created Sender instances.
deliveryMode(DeliveryMode) - Method in class org.apache.qpid.protonj2.client.StreamReceiverOptions
 
deliveryMode(DeliveryMode) - Method in class org.apache.qpid.protonj2.client.StreamSenderOptions
 
DeliveryMode - Enum in org.apache.qpid.protonj2.client
Control the message delivery guarantee for senders and receivers
DeliveryQueue - Interface in org.apache.qpid.protonj2.client.util
Queue based storage interface for inbound AMQP Delivery objects.
deliveryReadHandler(EventHandler<IncomingDelivery>) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonIncomingDelivery
 
deliveryReadHandler(EventHandler<IncomingDelivery>) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonReceiver
 
deliveryReadHandler(EventHandler<IncomingDelivery>) - Method in interface org.apache.qpid.protonj2.engine.IncomingDelivery
Handler for incoming deliveries that is called for each incoming Transfer frame that comprises either one complete delivery or a chunk of a split framed Transfer.
deliveryReadHandler(EventHandler<IncomingDelivery>) - Method in interface org.apache.qpid.protonj2.engine.Receiver
Handler for incoming deliveries that is called for each incoming Transfer frame that comprises either one complete delivery or a chunk of a split framed Transfer.
DeliveryState - Interface in org.apache.qpid.protonj2.client
Conveys the outcome of a Delivery either incoming or outgoing.
DeliveryState - Interface in org.apache.qpid.protonj2.types.transport
Describes the state of a delivery at a link end-point.
DeliveryState.DeliveryStateType - Enum in org.apache.qpid.protonj2.types.transport
An enumeration of the valid DeliveryState types that the library can provide.
DeliveryState.Type - Enum in org.apache.qpid.protonj2.client
 
deliveryStateUpdatedHandler(EventHandler<IncomingDelivery>) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonIncomingDelivery
 
deliveryStateUpdatedHandler(EventHandler<IncomingDelivery>) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonReceiver
 
deliveryStateUpdatedHandler(EventHandler<IncomingDelivery>) - Method in interface org.apache.qpid.protonj2.engine.IncomingDelivery
Handler for updates to the remote state of incoming deliveries that have previously been received.
deliveryStateUpdatedHandler(EventHandler<IncomingDelivery>) - Method in interface org.apache.qpid.protonj2.engine.Receiver
Handler for updates to the remote state of incoming deliveries that have previously been received.
deliveryStateUpdatedHandler(EventHandler<OutgoingDelivery>) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonOutgoingDelivery
 
deliveryStateUpdatedHandler(EventHandler<OutgoingDelivery>) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonSender
 
deliveryStateUpdatedHandler(EventHandler<OutgoingDelivery>) - Method in interface org.apache.qpid.protonj2.engine.OutgoingDelivery
Handler for updates to the remote state of outgoing deliveries that have begun transferring frames.
deliveryStateUpdatedHandler(EventHandler<OutgoingDelivery>) - Method in interface org.apache.qpid.protonj2.engine.Sender
Handler for updates for deliveries that have previously been sent.
DeliveryTag - Interface in org.apache.qpid.protonj2.types
An abstraction around Transfer frames Binary delivery tag which can be used to provide additional features to code sending transfers such as tag pooling etc.
DeliveryTag.ProtonDeliveryTag - Class in org.apache.qpid.protonj2.types
A default DeliveryTag implementation that can be used by a codec when decoding DeliveryTag instances from the wire.
DeliveryTagEncoder - Class in org.apache.qpid.protonj2.codec.encoders
Custom encoder for writing DeliveryTag types to a ProtonBuffer.
DeliveryTagEncoder() - Constructor for class org.apache.qpid.protonj2.codec.encoders.DeliveryTagEncoder
 
DeliveryTagGenerator - Interface in org.apache.qpid.protonj2.engine
Transfer tag generators can be assigned to Sender links in order to allow the link to automatically assign a transfer tag to each outbound delivery.
dequeue(long) - Method in interface org.apache.qpid.protonj2.client.util.DeliveryQueue
Used to get an Delivery.
dequeue(long) - Method in class org.apache.qpid.protonj2.client.util.FifoDeliveryQueue
 
dequeueNoWait() - Method in interface org.apache.qpid.protonj2.client.util.DeliveryQueue
Used to get an enqueued Delivery if on exists, otherwise returns null.
dequeueNoWait() - Method in class org.apache.qpid.protonj2.client.util.FifoDeliveryQueue
 
descendingKeySet() - Method in class org.apache.qpid.protonj2.engine.util.SplayMap
 
descendingMap() - Method in class org.apache.qpid.protonj2.engine.util.SplayMap
 
DESCRIBED_TYPE_INDICATOR - Static variable in interface org.apache.qpid.protonj2.codec.EncodingCodes
 
DescribedType - Interface in org.apache.qpid.protonj2.types
 
DescribedTypeDecoder<V> - Interface in org.apache.qpid.protonj2.codec
Interface for all DescribedType decoder implementations
DescribedTypeEncoder<V> - Interface in org.apache.qpid.protonj2.codec
Interface for all DescribedType encoder implementations
description() - Method in interface org.apache.qpid.protonj2.client.ErrorCondition
Descriptive text that supplies any supplementary details not indicated by the condition value..
description() - Method in class org.apache.qpid.protonj2.client.impl.ClientErrorCondition
 
DESCRIPTOR_CODE - Static variable in class org.apache.qpid.protonj2.types.messaging.Accepted
 
DESCRIPTOR_CODE - Static variable in class org.apache.qpid.protonj2.types.messaging.AmqpSequence
 
DESCRIPTOR_CODE - Static variable in class org.apache.qpid.protonj2.types.messaging.AmqpValue
 
DESCRIPTOR_CODE - Static variable in class org.apache.qpid.protonj2.types.messaging.ApplicationProperties
 
DESCRIPTOR_CODE - Static variable in class org.apache.qpid.protonj2.types.messaging.Data
 
DESCRIPTOR_CODE - Static variable in class org.apache.qpid.protonj2.types.messaging.DeleteOnClose
 
DESCRIPTOR_CODE - Static variable in class org.apache.qpid.protonj2.types.messaging.DeleteOnNoLinks
 
DESCRIPTOR_CODE - Static variable in class org.apache.qpid.protonj2.types.messaging.DeleteOnNoLinksOrMessages
 
DESCRIPTOR_CODE - Static variable in class org.apache.qpid.protonj2.types.messaging.DeleteOnNoMessages
 
DESCRIPTOR_CODE - Static variable in class org.apache.qpid.protonj2.types.messaging.DeliveryAnnotations
 
DESCRIPTOR_CODE - Static variable in class org.apache.qpid.protonj2.types.messaging.Footer
 
DESCRIPTOR_CODE - Static variable in class org.apache.qpid.protonj2.types.messaging.Header
 
DESCRIPTOR_CODE - Static variable in class org.apache.qpid.protonj2.types.messaging.MessageAnnotations
 
DESCRIPTOR_CODE - Static variable in class org.apache.qpid.protonj2.types.messaging.Modified
 
DESCRIPTOR_CODE - Static variable in class org.apache.qpid.protonj2.types.messaging.Properties
 
DESCRIPTOR_CODE - Static variable in class org.apache.qpid.protonj2.types.messaging.Received
 
DESCRIPTOR_CODE - Static variable in class org.apache.qpid.protonj2.types.messaging.Rejected
 
DESCRIPTOR_CODE - Static variable in class org.apache.qpid.protonj2.types.messaging.Released
 
DESCRIPTOR_CODE - Static variable in class org.apache.qpid.protonj2.types.messaging.Source
 
DESCRIPTOR_CODE - Static variable in class org.apache.qpid.protonj2.types.messaging.Target
 
DESCRIPTOR_CODE - Static variable in class org.apache.qpid.protonj2.types.security.SaslChallenge
 
DESCRIPTOR_CODE - Static variable in class org.apache.qpid.protonj2.types.security.SaslInit
 
DESCRIPTOR_CODE - Static variable in class org.apache.qpid.protonj2.types.security.SaslMechanisms
 
DESCRIPTOR_CODE - Static variable in class org.apache.qpid.protonj2.types.security.SaslOutcome
 
DESCRIPTOR_CODE - Static variable in class org.apache.qpid.protonj2.types.security.SaslResponse
 
DESCRIPTOR_CODE - Static variable in class org.apache.qpid.protonj2.types.transactions.Coordinator
 
DESCRIPTOR_CODE - Static variable in class org.apache.qpid.protonj2.types.transactions.Declare
 
DESCRIPTOR_CODE - Static variable in class org.apache.qpid.protonj2.types.transactions.Declared
 
DESCRIPTOR_CODE - Static variable in class org.apache.qpid.protonj2.types.transactions.Discharge
 
DESCRIPTOR_CODE - Static variable in class org.apache.qpid.protonj2.types.transactions.TransactionalState
 
DESCRIPTOR_CODE - Static variable in class org.apache.qpid.protonj2.types.transport.Attach
 
DESCRIPTOR_CODE - Static variable in class org.apache.qpid.protonj2.types.transport.Begin
 
DESCRIPTOR_CODE - Static variable in class org.apache.qpid.protonj2.types.transport.Close
The UnsignedLong descriptor code that defines this AMQP type.
DESCRIPTOR_CODE - Static variable in class org.apache.qpid.protonj2.types.transport.Detach
 
DESCRIPTOR_CODE - Static variable in class org.apache.qpid.protonj2.types.transport.Disposition
 
DESCRIPTOR_CODE - Static variable in class org.apache.qpid.protonj2.types.transport.End
 
DESCRIPTOR_CODE - Static variable in class org.apache.qpid.protonj2.types.transport.ErrorCondition
 
DESCRIPTOR_CODE - Static variable in class org.apache.qpid.protonj2.types.transport.Flow
 
DESCRIPTOR_CODE - Static variable in class org.apache.qpid.protonj2.types.transport.Open
 
DESCRIPTOR_CODE - Static variable in class org.apache.qpid.protonj2.types.transport.Transfer
 
DESCRIPTOR_SYMBOL - Static variable in class org.apache.qpid.protonj2.types.messaging.Accepted
 
DESCRIPTOR_SYMBOL - Static variable in class org.apache.qpid.protonj2.types.messaging.AmqpSequence
 
DESCRIPTOR_SYMBOL - Static variable in class org.apache.qpid.protonj2.types.messaging.AmqpValue
 
DESCRIPTOR_SYMBOL - Static variable in class org.apache.qpid.protonj2.types.messaging.ApplicationProperties
 
DESCRIPTOR_SYMBOL - Static variable in class org.apache.qpid.protonj2.types.messaging.Data
 
DESCRIPTOR_SYMBOL - Static variable in class org.apache.qpid.protonj2.types.messaging.DeleteOnClose
 
DESCRIPTOR_SYMBOL - Static variable in class org.apache.qpid.protonj2.types.messaging.DeleteOnNoLinks
 
DESCRIPTOR_SYMBOL - Static variable in class org.apache.qpid.protonj2.types.messaging.DeleteOnNoLinksOrMessages
 
DESCRIPTOR_SYMBOL - Static variable in class org.apache.qpid.protonj2.types.messaging.DeleteOnNoMessages
 
DESCRIPTOR_SYMBOL - Static variable in class org.apache.qpid.protonj2.types.messaging.DeliveryAnnotations
 
DESCRIPTOR_SYMBOL - Static variable in class org.apache.qpid.protonj2.types.messaging.Footer
 
DESCRIPTOR_SYMBOL - Static variable in class org.apache.qpid.protonj2.types.messaging.Header
 
DESCRIPTOR_SYMBOL - Static variable in class org.apache.qpid.protonj2.types.messaging.MessageAnnotations
 
DESCRIPTOR_SYMBOL - Static variable in class org.apache.qpid.protonj2.types.messaging.Modified
 
DESCRIPTOR_SYMBOL - Static variable in class org.apache.qpid.protonj2.types.messaging.Properties
 
DESCRIPTOR_SYMBOL - Static variable in class org.apache.qpid.protonj2.types.messaging.Received
 
DESCRIPTOR_SYMBOL - Static variable in class org.apache.qpid.protonj2.types.messaging.Rejected
 
DESCRIPTOR_SYMBOL - Static variable in class org.apache.qpid.protonj2.types.messaging.Released
 
DESCRIPTOR_SYMBOL - Static variable in class org.apache.qpid.protonj2.types.messaging.Source
 
DESCRIPTOR_SYMBOL - Static variable in class org.apache.qpid.protonj2.types.messaging.Target
 
DESCRIPTOR_SYMBOL - Static variable in class org.apache.qpid.protonj2.types.security.SaslChallenge
 
DESCRIPTOR_SYMBOL - Static variable in class org.apache.qpid.protonj2.types.security.SaslInit
 
DESCRIPTOR_SYMBOL - Static variable in class org.apache.qpid.protonj2.types.security.SaslMechanisms
 
DESCRIPTOR_SYMBOL - Static variable in class org.apache.qpid.protonj2.types.security.SaslOutcome
 
DESCRIPTOR_SYMBOL - Static variable in class org.apache.qpid.protonj2.types.security.SaslResponse
 
DESCRIPTOR_SYMBOL - Static variable in class org.apache.qpid.protonj2.types.transactions.Coordinator
 
DESCRIPTOR_SYMBOL - Static variable in class org.apache.qpid.protonj2.types.transactions.Declare
 
DESCRIPTOR_SYMBOL - Static variable in class org.apache.qpid.protonj2.types.transactions.Declared
 
DESCRIPTOR_SYMBOL - Static variable in class org.apache.qpid.protonj2.types.transactions.Discharge
 
DESCRIPTOR_SYMBOL - Static variable in class org.apache.qpid.protonj2.types.transactions.TransactionalState
 
DESCRIPTOR_SYMBOL - Static variable in class org.apache.qpid.protonj2.types.transport.Attach
 
DESCRIPTOR_SYMBOL - Static variable in class org.apache.qpid.protonj2.types.transport.Begin
 
DESCRIPTOR_SYMBOL - Static variable in class org.apache.qpid.protonj2.types.transport.Close
The Symbol descriptor code that defines this AMQP type.
DESCRIPTOR_SYMBOL - Static variable in class org.apache.qpid.protonj2.types.transport.Detach
 
DESCRIPTOR_SYMBOL - Static variable in class org.apache.qpid.protonj2.types.transport.Disposition
 
DESCRIPTOR_SYMBOL - Static variable in class org.apache.qpid.protonj2.types.transport.End
 
DESCRIPTOR_SYMBOL - Static variable in class org.apache.qpid.protonj2.types.transport.ErrorCondition
 
DESCRIPTOR_SYMBOL - Static variable in class org.apache.qpid.protonj2.types.transport.Flow
 
DESCRIPTOR_SYMBOL - Static variable in class org.apache.qpid.protonj2.types.transport.Open
 
DESCRIPTOR_SYMBOL - Static variable in class org.apache.qpid.protonj2.types.transport.Transfer
 
desiredCapabilities() - Method in interface org.apache.qpid.protonj2.client.Connection
Returns the desired capabilities that the remote provided upon successfully opening the Connection.
desiredCapabilities() - Method in class org.apache.qpid.protonj2.client.ConnectionOptions
 
desiredCapabilities() - Method in class org.apache.qpid.protonj2.client.impl.ClientConnection
 
desiredCapabilities() - Method in class org.apache.qpid.protonj2.client.impl.ClientReceiver
 
desiredCapabilities() - Method in class org.apache.qpid.protonj2.client.impl.ClientSession
 
desiredCapabilities() - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiver
 
desiredCapabilities() - Method in interface org.apache.qpid.protonj2.client.Receiver
Returns the desired capabilities that the remote provided upon successfully opening the Receiver.
desiredCapabilities() - Method in class org.apache.qpid.protonj2.client.ReceiverOptions
 
desiredCapabilities() - Method in interface org.apache.qpid.protonj2.client.Sender
Returns the desired capabilities that the remote provided upon successfully opening the Sender.
desiredCapabilities() - Method in class org.apache.qpid.protonj2.client.SenderOptions
 
desiredCapabilities() - Method in interface org.apache.qpid.protonj2.client.Session
Returns the desired capabilities that the remote provided upon successfully opening the Session.
desiredCapabilities() - Method in class org.apache.qpid.protonj2.client.SessionOptions
 
desiredCapabilities(String...) - Method in class org.apache.qpid.protonj2.client.ConnectionOptions
Sets the collection of capabilities to request from the remote for a new Connection created using these ConnectionOptions.
desiredCapabilities(String...) - Method in class org.apache.qpid.protonj2.client.ReceiverOptions
 
desiredCapabilities(String...) - Method in class org.apache.qpid.protonj2.client.SenderOptions
 
desiredCapabilities(String...) - Method in class org.apache.qpid.protonj2.client.SessionOptions
 
desiredCapabilities(String...) - Method in class org.apache.qpid.protonj2.client.StreamReceiverOptions
 
desiredCapabilities(String...) - Method in class org.apache.qpid.protonj2.client.StreamSenderOptions
 
detach() - Method in class org.apache.qpid.protonj2.client.impl.ClientReceiver
 
detach() - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiver
 
detach() - Method in interface org.apache.qpid.protonj2.client.Receiver
Requests a detach of the Receiver at the remote and waits until the Receiver has been fully detached or until the configured SenderOptions.closeTimeout() is exceeded.
detach() - Method in interface org.apache.qpid.protonj2.client.Sender
Requests a detach of the Sender at the remote and waits until the Sender has been fully detached or until the configured SenderOptions.closeTimeout() is exceeded.
detach() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonLink
 
detach() - Method in interface org.apache.qpid.protonj2.engine.Link
Detach this end of the link.
detach(ErrorCondition) - Method in class org.apache.qpid.protonj2.client.impl.ClientReceiver
 
detach(ErrorCondition) - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiver
 
detach(ErrorCondition) - Method in interface org.apache.qpid.protonj2.client.Receiver
Requests a detach of the Receiver at the remote and waits until the Receiver has been fully detached or until the configured SenderOptions.closeTimeout() is exceeded.
detach(ErrorCondition) - Method in interface org.apache.qpid.protonj2.client.Sender
Requests a detach of the Sender at the remote and waits until the Sender has been fully detached or until the configured SenderOptions.closeTimeout() is exceeded.
Detach - Class in org.apache.qpid.protonj2.types.transport
 
Detach() - Constructor for class org.apache.qpid.protonj2.types.transport.Detach
 
DETACH - org.apache.qpid.protonj2.types.transport.Performative.PerformativeType
 
DETACH_FORCED - Static variable in interface org.apache.qpid.protonj2.types.transport.LinkError
An operator intervened to detach for some reason.
detachAsync() - Method in class org.apache.qpid.protonj2.client.impl.ClientReceiver
 
detachAsync() - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiver
 
detachAsync() - Method in interface org.apache.qpid.protonj2.client.Receiver
Requests a detach of the Receiver link at the remote and returns a Future that will be completed once the link has been detached.
detachAsync() - Method in interface org.apache.qpid.protonj2.client.Sender
Requests a detach of the Sender link at the remote and returns a Future that will be completed once the link has been detached.
detachAsync(ErrorCondition) - Method in class org.apache.qpid.protonj2.client.impl.ClientReceiver
 
detachAsync(ErrorCondition) - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiver
 
detachAsync(ErrorCondition) - Method in interface org.apache.qpid.protonj2.client.Receiver
Requests a detach of the Receiver link at the remote and returns a Future that will be completed once the link has been detached.
detachAsync(ErrorCondition) - Method in interface org.apache.qpid.protonj2.client.Sender
Requests a detach of the Sender link at the remote and returns a Future that will be completed once the link has been detached.
DETACHED - org.apache.qpid.protonj2.engine.LinkState
Indicates that the targeted end of the Link (local or remote) has been detached.
detachHandler(EventHandler<L>) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonLink
 
detachHandler(EventHandler<L>) - Method in interface org.apache.qpid.protonj2.engine.Link
Sets a EventHandler for when an AMQP Detach frame is received from the remote peer for this Link which would have been locally opened previously, the Detach from would have been marked as not having been closed.
DetachTypeDecoder - Class in org.apache.qpid.protonj2.codec.decoders.transport
Decoder of AMQP Detach type values from a byte stream
DetachTypeDecoder() - Constructor for class org.apache.qpid.protonj2.codec.decoders.transport.DetachTypeDecoder
 
DetachTypeEncoder - Class in org.apache.qpid.protonj2.codec.encoders.transport
Encoder of AMQP Detach type values to a byte stream.
DetachTypeEncoder() - Constructor for class org.apache.qpid.protonj2.codec.encoders.transport.DetachTypeEncoder
 
disabledCipherSuites() - Method in class org.apache.qpid.protonj2.client.SslOptions
 
disabledCipherSuites(String...) - Method in class org.apache.qpid.protonj2.client.SslOptions
 
disabledProtocols() - Method in class org.apache.qpid.protonj2.client.SslOptions
 
disabledProtocols(String...) - Method in class org.apache.qpid.protonj2.client.SslOptions
The protocols to be disable.
discard() - Method in class org.apache.qpid.protonj2.client.impl.ClientOutgoingEnvelope
 
discharge(Transaction<TransactionController>, boolean) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonTransactionController
 
discharge(Transaction<TransactionController>, boolean) - Method in interface org.apache.qpid.protonj2.engine.TransactionController
Request that the remote TransactionManager discharge the given transaction and with the specified failure state (true for failed).
Discharge - Class in org.apache.qpid.protonj2.types.transactions
 
Discharge() - Constructor for class org.apache.qpid.protonj2.types.transactions.Discharge
 
DISCHARGE_FAILED - org.apache.qpid.protonj2.engine.TransactionState
A Transaction is considered failed in the TransactionManager responds with an error to the Discharge action.
discharged(Transaction<TransactionManager>) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonTransactionManager
 
discharged(Transaction<TransactionManager>) - Method in interface org.apache.qpid.protonj2.engine.TransactionManager
Respond to a previous Discharge request from the remote TransactionController indicating that the discharge completed on the transaction identified by given transaction Id has now been retired.
DISCHARGED - org.apache.qpid.protonj2.engine.TransactionState
A Transaction is considered discharged once a Discharge has been requested and the TransactionManager has responded in the affirmative that the request has been honored.
dischargedHandler(EventHandler<Transaction<TransactionController>>) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonTransactionController
 
dischargedHandler(EventHandler<Transaction<TransactionController>>) - Method in interface org.apache.qpid.protonj2.engine.TransactionController
Called when the TransactionManager end of the link has responded to a previous TransactionController.discharge(Transaction, boolean) request and the transaction has been retired.
dischargeFailed(Transaction<TransactionManager>, ErrorCondition) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonTransactionManager
 
dischargeFailed(Transaction<TransactionManager>, ErrorCondition) - Method in interface org.apache.qpid.protonj2.engine.TransactionManager
Respond to a previous Discharge request from the remote TransactionController indicating that the discharge resulted in an error and the transaction must be considered rolled back.
dischargeFailureHandler(EventHandler<Transaction<TransactionController>>) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonTransactionController
 
dischargeFailureHandler(EventHandler<Transaction<TransactionController>>) - Method in interface org.apache.qpid.protonj2.engine.TransactionController
Called when the TransactionManager end of the link has responded to a previous TransactionController.discharge(Transaction, boolean) request and the transaction discharge failed for some reason.
dischargeHandler(EventHandler<Transaction<TransactionManager>>) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonTransactionManager
 
dischargeHandler(EventHandler<Transaction<TransactionManager>>) - Method in interface org.apache.qpid.protonj2.engine.TransactionManager
Called when the TransactionController end of the link has requested a current transaction be discharged using the information provided in the given Discharge instance.
DischargeTypeDecoder - Class in org.apache.qpid.protonj2.codec.decoders.transactions
Decoder of AMQP Discharge type values from a byte stream.
DischargeTypeDecoder() - Constructor for class org.apache.qpid.protonj2.codec.decoders.transactions.DischargeTypeDecoder
 
DischargeTypeEncoder - Class in org.apache.qpid.protonj2.codec.encoders.transactions
Encoder of AMQP Discharge type values to a byte stream.
DischargeTypeEncoder() - Constructor for class org.apache.qpid.protonj2.codec.encoders.transactions.DischargeTypeEncoder
 
DISCHARGING - org.apache.qpid.protonj2.engine.TransactionState
A Transaction is considered to b discharging once a Discharge command has been sent to the remote but before any response has been received indicating the outcome of the attempted discharge.
disconnectedHandler() - Method in class org.apache.qpid.protonj2.client.ConnectionOptions
 
disconnectedHandler(BiConsumer<Connection, DisconnectionEvent>) - Method in class org.apache.qpid.protonj2.client.ConnectionOptions
Configures a handler that will be notified when the connection has failed and cannot be recovered should reconnect be enabled.
DisconnectionEvent - Class in org.apache.qpid.protonj2.client
An event object that accompanies events fired to handlers configured in the ConnectionOptions which are signaled during specific Connection life-cycle stages.
DisconnectionEvent(String, int, ClientIOException) - Constructor for class org.apache.qpid.protonj2.client.DisconnectionEvent
Creates the event object with all immutable data provided.
disposition(Predicate<IncomingDelivery>, DeliveryState, boolean) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonReceiver
 
disposition(Predicate<IncomingDelivery>, DeliveryState, boolean) - Method in interface org.apache.qpid.protonj2.engine.Receiver
For each unsettled outgoing delivery that is pending in the Receiver apply the given predicate and if it matches then apply the given delivery state and settled value to it.
disposition(Predicate<OutgoingDelivery>, DeliveryState, boolean) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonSender
 
disposition(Predicate<OutgoingDelivery>, DeliveryState, boolean) - Method in interface org.apache.qpid.protonj2.engine.Sender
For each unsettled outgoing delivery that is pending in the Sender apply the given predicate and if it matches then apply the given delivery state and settled value to it.
disposition(DeliveryState, boolean) - Method in interface org.apache.qpid.protonj2.client.Delivery
Updates the DeliveryState, and optionally settle the delivery as well.
disposition(DeliveryState, boolean) - Method in class org.apache.qpid.protonj2.client.impl.ClientDelivery
 
disposition(DeliveryState, boolean) - Method in class org.apache.qpid.protonj2.client.impl.ClientNoOpStreamTracker
 
disposition(DeliveryState, boolean) - Method in class org.apache.qpid.protonj2.client.impl.ClientNoOpTracker
 
disposition(DeliveryState, boolean) - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamDelivery
 
disposition(DeliveryState, boolean) - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamTracker
 
disposition(DeliveryState, boolean) - Method in interface org.apache.qpid.protonj2.client.StreamDelivery
Updates the DeliveryState, and optionally settle the delivery as well.
disposition(DeliveryState, boolean) - Method in interface org.apache.qpid.protonj2.client.StreamTracker
Updates the DeliveryState, and optionally settle the delivery as well.
disposition(DeliveryState, boolean) - Method in interface org.apache.qpid.protonj2.client.Tracker
Updates the DeliveryState, and optionally settle the delivery as well.
disposition(IncomingDelivery, DeliveryState, boolean) - Method in interface org.apache.qpid.protonj2.client.impl.ClientTransactionContext
Apply a disposition to the given delivery wrapping it with a TransactionalState outcome if there is an active transaction.
disposition(DeliveryState) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonIncomingDelivery
 
disposition(DeliveryState) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonOutgoingDelivery
 
disposition(DeliveryState) - Method in interface org.apache.qpid.protonj2.engine.IncomingDelivery
updates the state of the delivery
disposition(DeliveryState) - Method in interface org.apache.qpid.protonj2.engine.OutgoingDelivery
updates the state of the delivery
disposition(DeliveryState, boolean) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonIncomingDelivery
 
disposition(DeliveryState, boolean) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonOutgoingDelivery
 
disposition(DeliveryState, boolean) - Method in interface org.apache.qpid.protonj2.engine.IncomingDelivery
Update the delivery with the given disposition if not locally settled and optionally settles the delivery if not already settled.
disposition(DeliveryState, boolean) - Method in interface org.apache.qpid.protonj2.engine.OutgoingDelivery
Update the delivery with the given disposition if not locally settled and optionally settles the delivery if not already settled.
Disposition - Class in org.apache.qpid.protonj2.types.transport
 
Disposition() - Constructor for class org.apache.qpid.protonj2.types.transport.Disposition
 
DISPOSITION - org.apache.qpid.protonj2.types.transport.Performative.PerformativeType
 
DispositionTypeDecoder - Class in org.apache.qpid.protonj2.codec.decoders.transport
Decoder of AMQP Disposition type values from a byte stream.
DispositionTypeDecoder() - Constructor for class org.apache.qpid.protonj2.codec.decoders.transport.DispositionTypeDecoder
 
DispositionTypeEncoder - Class in org.apache.qpid.protonj2.codec.encoders.transport
Encoder of AMQP Disposition type values to a byte stream
DispositionTypeEncoder() - Constructor for class org.apache.qpid.protonj2.codec.encoders.transport.DispositionTypeEncoder
 
DISTRIBUTED_TXN - Static variable in interface org.apache.qpid.protonj2.types.transactions.TxnCapability
 
distributionMode() - Method in interface org.apache.qpid.protonj2.client.Source
 
distributionMode() - Method in class org.apache.qpid.protonj2.client.SourceOptions
 
distributionMode(DistributionMode) - Method in class org.apache.qpid.protonj2.client.SourceOptions
 
DistributionMode - Enum in org.apache.qpid.protonj2.client
Control whether messages are browsed or consumed.
DOUBLE - Static variable in interface org.apache.qpid.protonj2.codec.EncodingCodes
 
DoubleTypeDecoder - Class in org.apache.qpid.protonj2.codec.decoders.primitives
Decoder of AMQP Double values from a byte stream
DoubleTypeDecoder() - Constructor for class org.apache.qpid.protonj2.codec.decoders.primitives.DoubleTypeDecoder
 
DoubleTypeEncoder - Class in org.apache.qpid.protonj2.codec.encoders.primitives
Encoder of AMQP Double type values to a byte stream.
DoubleTypeEncoder() - Constructor for class org.apache.qpid.protonj2.codec.encoders.primitives.DoubleTypeEncoder
 
doubleValue() - Method in class org.apache.qpid.protonj2.engine.util.DeliveryIdTracker
 
doubleValue() - Method in class org.apache.qpid.protonj2.engine.util.SequenceNumber
 
doubleValue() - Method in class org.apache.qpid.protonj2.types.Decimal128
 
doubleValue() - Method in class org.apache.qpid.protonj2.types.Decimal32
 
doubleValue() - Method in class org.apache.qpid.protonj2.types.Decimal64
 
doubleValue() - Method in class org.apache.qpid.protonj2.types.UnsignedByte
 
doubleValue() - Method in class org.apache.qpid.protonj2.types.UnsignedInteger
 
doubleValue() - Method in class org.apache.qpid.protonj2.types.UnsignedLong
 
doubleValue() - Method in class org.apache.qpid.protonj2.types.UnsignedShort
 
drain() - Method in class org.apache.qpid.protonj2.client.impl.ClientReceiver
 
drain() - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiver
 
drain() - Method in interface org.apache.qpid.protonj2.client.Receiver
Requests the remote to drain previously granted credit for this Receiver link.
drain() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonReceiver
 
drain() - Method in interface org.apache.qpid.protonj2.engine.Receiver
Initiate a drain of all remaining credit of this Receiver link.
drain(int) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonReceiver
 
drain(int) - Method in interface org.apache.qpid.protonj2.engine.Receiver
Initiate a drain of the given credit from this this Receiver link.
drained() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonSender
 
drained() - Method in interface org.apache.qpid.protonj2.engine.Sender
Called when the Receiver has requested a drain of credit and the sender has sent all available messages.
drainTimeout() - Method in class org.apache.qpid.protonj2.client.ConnectionOptions
 
drainTimeout() - Method in class org.apache.qpid.protonj2.client.ReceiverOptions
 
drainTimeout() - Method in class org.apache.qpid.protonj2.client.SessionOptions
 
drainTimeout(long) - Method in class org.apache.qpid.protonj2.client.ConnectionOptions
Sets the drain timeout (in milliseconds) after which a Receiver request to drain link credit is considered failed and the request will be marked as such.
drainTimeout(long) - Method in class org.apache.qpid.protonj2.client.ReceiverOptions
Sets the drain timeout (in milliseconds) after which a Receiver request to drain link credit is considered failed and the request will be marked as such.
drainTimeout(long) - Method in class org.apache.qpid.protonj2.client.SessionOptions
Sets the drain timeout (in milliseconds) after which a Receiver request to drain link credit is considered failed and the request will be marked as such.
drainTimeout(long) - Method in class org.apache.qpid.protonj2.client.StreamReceiverOptions
 
drainTimeout(long, TimeUnit) - Method in class org.apache.qpid.protonj2.client.ConnectionOptions
Sets the drain timeout value after which a Receiver request to drain link credit is considered failed and the request will be marked as such.
drainTimeout(long, TimeUnit) - Method in class org.apache.qpid.protonj2.client.ReceiverOptions
Sets the drain timeout value after which a Receiver request to drain link credit is considered failed and the request will be marked as such.
drainTimeout(long, TimeUnit) - Method in class org.apache.qpid.protonj2.client.SessionOptions
Sets the drain timeout value after which a Receiver request to drain link credit is considered failed and the request will be marked as such.
drainTimeout(long, TimeUnit) - Method in class org.apache.qpid.protonj2.client.StreamReceiverOptions
 
duplicate() - Method in class org.apache.qpid.protonj2.buffer.ProtonAbstractBuffer
 
duplicate() - Method in interface org.apache.qpid.protonj2.buffer.ProtonBuffer
Create a duplicate of this ProtonBuffer instance that shares the same backing data store and but maintains separate position index values.
duplicate() - Method in class org.apache.qpid.protonj2.buffer.ProtonCompositeBuffer
 
duplicate() - Method in class org.apache.qpid.protonj2.buffer.ProtonDuplicatedBuffer
 
duplicate() - Method in class org.apache.qpid.protonj2.buffer.ProtonNettyByteBuffer
 
duplicate() - Method in class org.apache.qpid.protonj2.buffer.ProtonSlicedBuffer
 
durabilityMode() - Method in interface org.apache.qpid.protonj2.client.Source
 
durabilityMode() - Method in interface org.apache.qpid.protonj2.client.Target
 
durabilityMode() - Method in class org.apache.qpid.protonj2.client.TerminusOptions
 
durabilityMode(DurabilityMode) - Method in class org.apache.qpid.protonj2.client.TerminusOptions
 
DurabilityMode - Enum in org.apache.qpid.protonj2.client
Control the persistence of source or target state.
durable() - Method in class org.apache.qpid.protonj2.client.impl.ClientMessage
 
durable() - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiverMessage
 
durable() - Method in interface org.apache.qpid.protonj2.client.Message
For an message being sent this method returns the current state of the durable flag on the message.
durable(boolean) - Method in class org.apache.qpid.protonj2.client.impl.ClientMessage
 
durable(boolean) - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiverMessage
 
durable(boolean) - Method in interface org.apache.qpid.protonj2.client.Message
Controls if the message is marked as durable when sent.
dynamic() - Method in interface org.apache.qpid.protonj2.client.Source
 
dynamic() - Method in interface org.apache.qpid.protonj2.client.Target
 
dynamicNodeProperties() - Method in interface org.apache.qpid.protonj2.client.Source
 
dynamicNodeProperties() - Method in interface org.apache.qpid.protonj2.client.Target
 

E

EMPTY - org.apache.qpid.protonj2.engine.impl.ProtonDeliveryTagGenerator.BUILTIN
Provides a DeliveryTagGenerator that returns a singleton empty tag value that can be used by senders that are sending settled deliveries and simply need to provide a non-null tag value to the outgoing delivery instance.
EMPTY - Static variable in class org.apache.qpid.protonj2.engine.sasl.client.AbstractMechanism
 
EMPTY_TAG - Static variable in class org.apache.qpid.protonj2.types.DeliveryTag.ProtonDeliveryTag
 
EmptyEnvelope - Class in org.apache.qpid.protonj2.engine
An empty envelope which can be used to drive transport activity when idle.
enabledCipherSuites() - Method in class org.apache.qpid.protonj2.client.SslOptions
 
enabledCipherSuites(String...) - Method in class org.apache.qpid.protonj2.client.SslOptions
 
enabledProtocols() - Method in class org.apache.qpid.protonj2.client.SslOptions
 
enabledProtocols(String...) - Method in class org.apache.qpid.protonj2.client.SslOptions
The protocols to be set as enabled.
encode(Map<String, Object>) - Method in interface org.apache.qpid.protonj2.client.AdvancedMessage
Encodes the AdvancedMessage for transmission by the client.
encode(Map<String, Object>) - Method in class org.apache.qpid.protonj2.client.impl.ClientMessage
 
encode(Map<String, Object>) - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiverMessage
 
EncodeException - Exception in org.apache.qpid.protonj2.codec
Exception thrown when a type encoder fails due to some unrecoverable error or violation of AMQP type specifications.
EncodeException() - Constructor for exception org.apache.qpid.protonj2.codec.EncodeException
Creates a generic EncodeException with no cause or error description set.
EncodeException(String) - Constructor for exception org.apache.qpid.protonj2.codec.EncodeException
Creates a EncodeException with the given error message.
EncodeException(String, Throwable) - Constructor for exception org.apache.qpid.protonj2.codec.EncodeException
Creates a EncodeException with the given error message and assigned root cause exception.
EncodeException(Throwable) - Constructor for exception org.apache.qpid.protonj2.codec.EncodeException
Creates a EncodeException with the given assigned root cause exception.
encodeMessage(AdvancedMessage<?>, Map<String, Object>) - Static method in class org.apache.qpid.protonj2.client.impl.ClientMessageSupport
 
encodeMessage(Encoder, ProtonBufferAllocator, AdvancedMessage<?>, Map<String, Object>) - Static method in class org.apache.qpid.protonj2.client.impl.ClientMessageSupport
 
encodeMessage(Encoder, EncoderState, ProtonBufferAllocator, AdvancedMessage<?>, Map<String, Object>) - Static method in class org.apache.qpid.protonj2.client.impl.ClientMessageSupport
 
Encoder - Interface in org.apache.qpid.protonj2.codec
Encode AMQP types into binary streams
EncoderState - Interface in org.apache.qpid.protonj2.codec
Retains Encoder state information either between calls or across encode iterations.
encodeSection(Section<?>, ProtonBuffer) - Static method in class org.apache.qpid.protonj2.client.impl.ClientMessageSupport
 
encodeUTF8(ProtonBuffer, CharSequence) - Method in class org.apache.qpid.protonj2.codec.encoders.ProtonEncoderState
 
encodeUTF8(ProtonBuffer, CharSequence) - Method in interface org.apache.qpid.protonj2.codec.encoders.UTF8Encoder
Encodes the given sequence of characters in UTF8 to the given buffer.
encodeUTF8(ProtonBuffer, CharSequence) - Method in interface org.apache.qpid.protonj2.codec.EncoderState
Encodes the given sequence of characters in UTF8 to the given buffer.
EncodingCodes - Interface in org.apache.qpid.protonj2.codec
Provides a set of definitions for the byte value that indicates what the next AMQP encoding will be when encoding or decoding AMQP types.
End - Class in org.apache.qpid.protonj2.types.transport
 
End() - Constructor for class org.apache.qpid.protonj2.types.transport.End
 
END - org.apache.qpid.protonj2.types.transport.Performative.PerformativeType
 
Endpoint<E extends Endpoint<E>> - Interface in org.apache.qpid.protonj2.engine
Represents a conceptual endpoint type used to provide common operations that all the endpoint types will share.
EndTypeDecoder - Class in org.apache.qpid.protonj2.codec.decoders.transport
Decoder of AMQP End type values from a byte stream
EndTypeDecoder() - Constructor for class org.apache.qpid.protonj2.codec.decoders.transport.EndTypeDecoder
 
EndTypeEncoder - Class in org.apache.qpid.protonj2.codec.encoders.transport
Encoder of AMQP End type values to a byte stream.
EndTypeEncoder() - Constructor for class org.apache.qpid.protonj2.codec.encoders.transport.EndTypeEncoder
 
engine - Variable in class org.apache.qpid.protonj2.engine.impl.ProtonEndpoint
 
engine() - Method in interface org.apache.qpid.protonj2.engine.EngineHandlerContext
 
engine() - Method in interface org.apache.qpid.protonj2.engine.EnginePipeline
 
engine() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEngineHandlerContext
 
engine() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEnginePipeline
 
engine() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEnginePipelineProxy
 
Engine - Interface in org.apache.qpid.protonj2.engine
AMQP Engine interface.
EngineConfiguration - Interface in org.apache.qpid.protonj2.engine
Configuration options for the Engine
EngineFactory - Interface in org.apache.qpid.protonj2.engine
Interface used to define the basic mechanisms for creating Engine instances.
engineFailed(Throwable) - Method in interface org.apache.qpid.protonj2.engine.Engine
Transition the Engine to a failed state if not already closed or closing.
engineFailed(Throwable) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEngine
 
engineFailed(EngineHandlerContext, EngineFailedException) - Method in interface org.apache.qpid.protonj2.engine.EngineHandler
Called when the engine has transitioned to a failed state and cannot process any additional input or output.
engineFailed(EngineHandlerContext, EngineFailedException) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonFrameDecodingHandler
 
engineFailed(EngineHandlerContext, EngineFailedException) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonPerformativeHandler
 
EngineFailedException - Exception in org.apache.qpid.protonj2.engine.exceptions
Thrown from Engine API methods that attempted an operation what would have resulted in a write of data or other state modification after the engine has entered the the failed state.
EngineFailedException(String, Throwable) - Constructor for exception org.apache.qpid.protonj2.engine.exceptions.EngineFailedException
 
EngineFailedException(Throwable) - Constructor for exception org.apache.qpid.protonj2.engine.exceptions.EngineFailedException
 
EngineHandler - Interface in org.apache.qpid.protonj2.engine
Listen for events generated from the Engine
EngineHandlerContext - Interface in org.apache.qpid.protonj2.engine
Context provided to EngineHandler events to allow further event propagation
EngineNotStartedException - Exception in org.apache.qpid.protonj2.engine.exceptions
Thrown when a read or write operation is attempted on the engine before it has been properly started.
EngineNotStartedException() - Constructor for exception org.apache.qpid.protonj2.engine.exceptions.EngineNotStartedException
 
EngineNotStartedException(String) - Constructor for exception org.apache.qpid.protonj2.engine.exceptions.EngineNotStartedException
 
EngineNotStartedException(String, Throwable) - Constructor for exception org.apache.qpid.protonj2.engine.exceptions.EngineNotStartedException
 
EngineNotStartedException(Throwable) - Constructor for exception org.apache.qpid.protonj2.engine.exceptions.EngineNotStartedException
 
EngineNotWritableException - Exception in org.apache.qpid.protonj2.engine.exceptions
Exception indicating that the engine is not currently accepting input of data
EngineNotWritableException() - Constructor for exception org.apache.qpid.protonj2.engine.exceptions.EngineNotWritableException
 
EngineNotWritableException(String) - Constructor for exception org.apache.qpid.protonj2.engine.exceptions.EngineNotWritableException
 
EngineNotWritableException(String, Throwable) - Constructor for exception org.apache.qpid.protonj2.engine.exceptions.EngineNotWritableException
 
EngineNotWritableException(Throwable) - Constructor for exception org.apache.qpid.protonj2.engine.exceptions.EngineNotWritableException
 
EnginePipeline - Interface in org.apache.qpid.protonj2.engine
Pipeline of handlers for Engine work.
EngineSaslDriver - Interface in org.apache.qpid.protonj2.engine
Driver for the Engine that exposes SASL state and configuration.
EngineSaslDriver.SaslState - Enum in org.apache.qpid.protonj2.engine
The SASL driver state used to determine at what point the current SASL negotiation process is currently in.
EngineShutdownException - Exception in org.apache.qpid.protonj2.engine.exceptions
Exception thrown when an option is performed on a closed engine.
EngineShutdownException() - Constructor for exception org.apache.qpid.protonj2.engine.exceptions.EngineShutdownException
 
EngineShutdownException(String) - Constructor for exception org.apache.qpid.protonj2.engine.exceptions.EngineShutdownException
 
EngineShutdownException(String, Throwable) - Constructor for exception org.apache.qpid.protonj2.engine.exceptions.EngineShutdownException
 
EngineShutdownException(Throwable) - Constructor for exception org.apache.qpid.protonj2.engine.exceptions.EngineShutdownException
 
engineShutdownHandler(EventHandler<Engine>) - Method in interface org.apache.qpid.protonj2.engine.Endpoint
Sets an EventHandler that is invoked when the engine that supports this Endpoint is shutdown via a call to Engine.shutdown() which indicates a desire to terminate all engine operations.
engineShutdownHandler(EventHandler<Engine>) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEndpoint
 
EngineStartedException - Exception in org.apache.qpid.protonj2.engine.exceptions
Thrown when an API method has been called which cannot be allowed to proceed due to the engine having already been started and doesn't allow modification to the resource in question after that point.
EngineStartedException(String) - Constructor for exception org.apache.qpid.protonj2.engine.exceptions.EngineStartedException
 
engineStarting(EngineHandlerContext) - Method in interface org.apache.qpid.protonj2.engine.EngineHandler
Called when the engine is started to allow handlers to prepare for use based on the configuration state at start of the engine.
engineStarting(EngineHandlerContext) - Method in class org.apache.qpid.protonj2.engine.impl.sasl.ProtonSaslHandler
 
EngineState - Enum in org.apache.qpid.protonj2.engine
Enumeration of Engine states as visible from the Engine API
EngineStateException - Exception in org.apache.qpid.protonj2.engine.exceptions
Root type for exceptions thrown from the engine due to state violations
EngineStateException() - Constructor for exception org.apache.qpid.protonj2.engine.exceptions.EngineStateException
 
EngineStateException(String) - Constructor for exception org.apache.qpid.protonj2.engine.exceptions.EngineStateException
 
EngineStateException(String, Throwable) - Constructor for exception org.apache.qpid.protonj2.engine.exceptions.EngineStateException
 
EngineStateException(Throwable) - Constructor for exception org.apache.qpid.protonj2.engine.exceptions.EngineStateException
 
enqueue(ClientDelivery) - Method in interface org.apache.qpid.protonj2.client.util.DeliveryQueue
Adds the given Delivery to the end of the Delivery queue.
enqueue(ClientDelivery) - Method in class org.apache.qpid.protonj2.client.util.FifoDeliveryQueue
 
enqueueFirst(ClientDelivery) - Method in interface org.apache.qpid.protonj2.client.util.DeliveryQueue
Adds the given Delivery to the front of the queue.
enqueueFirst(ClientDelivery) - Method in class org.apache.qpid.protonj2.client.util.FifoDeliveryQueue
 
ensureWritable(int) - Method in class org.apache.qpid.protonj2.buffer.ProtonAbstractBuffer
 
ensureWritable(int) - Method in interface org.apache.qpid.protonj2.buffer.ProtonBuffer
Ensures that the requested number of bytes is available for write operations in the current buffer, growing the buffer if needed to meet the requested writable capacity.
ensureWritable(int) - Method in class org.apache.qpid.protonj2.buffer.ProtonNettyByteBuffer
 
entryAdded(SplayMap.SplayedEntry<E>) - Method in class org.apache.qpid.protonj2.engine.util.LinkedSplayMap
 
entryAdded(SplayMap.SplayedEntry<E>) - Method in class org.apache.qpid.protonj2.engine.util.SplayMap
 
entryDeleted(SplayMap.SplayedEntry<E>) - Method in class org.apache.qpid.protonj2.engine.util.LinkedSplayMap
 
entryDeleted(SplayMap.SplayedEntry<E>) - Method in class org.apache.qpid.protonj2.engine.util.SplayMap
 
entryPool - Variable in class org.apache.qpid.protonj2.engine.util.SplayMap
 
entrySet - Variable in class org.apache.qpid.protonj2.engine.util.SplayMap
 
entrySet() - Method in class org.apache.qpid.protonj2.engine.util.LinkedSplayMap
 
entrySet() - Method in class org.apache.qpid.protonj2.engine.util.SplayMap
 
EpollSupport - Class in org.apache.qpid.protonj2.client.transport
 
EpollSupport() - Constructor for class org.apache.qpid.protonj2.client.transport.EpollSupport
 
equals(int) - Method in class org.apache.qpid.protonj2.engine.util.DeliveryIdTracker
Performs an unsigned comparison between the value being tracked and the integer value passed, if no id is currently being tracked then this method returns false.
equals(int) - Method in class org.apache.qpid.protonj2.engine.util.SequenceNumber
Performs an unsigned comparison between the current sequence number and the integer value passed.
equals(Object) - Method in class org.apache.qpid.protonj2.buffer.ProtonAbstractBuffer
 
equals(Object) - Method in class org.apache.qpid.protonj2.buffer.ProtonNettyByteBuffer
 
equals(Object) - Method in class org.apache.qpid.protonj2.client.ReconnectLocation
 
equals(Object) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonSequentialTagGenerator.ProtonNumericDeliveryTag
 
equals(Object) - Method in class org.apache.qpid.protonj2.engine.util.DeliveryIdTracker
 
equals(Object) - Method in class org.apache.qpid.protonj2.engine.util.SequenceNumber
 
equals(Object) - Method in class org.apache.qpid.protonj2.engine.util.SplayMap.SplayedEntry
 
equals(Object) - Method in class org.apache.qpid.protonj2.types.Binary
 
equals(Object) - Method in class org.apache.qpid.protonj2.types.Decimal128
 
equals(Object) - Method in class org.apache.qpid.protonj2.types.Decimal32
 
equals(Object) - Method in class org.apache.qpid.protonj2.types.Decimal64
 
equals(Object) - Method in class org.apache.qpid.protonj2.types.DeliveryTag.ProtonDeliveryTag
 
equals(Object) - Method in class org.apache.qpid.protonj2.types.messaging.AmqpSequence
 
equals(Object) - Method in class org.apache.qpid.protonj2.types.messaging.AmqpValue
 
equals(Object) - Method in class org.apache.qpid.protonj2.types.messaging.ApplicationProperties
 
equals(Object) - Method in class org.apache.qpid.protonj2.types.messaging.Data
 
equals(Object) - Method in class org.apache.qpid.protonj2.types.messaging.DeliveryAnnotations
 
equals(Object) - Method in class org.apache.qpid.protonj2.types.messaging.Footer
 
equals(Object) - Method in class org.apache.qpid.protonj2.types.messaging.MessageAnnotations
 
equals(Object) - Method in class org.apache.qpid.protonj2.types.Symbol
 
equals(Object) - Method in class org.apache.qpid.protonj2.types.transport.AMQPHeader
 
equals(Object) - Method in class org.apache.qpid.protonj2.types.transport.ErrorCondition
 
equals(Object) - Method in class org.apache.qpid.protonj2.types.UnknownDescribedType
 
equals(Object) - Method in class org.apache.qpid.protonj2.types.UnsignedByte
 
equals(Object) - Method in class org.apache.qpid.protonj2.types.UnsignedInteger
 
equals(Object) - Method in class org.apache.qpid.protonj2.types.UnsignedLong
 
equals(Object) - Method in class org.apache.qpid.protonj2.types.UnsignedShort
 
ERRANT_LINK - Static variable in interface org.apache.qpid.protonj2.types.transport.SessionError
Input was received for a link that was detached with an error.
error - Variable in class org.apache.qpid.protonj2.client.futures.ClientFuture
 
error(String) - Method in class org.apache.qpid.protonj2.logging.NoOpProtonLogger
 
error(String) - Method in interface org.apache.qpid.protonj2.logging.ProtonLogger
 
error(String) - Method in class org.apache.qpid.protonj2.logging.Slf4JLoggerWrapper
 
error(String, Object) - Method in class org.apache.qpid.protonj2.logging.NoOpProtonLogger
 
error(String, Object) - Method in interface org.apache.qpid.protonj2.logging.ProtonLogger
 
error(String, Object) - Method in class org.apache.qpid.protonj2.logging.Slf4JLoggerWrapper
 
error(String, Object...) - Method in class org.apache.qpid.protonj2.logging.NoOpProtonLogger
 
error(String, Object...) - Method in interface org.apache.qpid.protonj2.logging.ProtonLogger
 
error(String, Object...) - Method in class org.apache.qpid.protonj2.logging.Slf4JLoggerWrapper
 
error(String, Object, Object) - Method in class org.apache.qpid.protonj2.logging.NoOpProtonLogger
 
error(String, Object, Object) - Method in interface org.apache.qpid.protonj2.logging.ProtonLogger
 
error(String, Object, Object) - Method in class org.apache.qpid.protonj2.logging.Slf4JLoggerWrapper
 
ErrorCondition - Class in org.apache.qpid.protonj2.types.transport
 
ErrorCondition - Interface in org.apache.qpid.protonj2.client
Conveys the error value used to inform the user of why an endpoint was closed or a delivery rejected.
ErrorCondition(String, String) - Constructor for class org.apache.qpid.protonj2.types.transport.ErrorCondition
 
ErrorCondition(Symbol, String) - Constructor for class org.apache.qpid.protonj2.types.transport.ErrorCondition
 
ErrorCondition(Symbol, String, Map<Symbol, Object>) - Constructor for class org.apache.qpid.protonj2.types.transport.ErrorCondition
 
ErrorConditionTypeDecoder - Class in org.apache.qpid.protonj2.codec.decoders.transport
Decoder of AMQP ErrorCondition type values from a byte stream.
ErrorConditionTypeDecoder() - Constructor for class org.apache.qpid.protonj2.codec.decoders.transport.ErrorConditionTypeDecoder
 
ErrorConditionTypeEncoder - Class in org.apache.qpid.protonj2.codec.encoders.transport
Encoder of AMQP ErrorCondition type values to a byte stream
ErrorConditionTypeEncoder() - Constructor for class org.apache.qpid.protonj2.codec.encoders.transport.ErrorConditionTypeEncoder
 
errorHandler(EventHandler<Engine>) - Method in interface org.apache.qpid.protonj2.engine.Engine
Sets a handler instance that will be notified when the engine encounters a fatal error.
errorHandler(EventHandler<Engine>) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEngine
 
EventHandler<E> - Interface in org.apache.qpid.protonj2.engine
Handler of events from the proton resources.
eventLoop() - Method in class org.apache.qpid.protonj2.client.transport.NettyIOContext
 
exceptionCaught(ChannelHandlerContext, Throwable) - Method in class org.apache.qpid.protonj2.client.transport.TcpTransport.NettyDefaultHandler
 
expiryPolicy() - Method in interface org.apache.qpid.protonj2.client.Source
 
expiryPolicy() - Method in interface org.apache.qpid.protonj2.client.Target
 
expiryPolicy() - Method in class org.apache.qpid.protonj2.client.TerminusOptions
 
expiryPolicy(ExpiryPolicy) - Method in class org.apache.qpid.protonj2.client.TerminusOptions
 
ExpiryPolicy - Enum in org.apache.qpid.protonj2.client
Control when the clock for expiration begins.
export(SplayMap.SplayedEntry<E>) - Method in class org.apache.qpid.protonj2.engine.util.SplayMap
 
EXTERNAL - org.apache.qpid.protonj2.engine.sasl.client.SaslMechanisms
 
EXTERNAL - Static variable in class org.apache.qpid.protonj2.engine.sasl.client.ExternalMechanism
A singleton instance of the symbolic mechanism name.
ExternalMechanism - Class in org.apache.qpid.protonj2.engine.sasl.client
Implements the External SASL authentication mechanism.
ExternalMechanism() - Constructor for class org.apache.qpid.protonj2.engine.sasl.client.ExternalMechanism
 

F

failed(ClientException) - Method in interface org.apache.qpid.protonj2.client.futures.AsyncResult
If the operation fails this method is invoked with the Exception that caused the failure.
failed(ClientException) - Method in class org.apache.qpid.protonj2.client.futures.ClientFuture
 
failed(ClientException) - Method in class org.apache.qpid.protonj2.client.futures.NoOpAsyncResult
 
failed(ClientException) - Method in class org.apache.qpid.protonj2.client.impl.ClientOutgoingEnvelope
 
FAILED - org.apache.qpid.protonj2.engine.EngineState
The engine has encountered an error and is no longer usable.
FAILURE - Static variable in class org.apache.qpid.protonj2.client.futures.ClientFuture
 
failureCause - Variable in class org.apache.qpid.protonj2.client.transport.TcpTransport
 
failureCause() - Method in class org.apache.qpid.protonj2.client.DisconnectionEvent
Gets the failure cause that is associated with this event if the event indicates an error stage in the Connection life-cycle such as a connection being interrupted which might later be recovered or a failure to establish or reconnect a previously established Connection.
failureCause() - Method in interface org.apache.qpid.protonj2.engine.Engine
 
failureCause() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEngine
 
FifoDeliveryQueue - Class in org.apache.qpid.protonj2.client.util
Simple first in / first out Delivery Queue.
FifoDeliveryQueue(int) - Constructor for class org.apache.qpid.protonj2.client.util.FifoDeliveryQueue
Creates a new first in / first out message queue with the given queue depth
filters() - Method in interface org.apache.qpid.protonj2.client.Source
 
filters() - Method in class org.apache.qpid.protonj2.client.SourceOptions
 
filters(Map<String, String>) - Method in class org.apache.qpid.protonj2.client.SourceOptions
 
find(String) - Method in interface org.apache.qpid.protonj2.engine.EnginePipeline
Finds and returns first handler that is found in the pipeline that matches the given name.
find(String) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEnginePipeline
 
find(String) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEnginePipelineProxy
 
findLoggerFactory() - Static method in class org.apache.qpid.protonj2.logging.Slf4JLoggerFactory
Static factory method that will create the correct Slf4j logging factory and return it or throw an NoClassDefFoundError if none found.
fireEngineStarting() - Method in interface org.apache.qpid.protonj2.engine.EngineHandlerContext
Fires the engine starting event into the next handler in the EnginePipeline chain.
fireEngineStarting() - Method in interface org.apache.qpid.protonj2.engine.EnginePipeline
Fires an engine starting event to each handler in the pipeline.
fireEngineStarting() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEngineHandlerContext
 
fireEngineStarting() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEnginePipeline
 
fireEngineStarting() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEnginePipelineProxy
 
fireEngineStateChanged() - Method in interface org.apache.qpid.protonj2.engine.EngineHandlerContext
Fires the engine state changed event into the next handler in the EnginePipeline chain.
fireEngineStateChanged() - Method in interface org.apache.qpid.protonj2.engine.EnginePipeline
Fires an engine state changed event to each handler in the pipeline.
fireEngineStateChanged() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEngineHandlerContext
 
fireEngineStateChanged() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEnginePipeline
 
fireEngineStateChanged() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEnginePipelineProxy
 
fireFailed(EngineFailedException) - Method in interface org.apache.qpid.protonj2.engine.EngineHandlerContext
Fires the Engine failed event into the next handler in the EnginePipeline chain.
fireFailed(EngineFailedException) - Method in interface org.apache.qpid.protonj2.engine.EnginePipeline
Fires an engine failed event into each EngineHandler in the pipeline indicating that the engine is now failed and should not accept or produce new work.
fireFailed(EngineFailedException) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEngineHandlerContext
 
fireFailed(EngineFailedException) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEnginePipeline
 
fireFailed(EngineFailedException) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEnginePipelineProxy
 
fireRead(ProtonBuffer) - Method in interface org.apache.qpid.protonj2.engine.EngineHandlerContext
Fires a read of ProtonBuffer events into the previous handler in the EnginePipeline for further processing.
fireRead(ProtonBuffer) - Method in interface org.apache.qpid.protonj2.engine.EnginePipeline
Fires a read event consisting of the given ProtonBuffer into the pipeline starting from the last EngineHandler in the pipeline and moving through each until the incoming work is fully processed.
fireRead(ProtonBuffer) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEngineHandlerContext
 
fireRead(ProtonBuffer) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEnginePipeline
 
fireRead(ProtonBuffer) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEnginePipelineProxy
 
fireRead(HeaderEnvelope) - Method in interface org.apache.qpid.protonj2.engine.EngineHandlerContext
Fires a read of HeaderFrame events into the previous handler in the EnginePipeline for further processing.
fireRead(HeaderEnvelope) - Method in interface org.apache.qpid.protonj2.engine.EnginePipeline
Fires a read event consisting of the given HeaderEnvelope into the pipeline starting from the last EngineHandler in the pipeline and moving through each until the incoming work is fully processed.
fireRead(HeaderEnvelope) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEngineHandlerContext
 
fireRead(HeaderEnvelope) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEnginePipeline
 
fireRead(HeaderEnvelope) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEnginePipelineProxy
 
fireRead(IncomingAMQPEnvelope) - Method in interface org.apache.qpid.protonj2.engine.EngineHandlerContext
Fires a read of IncomingProtocolFrame events into the previous handler in the EnginePipeline for further processing.
fireRead(IncomingAMQPEnvelope) - Method in interface org.apache.qpid.protonj2.engine.EnginePipeline
Fires a read event consisting of the given IncomingAMQPEnvelope into the pipeline starting from the last EngineHandler in the pipeline and moving through each until the incoming work is fully processed.
fireRead(IncomingAMQPEnvelope) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEngineHandlerContext
 
fireRead(IncomingAMQPEnvelope) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEnginePipeline
 
fireRead(IncomingAMQPEnvelope) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEnginePipelineProxy
 
fireRead(SASLEnvelope) - Method in interface org.apache.qpid.protonj2.engine.EngineHandlerContext
Fires a read of SASL events into the previous handler in the EnginePipeline for further processing.
fireRead(SASLEnvelope) - Method in interface org.apache.qpid.protonj2.engine.EnginePipeline
Fires a read event consisting of the given SASLEnvelope into the pipeline starting from the last EngineHandler in the pipeline and moving through each until the incoming work is fully processed.
fireRead(SASLEnvelope) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEngineHandlerContext
 
fireRead(SASLEnvelope) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEnginePipeline
 
fireRead(SASLEnvelope) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEnginePipelineProxy
 
fireWrite(ProtonBuffer, Runnable) - Method in interface org.apache.qpid.protonj2.engine.EngineHandlerContext
Fires a write of ProtonBuffer events into the next handler in the EnginePipeline for further processing.
fireWrite(ProtonBuffer, Runnable) - Method in interface org.apache.qpid.protonj2.engine.EnginePipeline
Fires a write event consisting of the given ProtonBuffer into the pipeline starting from the first EngineHandler in the pipeline and moving through each until the outgoing work is fully processed.
fireWrite(ProtonBuffer, Runnable) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEngineHandlerContext
 
fireWrite(ProtonBuffer, Runnable) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEnginePipeline
 
fireWrite(ProtonBuffer, Runnable) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEnginePipelineProxy
 
fireWrite(HeaderEnvelope) - Method in interface org.apache.qpid.protonj2.engine.EngineHandlerContext
Fires a write of HeaderFrame events into the next handler in the EnginePipeline for further processing.
fireWrite(HeaderEnvelope) - Method in interface org.apache.qpid.protonj2.engine.EnginePipeline
Fires a write event consisting of the given HeaderEnvelope into the pipeline starting from the first EngineHandler in the pipeline and moving through each until the outgoing work is fully processed.
fireWrite(HeaderEnvelope) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEngineHandlerContext
 
fireWrite(HeaderEnvelope) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEnginePipeline
 
fireWrite(HeaderEnvelope) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEnginePipelineProxy
 
fireWrite(OutgoingAMQPEnvelope) - Method in interface org.apache.qpid.protonj2.engine.EngineHandlerContext
Fires a write of OutgoingAMQPEnvelope events into the next handler in the EnginePipeline for further processing.
fireWrite(OutgoingAMQPEnvelope) - Method in interface org.apache.qpid.protonj2.engine.EnginePipeline
Fires a write event consisting of the given OutgoingAMQPEnvelope into the pipeline starting from the first EngineHandler in the pipeline and moving through each until the outgoing work is fully processed.
fireWrite(OutgoingAMQPEnvelope) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEngineHandlerContext
 
fireWrite(OutgoingAMQPEnvelope) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEnginePipeline
 
fireWrite(OutgoingAMQPEnvelope) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEnginePipelineProxy
 
fireWrite(SASLEnvelope) - Method in interface org.apache.qpid.protonj2.engine.EngineHandlerContext
Fires a write of SASLEnvelope events into the next handler in the EnginePipeline for further processing.
fireWrite(SASLEnvelope) - Method in interface org.apache.qpid.protonj2.engine.EnginePipeline
Fires a write event consisting of the given SASLEnvelope into the pipeline starting from the first EngineHandler in the pipeline and moving through each until the outgoing work is fully processed.
fireWrite(SASLEnvelope) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEngineHandlerContext
 
fireWrite(SASLEnvelope) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEnginePipeline
 
fireWrite(SASLEnvelope) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEnginePipelineProxy
 
first() - Method in interface org.apache.qpid.protonj2.engine.EnginePipeline
 
first() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEnginePipeline
 
first() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEnginePipelineProxy
 
FIRST - org.apache.qpid.protonj2.types.transport.ReceiverSettleMode
 
firstAcquirer() - Method in class org.apache.qpid.protonj2.client.impl.ClientMessage
 
firstAcquirer() - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiverMessage
 
firstAcquirer() - Method in interface org.apache.qpid.protonj2.client.Message
 
firstAcquirer(boolean) - Method in class org.apache.qpid.protonj2.client.impl.ClientMessage
 
firstAcquirer(boolean) - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiverMessage
 
firstAcquirer(boolean) - Method in interface org.apache.qpid.protonj2.client.Message
Sets the value to assign to the first acquirer field of this Message.
firstContext() - Method in interface org.apache.qpid.protonj2.engine.EnginePipeline
 
firstContext() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEnginePipeline
 
firstContext() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEnginePipelineProxy
 
firstEntry() - Method in class org.apache.qpid.protonj2.engine.util.SplayMap
 
firstKey() - Method in class org.apache.qpid.protonj2.engine.util.SplayMap
 
FLOAT - Static variable in interface org.apache.qpid.protonj2.codec.EncodingCodes
 
FloatTypeDecoder - Class in org.apache.qpid.protonj2.codec.decoders.primitives
Decoder of AMQP Float values from a byte stream.
FloatTypeDecoder() - Constructor for class org.apache.qpid.protonj2.codec.decoders.primitives.FloatTypeDecoder
 
FloatTypeEncoder - Class in org.apache.qpid.protonj2.codec.encoders.primitives
Encoder of AMQP Float type values to a byte stream.
FloatTypeEncoder() - Constructor for class org.apache.qpid.protonj2.codec.encoders.primitives.FloatTypeEncoder
 
floatValue() - Method in class org.apache.qpid.protonj2.engine.util.DeliveryIdTracker
 
floatValue() - Method in class org.apache.qpid.protonj2.engine.util.SequenceNumber
 
floatValue() - Method in class org.apache.qpid.protonj2.types.Decimal128
 
floatValue() - Method in class org.apache.qpid.protonj2.types.Decimal32
 
floatValue() - Method in class org.apache.qpid.protonj2.types.Decimal64
 
floatValue() - Method in class org.apache.qpid.protonj2.types.UnsignedByte
 
floatValue() - Method in class org.apache.qpid.protonj2.types.UnsignedInteger
 
floatValue() - Method in class org.apache.qpid.protonj2.types.UnsignedLong
 
floatValue() - Method in class org.apache.qpid.protonj2.types.UnsignedShort
 
floorEntry(UnsignedInteger) - Method in class org.apache.qpid.protonj2.engine.util.SplayMap
 
floorKey(UnsignedInteger) - Method in class org.apache.qpid.protonj2.engine.util.SplayMap
 
Flow - Class in org.apache.qpid.protonj2.types.transport
 
Flow() - Constructor for class org.apache.qpid.protonj2.types.transport.Flow
 
FLOW - org.apache.qpid.protonj2.types.transport.Performative.PerformativeType
 
FlowTypeDecoder - Class in org.apache.qpid.protonj2.codec.decoders.transport
Decoder of AMQP Flow type values from a byte stream.
FlowTypeDecoder() - Constructor for class org.apache.qpid.protonj2.codec.decoders.transport.FlowTypeDecoder
 
FlowTypeEncoder - Class in org.apache.qpid.protonj2.codec.encoders.transport
Encoder of AMQP Flow type values to a byte stream.
FlowTypeEncoder() - Constructor for class org.apache.qpid.protonj2.codec.encoders.transport.FlowTypeEncoder
 
flush() - Method in class org.apache.qpid.protonj2.client.transport.TcpTransport
 
flush() - Method in interface org.apache.qpid.protonj2.client.transport.Transport
Request a flush of all pending writes to the underlying connection.
footer() - Method in interface org.apache.qpid.protonj2.client.AdvancedMessage
Return the current Footer assigned to this message, if none was assigned yet then this method returns null.
footer() - Method in class org.apache.qpid.protonj2.client.impl.ClientMessage
 
footer() - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiverMessage
 
footer(String) - Method in class org.apache.qpid.protonj2.client.impl.ClientMessage
 
footer(String) - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiverMessage
 
footer(String) - Method in interface org.apache.qpid.protonj2.client.Message
Returns the requested footer value from this Message if it exists or returns null otherwise.
footer(String, Object) - Method in class org.apache.qpid.protonj2.client.impl.ClientMessage
 
footer(String, Object) - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiverMessage
 
footer(String, Object) - Method in interface org.apache.qpid.protonj2.client.Message
Sets the given footer value at the given key, replacing any previous value that was assigned to this Message.
footer(Footer) - Method in interface org.apache.qpid.protonj2.client.AdvancedMessage
Assign or replace the Footer instance associated with this message.
footer(Footer) - Method in class org.apache.qpid.protonj2.client.impl.ClientMessage
 
footer(Footer) - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiverMessage
 
Footer - Class in org.apache.qpid.protonj2.types.messaging
 
Footer - org.apache.qpid.protonj2.types.messaging.Section.SectionType
 
Footer(Map<Symbol, ?>) - Constructor for class org.apache.qpid.protonj2.types.messaging.Footer
 
FooterTypeDecoder - Class in org.apache.qpid.protonj2.codec.decoders.messaging
Decoder of AMQP Footer type values from a byte stream.
FooterTypeDecoder() - Constructor for class org.apache.qpid.protonj2.codec.decoders.messaging.FooterTypeDecoder
 
FooterTypeEncoder - Class in org.apache.qpid.protonj2.codec.encoders.messaging
Encoder of AMQP Footer type values to a byte stream
FooterTypeEncoder() - Constructor for class org.apache.qpid.protonj2.codec.encoders.messaging.FooterTypeEncoder
 
forEach(BiConsumer<? super UnsignedInteger, ? super E>) - Method in class org.apache.qpid.protonj2.engine.util.LinkedSplayMap
 
forEach(BiConsumer<? super UnsignedInteger, ? super E>) - Method in class org.apache.qpid.protonj2.engine.util.SplayMap
 
forEach(Consumer<? super E>) - Method in class org.apache.qpid.protonj2.engine.util.LinkedSplayMap
 
forEach(Consumer<? super E>) - Method in class org.apache.qpid.protonj2.engine.util.SplayMap
A specialized forEach implementation that accepts a Consumer function that will be called for each value in the SplayMap.
forEachAnnotation(BiConsumer<String, Object>) - Method in class org.apache.qpid.protonj2.client.impl.ClientMessage
 
forEachAnnotation(BiConsumer<String, Object>) - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiverMessage
 
forEachAnnotation(BiConsumer<String, Object>) - Method in interface org.apache.qpid.protonj2.client.Message
Invokes the given BiConsumer on each message annotation entry carried in this Message.
forEachBodySection(Consumer<Section<?>>) - Method in interface org.apache.qpid.protonj2.client.AdvancedMessage
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.
forEachBodySection(Consumer<Section<?>>) - Method in class org.apache.qpid.protonj2.client.impl.ClientMessage
 
forEachBodySection(Consumer<Section<?>>) - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiverMessage
 
foreachBuffer(Consumer<ProtonBuffer>) - Method in class org.apache.qpid.protonj2.buffer.ProtonCompositeBuffer
For each of the buffers contained in this ProtonCompositeBuffer instance the given consumer will be invoked with a duplicate of the buffer that can be independently modified and not affect the contents of this buffer.
forEachFooter(BiConsumer<String, Object>) - Method in class org.apache.qpid.protonj2.client.impl.ClientMessage
 
forEachFooter(BiConsumer<String, Object>) - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiverMessage
 
forEachFooter(BiConsumer<String, Object>) - Method in interface org.apache.qpid.protonj2.client.Message
Invokes the given BiConsumer on each footer entry carried in this Message.
foreachInternalBuffer(Consumer<ProtonBuffer>) - Method in class org.apache.qpid.protonj2.buffer.ProtonCompositeBuffer
For each of the buffers contained in this ProtonCompositeBuffer instance the given consumer will be invoked with the ProtonBuffer that backs this composite instance.
forEachProperty(BiConsumer<String, Object>) - Method in class org.apache.qpid.protonj2.client.impl.ClientMessage
 
forEachProperty(BiConsumer<String, Object>) - Method in class org.apache.qpid.protonj2.client.impl.ClientStreamReceiverMessage
 
forEachProperty(BiConsumer<String, Object>) - Method in interface org.apache.qpid.protonj2.client.Message
Invokes the given BiConsumer on each application property entry carried in this Message.
FRAME_DECODING_HANDLER - Static variable in class org.apache.qpid.protonj2.engine.impl.ProtonConstants
Engine handler that decodes performatives and forwards the frames
FRAME_ENCODING_HANDLER - Static variable in class org.apache.qpid.protonj2.engine.impl.ProtonConstants
Engine handler that encodes performatives and writes the resulting buffer
FRAME_LOGGING_HANDLER - Static variable in class org.apache.qpid.protonj2.engine.impl.ProtonConstants
Engine handler that logs incoming and outgoing performatives and frames
FRAME_SIZE_BYTES - Static variable in class org.apache.qpid.protonj2.engine.impl.ProtonFrameDecodingHandler
The specified encoding size for the frame size value of each encoded frame.
FRAME_SIZE_TOO_SMALL - Static variable in interface org.apache.qpid.protonj2.types.transport.AmqpError
The peer cannot send a frame because the smallest encoding of the performative with the currently valid values would be too large to fit within a frame of the agreed maximum frame size.
FrameDecodingException - Exception in org.apache.qpid.protonj2.engine.exceptions
Exception thrown when the engine cannot decode an incoming frame due to some error either with the encoding itself or the contents which cause a specification violation.
FrameDecodingException() - Constructor for exception org.apache.qpid.protonj2.engine.exceptions.FrameDecodingException
 
FrameDecodingException(String) - Constructor for exception org.apache.qpid.protonj2.engine.exceptions.FrameDecodingException
 
FrameDecodingException(String, Throwable) - Constructor for exception org.apache.qpid.protonj2.engine.exceptions.FrameDecodingException
 
FrameDecodingException(Throwable) - Constructor for exception org.apache.qpid.protonj2.engine.exceptions.FrameDecodingException
 
FrameEncodingException - Exception in org.apache.qpid.protonj2.engine.exceptions
Exception thrown when the engine cannot encode a frame from a given performative and or payload combination.
FrameEncodingException() - Constructor for exception org.apache.qpid.protonj2.engine.exceptions.FrameEncodingException
 
FrameEncodingException(String) - Constructor for exception org.apache.qpid.protonj2.engine.exceptions.FrameEncodingException
 
FrameEncodingException(String, Throwable) - Constructor for exception org.apache.qpid.protonj2.engine.exceptions.FrameEncodingException
 
FrameEncodingException(Throwable) - Constructor for exception org.apache.qpid.protonj2.engine.exceptions.FrameEncodingException
 
FRAMING_ERROR - Static variable in interface org.apache.qpid.protonj2.types.transport.ConnectionError
A valid frame header cannot be formed from the incoming byte stream.
futureType() - Method in class org.apache.qpid.protonj2.client.ClientOptions
 
futureType(String) - Method in class org.apache.qpid.protonj2.client.ClientOptions
Sets the desired future type that the client connection should use when creating the futures used by the API.

G

generateId() - Method in class org.apache.qpid.protonj2.client.util.IdGenerator
Generate a unique id using the configured characteristics.
get() - Method in class org.apache.qpid.protonj2.client.futures.BalancedClientFuture
 
get() - Method in class org.apache.qpid.protonj2.client.futures.ClientFuture
 
get() - Method in class org.apache.qpid.protonj2.client.futures.ConservativeClientFuture
 
get() - Method in class org.apache.qpid.protonj2.client.futures.ProgressiveClientFuture
 
get(int) - Method in class org.apache.qpid.protonj2.engine.util.SplayMap
Gets the value of the element stored in the Map with the key (treated as an unsigned integer for comparison.
get(long, TimeUnit) - Method in class org.apache.qpid.protonj2.client.futures.BalancedClientFuture
 
get(long, TimeUnit) - Method in class org.apache.qpid.protonj2.client.futures.ClientFuture
 
get(long, TimeUnit) - Method in class org.apache.qpid.protonj2.client.futures.ConservativeClientFuture
 
get(long, TimeUnit) - Method in class org.apache.qpid.protonj2.client.futures.ProgressiveClientFuture
 
get(Object) - Method in class org.apache.qpid.protonj2.engine.util.SplayMap
 
get(String) - Method in interface org.apache.qpid.protonj2.engine.Attachments
Gets the user attached value that is associated with the given key, or null if no data is mapped to the key.
get(String) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonAttachments
 
get(String, Class<T>) - Method in interface org.apache.qpid.protonj2.engine.Attachments
Gets the user set Attachments value that is associated with the given key, or null if no data is mapped to the key.
get(String, Class<T>) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonAttachments
 
getAborted() - Method in class org.apache.qpid.protonj2.types.transport.Transfer
 
getAbsoluteExpiryTime() - Method in class org.apache.qpid.protonj2.types.messaging.Properties
 
getAdditionalData() - Method in class org.apache.qpid.protonj2.types.security.SaslOutcome
 
getAddress() - Method in exception org.apache.qpid.protonj2.client.exceptions.ClientLinkRedirectedException
The address value that should be used when connecting to the provided host and port and creating a new link instance as directed.
getAddress() - Method in class org.apache.qpid.protonj2.client.impl.ClientRedirect
 
getAddress() - Method in class org.apache.qpid.protonj2.types.messaging.Source
 
getAddress() - Method in class org.apache.qpid.protonj2.types.messaging.Target
 
getAllowedMechanisms() - Method in class org.apache.qpid.protonj2.engine.sasl.client.SaslMechanismSelector
 
getAMQPHeader() - Static method in class org.apache.qpid.protonj2.types.transport.AMQPHeader
 
getAndDecrement() - Method in class org.apache.qpid.protonj2.engine.util.SequenceNumber
Subtract one to the sequence value.
getAndIncrement() - Method in class org.apache.qpid.protonj2.engine.util.SequenceNumber
Add one to the sequence value.
getArray() - Method in interface org.apache.qpid.protonj2.buffer.ProtonBuffer
Returns the backing array for this ProtonBuffer instance if there is such an array or throws an exception if this ProtonBuffer implementation has no backing array.
getArray() - Method in class org.apache.qpid.protonj2.buffer.ProtonByteBuffer
 
getArray() - Method in class org.apache.qpid.protonj2.buffer.ProtonCompositeBuffer
 
getArray() - Method in class org.apache.qpid.protonj2.buffer.ProtonDuplicatedBuffer
 
getArray() - Method in class org.apache.qpid.protonj2.buffer.ProtonNettyByteBuffer
 
getArray() - Method in class org.apache.qpid.protonj2.buffer.ProtonNioByteBuffer
 
getArray() - Method in class org.apache.qpid.protonj2.buffer.ProtonSlicedBuffer
 
getArray() - Method in class org.apache.qpid.protonj2.types.Binary
 
getArrayOffset() - Method in interface org.apache.qpid.protonj2.buffer.ProtonBuffer
 
getArrayOffset() - Method in class org.apache.qpid.protonj2.buffer.ProtonByteBuffer
 
getArrayOffset() - Method in class org.apache.qpid.protonj2.buffer.ProtonCompositeBuffer
 
getArrayOffset() - Method in class org.apache.qpid.protonj2.buffer.ProtonDuplicatedBuffer
 
getArrayOffset() - Method in class org.apache.qpid.protonj2.buffer.ProtonNettyByteBuffer
 
getArrayOffset() - Method in class org.apache.qpid.protonj2.buffer.ProtonNioByteBuffer
 
getArrayOffset() - Method in class org.apache.qpid.protonj2.buffer.ProtonSlicedBuffer
 
getArrayOffset() - Method in class org.apache.qpid.protonj2.types.Binary
 
getAttachments() - Method in interface org.apache.qpid.protonj2.engine.Endpoint
 
getAttachments() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEndpoint
 
getAttachments() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonIncomingDelivery
 
getAttachments() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonOutgoingDelivery
 
getAttachments() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonTransaction
 
getAttachments() - Method in interface org.apache.qpid.protonj2.engine.IncomingDelivery
 
getAttachments() - Method in interface org.apache.qpid.protonj2.engine.OutgoingDelivery
 
getAttachments() - Method in interface org.apache.qpid.protonj2.engine.sasl.SaslContext
Returns a mutable context that the application layer can use to store meaningful data for itself in relation to this specific SASL context object.
getAttachments() - Method in interface org.apache.qpid.protonj2.engine.Transaction
 
getAvailable() - Method in class org.apache.qpid.protonj2.types.transport.Flow
 
getBatchable() - Method in class org.apache.qpid.protonj2.types.transport.Disposition
 
getBatchable() - Method in class org.apache.qpid.protonj2.types.transport.Transfer
 
getBinary() - Method in class org.apache.qpid.protonj2.types.messaging.Data
 
getBits() - Method in class org.apache.qpid.protonj2.types.Decimal32
 
getBits() - Method in class org.apache.qpid.protonj2.types.Decimal64
 
getBody() - Method in class org.apache.qpid.protonj2.engine.PerformativeEnvelope
 
getBoolean(int) - Method in class org.apache.qpid.protonj2.buffer.ProtonAbstractBuffer
 
getBoolean(int) - Method in interface org.apache.qpid.protonj2.buffer.ProtonBuffer
Gets a boolean from the specified index, this method will not modify the read or write index.
getBoolean(int) - Method in class org.apache.qpid.protonj2.buffer.ProtonNettyByteBuffer
 
getBoolean(int) - Method in class org.apache.qpid.protonj2.buffer.ProtonSlicedBuffer
 
getBuffer() - Method in class org.apache.qpid.protonj2.types.transport.AMQPHeader
 
getBufferAllocator() - Method in class org.apache.qpid.protonj2.client.transport.TcpTransport
 
getBufferAllocator() - Method in interface org.apache.qpid.protonj2.client.transport.Transport
Gets a buffer allocator that can produce ProtonBuffer instance that may be optimized for use with the underlying transport implementation.
getBufferAllocator() - Method in interface org.apache.qpid.protonj2.engine.EngineConfiguration
 
getBufferAllocator() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEngineConfiguration
 
getByte(int) - Method in interface org.apache.qpid.protonj2.buffer.ProtonBuffer
Gets a byte from the specified index, this method will not modify the read or write index.
getByte(int) - Method in class org.apache.qpid.protonj2.buffer.ProtonByteBuffer
 
getByte(int) - Method in class org.apache.qpid.protonj2.buffer.ProtonCompositeBuffer
 
getByte(int) - Method in class org.apache.qpid.protonj2.buffer.ProtonDuplicatedBuffer
 
getByte(int) - Method in class org.apache.qpid.protonj2.buffer.ProtonNettyByteBuffer
 
getByte(int) - Method in class org.apache.qpid.protonj2.buffer.ProtonNioByteBuffer
 
getByte(int) - Method in class org.apache.qpid.protonj2.buffer.ProtonSlicedBuffer
 
getByteAt(int) - Method in class org.apache.qpid.protonj2.types.transport.AMQPHeader
 
getBytes(int, byte[]) - Method in class org.apache.qpid.protonj2.buffer.ProtonAbstractBuffer
 
getBytes(int, byte[]) - Method in interface org.apache.qpid.protonj2.buffer.ProtonBuffer
Transfers this buffer's data to the specified destination starting at the specified absolute index.
getBytes(int, byte[]) - Method in class org.apache.qpid.protonj2.buffer.ProtonNettyByteBuffer
 
getBytes(int, byte[]) - Method in class org.apache.qpid.protonj2.buffer.ProtonSlicedBuffer
 
getBytes(int, byte[], int, int) - Method in interface org.apache.qpid.protonj2.buffer.ProtonBuffer
Transfers this buffer's data to the specified destination starting at the specified absolute index.
getBytes(int, byte[], int, int) - Method in class org.apache.qpid.protonj2.buffer.ProtonByteBuffer
 
getBytes(int, byte[], int, int) - Method in class org.apache.qpid.protonj2.buffer.ProtonCompositeBuffer
 
getBytes(int, byte[], int, int) - Method in class org.apache.qpid.protonj2.buffer.ProtonDuplicatedBuffer
 
getBytes(int, byte[], int, int) - Method in class org.apache.qpid.protonj2.buffer.ProtonNettyByteBuffer
 
getBytes(int, byte[], int, int) - Method in class org.apache.qpid.protonj2.buffer.ProtonNioByteBuffer
 
getBytes(int, byte[], int, int) - Method in class org.apache.qpid.protonj2.buffer.ProtonSlicedBuffer
 
getBytes(int, ByteBuffer) - Method in interface org.apache.qpid.protonj2.buffer.ProtonBuffer
Transfers this buffer's data to the specified destination starting at the specified absolute index until the destination's position reaches its limit.
getBytes(int, ByteBuffer) - Method in class org.apache.qpid.protonj2.buffer.ProtonByteBuffer
 
getBytes(int, ByteBuffer) - Method in class org.apache.qpid.protonj2.buffer.ProtonCompositeBuffer
 
getBytes(int, ByteBuffer) - Method in class org.apache.qpid.protonj2.buffer.ProtonDuplicatedBuffer
 
getBytes(int, ByteBuffer) - Method in class org.apache.qpid.protonj2.buffer.ProtonNettyByteBuffer
 
getBytes(int, ByteBuffer) - Method in class org.apache.qpid.protonj2.buffer.ProtonNioByteBuffer
 
getBytes(int, ByteBuffer) - Method in class org.apache.qpid.protonj2.buffer.ProtonSlicedBuffer
 
getBytes(int, ProtonBuffer) - Method in class org.apache.qpid.protonj2.buffer.ProtonAbstractBuffer
 
getBytes(int, ProtonBuffer) - Method in interface org.apache.qpid.protonj2.buffer.ProtonBuffer
Transfers this buffer's data to the specified destination starting at the specified absolute index until the destination becomes non-writable.
getBytes(int, ProtonBuffer) - Method in class org.apache.qpid.protonj2.buffer.ProtonNettyByteBuffer
 
getBytes(int, ProtonBuffer) - Method in class org.apache.qpid.protonj2.buffer.ProtonSlicedBuffer
 
getBytes(int, ProtonBuffer, int) - Method in class org.apache.qpid.protonj2.buffer.ProtonAbstractBuffer
 
getBytes(int, ProtonBuffer, int) - Method in interface org.apache.qpid.protonj2.buffer.ProtonBuffer
Transfers this buffer's data to the specified destination starting at the specified absolute index.
getBytes(int, ProtonBuffer, int) - Method in class org.apache.qpid.protonj2.buffer.ProtonNettyByteBuffer
 
getBytes(int, ProtonBuffer, int) - Method in class org.apache.qpid.protonj2.buffer.ProtonSlicedBuffer
 
getBytes(int, ProtonBuffer, int, int) - Method in interface org.apache.qpid.protonj2.buffer.ProtonBuffer
Transfers this buffer's data to the specified destination starting at the specified absolute index.
getBytes(int, ProtonBuffer, int, int) - Method in class org.apache.qpid.protonj2.buffer.ProtonByteBuffer
 
getBytes(int, ProtonBuffer, int, int) - Method in class org.apache.qpid.protonj2.buffer.ProtonCompositeBuffer
 
getBytes(int, ProtonBuffer, int, int) - Method in class org.apache.qpid.protonj2.buffer.ProtonDuplicatedBuffer
 
getBytes(int, ProtonBuffer, int, int) - Method in class org.apache.qpid.protonj2.buffer.ProtonNettyByteBuffer
 
getBytes(int, ProtonBuffer, int, int) - Method in class org.apache.qpid.protonj2.buffer.ProtonNioByteBuffer
 
getBytes(int, ProtonBuffer, int, int) - Method in class org.apache.qpid.protonj2.buffer.ProtonSlicedBuffer
 
getBytesRead() - Method in class org.apache.qpid.protonj2.buffer.ProtonBufferInputStream
 
getBytesWritten() - Method in class org.apache.qpid.protonj2.buffer.ProtonBufferOutputStream
 
getCachedDecoderState() - Method in interface org.apache.qpid.protonj2.codec.Decoder
Return a singleton DecoderState instance that is meant to be shared within single threaded decoder interactions.
getCachedDecoderState() - Method in class org.apache.qpid.protonj2.codec.decoders.ProtonDecoder
 
getCachedDecoderState() - Method in class org.apache.qpid.protonj2.codec.decoders.ProtonStreamDecoder
 
getCachedDecoderState() - Method in interface org.apache.qpid.protonj2.codec.StreamDecoder
Return a singleton StreamDecoderState instance that is meant to be shared within single threaded decoder interactions.
getCachedEncoderState() - Method in interface org.apache.qpid.protonj2.codec.Encoder
Return a singleton EncoderState instance that is meant to be shared within single threaded encoder interactions.
getCachedEncoderState() - Method in class org.apache.qpid.protonj2.codec.encoders.ProtonEncoder
 
getCapabilities() - Method in class org.apache.qpid.protonj2.types.messaging.Source
 
getCapabilities() - Method in class org.apache.qpid.protonj2.types.messaging.Target
 
getCapabilities() - Method in class org.apache.qpid.protonj2.types.transactions.Coordinator
 
getCertificateChain(String) - Method in class org.apache.qpid.protonj2.client.transport.X509AliasKeyManager
 
getChallenge() - Method in class org.apache.qpid.protonj2.types.security.SaslChallenge
 
getChallengeResponse(SaslCredentialsProvider, ProtonBuffer) - Method in class org.apache.qpid.protonj2.engine.sasl.client.AbstractMechanism
 
getChallengeResponse(SaslCredentialsProvider, ProtonBuffer) - Method in class org.apache.qpid.protonj2.engine.sasl.client.CramMD5Mechanism
 
getChallengeResponse(SaslCredentialsProvider, ProtonBuffer) - Method in interface org.apache.qpid.protonj2.engine.sasl.client.Mechanism
Create a response based on a given challenge from the remote peer.
getChallengeResponse(SaslCredentialsProvider, ProtonBuffer) - Method in class org.apache.qpid.protonj2.engine.sasl.client.XOauth2Mechanism
 
getChannel() - Method in class org.apache.qpid.protonj2.engine.PerformativeEnvelope
 
getChannelClass() - Static method in class org.apache.qpid.protonj2.client.transport.EpollSupport
 
getChannelClass() - Static method in class org.apache.qpid.protonj2.client.transport.IOUringSupport
 
getChannelClass() - Static method in class org.apache.qpid.protonj2.client.transport.KQueueSupport
 
getChannelMax() - Method in interface org.apache.qpid.protonj2.engine.Connection
 
getChannelMax() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonConnection
 
getChannelMax() - Method in class org.apache.qpid.protonj2.types.transport.Open
 
getChar(int) - Method in class org.apache.qpid.protonj2.buffer.ProtonAbstractBuffer
 
getChar(int) - Method in interface org.apache.qpid.protonj2.buffer.ProtonBuffer
Gets a 2-byte char from the specified index, this method will not modify the read or write index.
getChar(int) - Method in class org.apache.qpid.protonj2.buffer.ProtonNettyByteBuffer
 
getChar(int) - Method in class org.apache.qpid.protonj2.buffer.ProtonSlicedBuffer
 
getChosenMechanism() - Method in interface org.apache.qpid.protonj2.engine.sasl.SaslContext
Returns the mechanism that was sent to the server to select the SASL mechanism to use for negotiations.
getClientAliases(String, Principal[]) - Method in class org.apache.qpid.protonj2.client.transport.X509AliasKeyManager
 
getClosed() - Method in class org.apache.qpid.protonj2.types.transport.Detach
 
getCode() - Method in class org.apache.qpid.protonj2.types.security.SaslOutcome
 
getCondition() - Method in interface org.apache.qpid.protonj2.engine.Endpoint
 
getCondition() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEndpoint
 
getCondition() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonTransaction
 
getCondition() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonTransactionController
 
getCondition() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonTransactionManager
 
getCondition() - Method in interface org.apache.qpid.protonj2.engine.Transaction
If the declare or discharge of the transaction caused its state to become TransactionState FAILED this method returns the ErrorCondition that the remote used to describe the reason for the failure.
getCondition() - Method in class org.apache.qpid.protonj2.types.transport.ErrorCondition
 
getConnection() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonLink
 
getConnection() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonSession
 
getConnection() - Method in interface org.apache.qpid.protonj2.engine.Link
 
getConnection() - Method in interface org.apache.qpid.protonj2.engine.Session
 
getContainerId() - Method in interface org.apache.qpid.protonj2.engine.Connection
 
getContainerId() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonConnection
 
getContainerId() - Method in class org.apache.qpid.protonj2.types.transport.Open
 
getContentEncoding() - Method in class org.apache.qpid.protonj2.types.messaging.Properties
 
getContentType() - Method in class org.apache.qpid.protonj2.types.messaging.Properties
 
getCoordinator() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonTransactionController
 
getCoordinator() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonTransactionManager
 
getCoordinator() - Method in interface org.apache.qpid.protonj2.engine.TransactionController
Returns the currently set Coordinator target for this Link.
getCoordinator() - Method in interface org.apache.qpid.protonj2.engine.TransactionManager
Returns the currently set Coordinator target for this Link.
getCorrelationId() - Method in class org.apache.qpid.protonj2.types.messaging.Properties
 
getCreationTime() - Method in class org.apache.qpid.protonj2.types.messaging.Properties
 
getCredit() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonLinkCreditState
 
getCredit() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonReceiver
 
getCredit() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonSender
 
getCredit() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonTransactionManager
 
getCredit() - Method in interface org.apache.qpid.protonj2.engine.Link
Get the credit that is currently available or assigned to this link.
getCredit() - Method in interface org.apache.qpid.protonj2.engine.LinkCreditState
The currently available credit for this link
getCredit() - Method in interface org.apache.qpid.protonj2.engine.TransactionManager
Get the credit that is currently available or assigned to this TransactionManager.
getDecoder() - Static method in class org.apache.qpid.protonj2.codec.CodecFactory
 
getDecoder() - Method in class org.apache.qpid.protonj2.codec.decoders.ProtonDecoderState
 
getDecoder() - Method in class org.apache.qpid.protonj2.codec.decoders.ProtonStreamDecoderState
 
getDecoder() - Method in interface org.apache.qpid.protonj2.codec.DecoderState
 
getDecoder() - Method in interface org.apache.qpid.protonj2.codec.StreamDecoderState
 
getDefaultDecoder() - Static method in class org.apache.qpid.protonj2.codec.CodecFactory
 
getDefaultDeliveryState() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonIncomingDelivery
 
getDefaultDeliveryState() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonReceiver
 
getDefaultDeliveryState() - Method in interface org.apache.qpid.protonj2.engine.IncomingDelivery
 
getDefaultDeliveryState() - Method in interface org.apache.qpid.protonj2.engine.Receiver
 
getDefaultEncoder() - Static method in class org.apache.qpid.protonj2.codec.CodecFactory
 
getDefaultOutcome() - Method in class org.apache.qpid.protonj2.types.messaging.Source
 
getDefaultSaslDecoder() - Static method in class org.apache.qpid.protonj2.codec.CodecFactory
 
getDefaultSaslEncoder() - Static method in class org.apache.qpid.protonj2.codec.CodecFactory
 
getDeliveryCount() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonLinkCreditState
 
getDeliveryCount() - Method in interface org.apache.qpid.protonj2.engine.LinkCreditState
The current delivery count value for this link
getDeliveryCount() - Method in class org.apache.qpid.protonj2.types.messaging.Header
 
getDeliveryCount() - Method in class org.apache.qpid.protonj2.types.transport.Flow
 
getDeliveryId() - Method in class org.apache.qpid.protonj2.types.transport.Transfer
 
getDeliveryTag() - Method in class org.apache.qpid.protonj2.types.transport.Transfer
 
getDeliveryTagGenerator() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonSender
 
getDeliveryTagGenerator() - Method in interface org.apache.qpid.protonj2.engine.Sender
 
getDescribed() - Method in interface org.apache.qpid.protonj2.types.DescribedType
Returns the described type value that is carried in this instance.
getDescribed() - Method in class org.apache.qpid.protonj2.types.UnknownDescribedType
 
getDescription() - Method in class org.apache.qpid.protonj2.types.transport.ErrorCondition
 
getDescriptor() - Method in class org.apache.qpid.protonj2.codec.decoders.UnknownDescribedTypeDecoder
 
getDescriptor() - Method in interface org.apache.qpid.protonj2.types.DescribedType
Returns the Described Type descriptor that identified this instance.
getDescriptor() - Method in class org.apache.qpid.protonj2.types.UnknownDescribedType
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.decoders.messaging.AcceptedTypeDecoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.decoders.messaging.AmqpSequenceTypeDecoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.decoders.messaging.AmqpValueTypeDecoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.decoders.messaging.ApplicationPropertiesTypeDecoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.decoders.messaging.DataTypeDecoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.decoders.messaging.DeleteOnCloseTypeDecoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.decoders.messaging.DeleteOnNoLinksOrMessagesTypeDecoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.decoders.messaging.DeleteOnNoLinksTypeDecoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.decoders.messaging.DeleteOnNoMessagesTypeDecoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.decoders.messaging.DeliveryAnnotationsTypeDecoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.decoders.messaging.FooterTypeDecoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.decoders.messaging.HeaderTypeDecoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.decoders.messaging.MessageAnnotationsTypeDecoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.decoders.messaging.ModifiedTypeDecoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.decoders.messaging.PropertiesTypeDecoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.decoders.messaging.ReceivedTypeDecoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.decoders.messaging.RejectedTypeDecoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.decoders.messaging.ReleasedTypeDecoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.decoders.messaging.SourceTypeDecoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.decoders.messaging.TargetTypeDecoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.decoders.security.SaslChallengeTypeDecoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.decoders.security.SaslInitTypeDecoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.decoders.security.SaslMechanismsTypeDecoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.decoders.security.SaslOutcomeTypeDecoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.decoders.security.SaslResponseTypeDecoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.decoders.transactions.CoordinatorTypeDecoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.decoders.transactions.DeclaredTypeDecoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.decoders.transactions.DeclareTypeDecoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.decoders.transactions.DischargeTypeDecoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.decoders.transactions.TransactionStateTypeDecoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.decoders.transport.AttachTypeDecoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.decoders.transport.BeginTypeDecoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.decoders.transport.CloseTypeDecoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.decoders.transport.DetachTypeDecoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.decoders.transport.DispositionTypeDecoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.decoders.transport.EndTypeDecoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.decoders.transport.ErrorConditionTypeDecoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.decoders.transport.FlowTypeDecoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.decoders.transport.OpenTypeDecoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.decoders.transport.TransferTypeDecoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.decoders.UnknownDescribedTypeDecoder
 
getDescriptorCode() - Method in interface org.apache.qpid.protonj2.codec.DescribedTypeDecoder
Returns the AMQP descriptor code for the type this decoder reads.
getDescriptorCode() - Method in interface org.apache.qpid.protonj2.codec.DescribedTypeEncoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.AcceptedTypeEncoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.AmqpSequenceTypeEncoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.AmqpValueTypeEncoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.ApplicationPropertiesTypeEncoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.DataTypeEncoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.DeleteOnCloseTypeEncoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.DeleteOnNoLinksOrMessagesTypeEncoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.DeleteOnNoLinksTypeEncoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.DeleteOnNoMessagesTypeEncoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.DeliveryAnnotationsTypeEncoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.FooterTypeEncoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.HeaderTypeEncoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.MessageAnnotationsTypeEncoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.ModifiedTypeEncoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.PropertiesTypeEncoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.ReceivedTypeEncoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.RejectedTypeEncoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.ReleasedTypeEncoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.SourceTypeEncoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.TargetTypeEncoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.encoders.security.SaslChallengeTypeEncoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.encoders.security.SaslInitTypeEncoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.encoders.security.SaslMechanismsTypeEncoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.encoders.security.SaslOutcomeTypeEncoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.encoders.security.SaslResponseTypeEncoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.encoders.transactions.CoordinatorTypeEncoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.encoders.transactions.DeclaredTypeEncoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.encoders.transactions.DeclareTypeEncoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.encoders.transactions.DischargeTypeEncoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.encoders.transactions.TransactionStateTypeEncoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.encoders.transport.AttachTypeEncoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.encoders.transport.BeginTypeEncoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.encoders.transport.CloseTypeEncoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.encoders.transport.DetachTypeEncoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.encoders.transport.DispositionTypeEncoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.encoders.transport.EndTypeEncoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.encoders.transport.ErrorConditionTypeEncoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.encoders.transport.FlowTypeEncoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.encoders.transport.OpenTypeEncoder
 
getDescriptorCode() - Method in class org.apache.qpid.protonj2.codec.encoders.transport.TransferTypeEncoder
 
getDescriptorCode() - Method in interface org.apache.qpid.protonj2.codec.StreamDescribedTypeDecoder
Returns the AMQP descriptor code for the type this decoder reads.
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.decoders.messaging.AcceptedTypeDecoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.decoders.messaging.AmqpSequenceTypeDecoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.decoders.messaging.AmqpValueTypeDecoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.decoders.messaging.ApplicationPropertiesTypeDecoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.decoders.messaging.DataTypeDecoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.decoders.messaging.DeleteOnCloseTypeDecoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.decoders.messaging.DeleteOnNoLinksOrMessagesTypeDecoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.decoders.messaging.DeleteOnNoLinksTypeDecoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.decoders.messaging.DeleteOnNoMessagesTypeDecoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.decoders.messaging.DeliveryAnnotationsTypeDecoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.decoders.messaging.FooterTypeDecoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.decoders.messaging.HeaderTypeDecoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.decoders.messaging.MessageAnnotationsTypeDecoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.decoders.messaging.ModifiedTypeDecoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.decoders.messaging.PropertiesTypeDecoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.decoders.messaging.ReceivedTypeDecoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.decoders.messaging.RejectedTypeDecoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.decoders.messaging.ReleasedTypeDecoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.decoders.messaging.SourceTypeDecoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.decoders.messaging.TargetTypeDecoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.decoders.security.SaslChallengeTypeDecoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.decoders.security.SaslInitTypeDecoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.decoders.security.SaslMechanismsTypeDecoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.decoders.security.SaslOutcomeTypeDecoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.decoders.security.SaslResponseTypeDecoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.decoders.transactions.CoordinatorTypeDecoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.decoders.transactions.DeclaredTypeDecoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.decoders.transactions.DeclareTypeDecoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.decoders.transactions.DischargeTypeDecoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.decoders.transactions.TransactionStateTypeDecoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.decoders.transport.AttachTypeDecoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.decoders.transport.BeginTypeDecoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.decoders.transport.CloseTypeDecoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.decoders.transport.DetachTypeDecoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.decoders.transport.DispositionTypeDecoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.decoders.transport.EndTypeDecoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.decoders.transport.ErrorConditionTypeDecoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.decoders.transport.FlowTypeDecoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.decoders.transport.OpenTypeDecoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.decoders.transport.TransferTypeDecoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.decoders.UnknownDescribedTypeDecoder
 
getDescriptorSymbol() - Method in interface org.apache.qpid.protonj2.codec.DescribedTypeDecoder
Returns the AMQP descriptor symbol for the type this decoder reads.
getDescriptorSymbol() - Method in interface org.apache.qpid.protonj2.codec.DescribedTypeEncoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.AcceptedTypeEncoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.AmqpSequenceTypeEncoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.AmqpValueTypeEncoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.ApplicationPropertiesTypeEncoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.DataTypeEncoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.DeleteOnCloseTypeEncoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.DeleteOnNoLinksOrMessagesTypeEncoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.DeleteOnNoLinksTypeEncoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.DeleteOnNoMessagesTypeEncoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.DeliveryAnnotationsTypeEncoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.FooterTypeEncoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.HeaderTypeEncoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.MessageAnnotationsTypeEncoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.ModifiedTypeEncoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.PropertiesTypeEncoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.ReceivedTypeEncoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.RejectedTypeEncoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.ReleasedTypeEncoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.SourceTypeEncoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.TargetTypeEncoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.encoders.security.SaslChallengeTypeEncoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.encoders.security.SaslInitTypeEncoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.encoders.security.SaslMechanismsTypeEncoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.encoders.security.SaslOutcomeTypeEncoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.encoders.security.SaslResponseTypeEncoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.encoders.transactions.CoordinatorTypeEncoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.encoders.transactions.DeclaredTypeEncoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.encoders.transactions.DeclareTypeEncoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.encoders.transactions.DischargeTypeEncoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.encoders.transactions.TransactionStateTypeEncoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.encoders.transport.AttachTypeEncoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.encoders.transport.BeginTypeEncoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.encoders.transport.CloseTypeEncoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.encoders.transport.DetachTypeEncoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.encoders.transport.DispositionTypeEncoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.encoders.transport.EndTypeEncoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.encoders.transport.ErrorConditionTypeEncoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.encoders.transport.FlowTypeEncoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.encoders.transport.OpenTypeEncoder
 
getDescriptorSymbol() - Method in class org.apache.qpid.protonj2.codec.encoders.transport.TransferTypeEncoder
 
getDescriptorSymbol() - Method in interface org.apache.qpid.protonj2.codec.StreamDescribedTypeDecoder
Returns the AMQP descriptor symbol for the type this decoder reads.
getDesiredCapabilities() - Method in interface org.apache.qpid.protonj2.engine.Endpoint
 
getDesiredCapabilities() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonConnection
 
getDesiredCapabilities() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonLink
 
getDesiredCapabilities() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonSession
 
getDesiredCapabilities() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonTransactionController
 
getDesiredCapabilities() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonTransactionManager
 
getDesiredCapabilities() - Method in class org.apache.qpid.protonj2.types.transport.Attach
 
getDesiredCapabilities() - Method in class org.apache.qpid.protonj2.types.transport.Begin
 
getDesiredCapabilities() - Method in class org.apache.qpid.protonj2.types.transport.Open
 
getDischargeState() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonTransaction
 
getDischargeState() - Method in interface org.apache.qpid.protonj2.engine.Transaction
For a Transaction that has either been requested to discharge or has successfully discharged the Transaction.DischargeState reflects whether the transaction was to be committed or rolled back.
getDistributionMode() - Method in class org.apache.qpid.protonj2.types.messaging.Source
 
getDouble(int) - Method in class org.apache.qpid.protonj2.buffer.ProtonAbstractBuffer
 
getDouble(int) - Method in interface org.apache.qpid.protonj2.buffer.ProtonBuffer
Gets a double from the specified index, this method will not modify the read or write index.
getDouble(int) - Method in class org.apache.qpid.protonj2.buffer.ProtonNettyByteBuffer
 
getDouble(int) - Method in class org.apache.qpid.protonj2.buffer.ProtonSlicedBuffer
 
getDrain() - Method in class org.apache.qpid.protonj2.types.transport.Flow
 
getDurable() - Method in class org.apache.qpid.protonj2.types.messaging.Source
 
getDurable() - Method in class org.apache.qpid.protonj2.types.messaging.Target
 
getDynamicNodeProperties() - Method in class org.apache.qpid.protonj2.types.messaging.Source
 
getDynamicNodeProperties() - Method in class org.apache.qpid.protonj2.types.messaging.Target
 
getEcho() - Method in class org.apache.qpid.protonj2.types.transport.Flow
 
getElementCount() - Method in class org.apache.qpid.protonj2.types.messaging.Header
 
getElementCount() - Method in class org.apache.qpid.protonj2.types.messaging.Properties
 
getElementCount() - Method in class org.apache.qpid.protonj2.types.transport.Attach
 
getElementCount() - Method in class org.apache.qpid.protonj2.types.transport.Begin
 
getElementCount() - Method in class org.apache.qpid.protonj2.types.transport.Detach
 
getElementCount() - Method in class org.apache.qpid.protonj2.types.transport.Disposition
 
getElementCount() - Method in class org.apache.qpid.protonj2.types.transport.Flow
 
getElementCount() - Method in class org.apache.qpid.protonj2.types.transport.Open
 
getElementCount() - Method in class org.apache.qpid.protonj2.types.transport.Transfer
 
getElementCount(Accepted) - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.AcceptedTypeEncoder
 
getElementCount(DeleteOnClose) - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.DeleteOnCloseTypeEncoder
 
getElementCount(DeleteOnNoLinks) - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.DeleteOnNoLinksTypeEncoder
 
getElementCount(DeleteOnNoLinksOrMessages) - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.DeleteOnNoLinksOrMessagesTypeEncoder
 
getElementCount(DeleteOnNoMessages) - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.DeleteOnNoMessagesTypeEncoder
 
getElementCount(Header) - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.HeaderTypeEncoder
 
getElementCount(Modified) - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.ModifiedTypeEncoder
 
getElementCount(Properties) - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.PropertiesTypeEncoder
 
getElementCount(Received) - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.ReceivedTypeEncoder
 
getElementCount(Rejected) - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.RejectedTypeEncoder
 
getElementCount(Released) - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.ReleasedTypeEncoder
 
getElementCount(Source) - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.SourceTypeEncoder
 
getElementCount(Target) - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.TargetTypeEncoder
 
getElementCount(SaslChallenge) - Method in class org.apache.qpid.protonj2.codec.encoders.security.SaslChallengeTypeEncoder
 
getElementCount(SaslInit) - Method in class org.apache.qpid.protonj2.codec.encoders.security.SaslInitTypeEncoder
 
getElementCount(SaslMechanisms) - Method in class org.apache.qpid.protonj2.codec.encoders.security.SaslMechanismsTypeEncoder
 
getElementCount(SaslOutcome) - Method in class org.apache.qpid.protonj2.codec.encoders.security.SaslOutcomeTypeEncoder
 
getElementCount(SaslResponse) - Method in class org.apache.qpid.protonj2.codec.encoders.security.SaslResponseTypeEncoder
 
getElementCount(Coordinator) - Method in class org.apache.qpid.protonj2.codec.encoders.transactions.CoordinatorTypeEncoder
 
getElementCount(Declare) - Method in class org.apache.qpid.protonj2.codec.encoders.transactions.DeclareTypeEncoder
 
getElementCount(Declared) - Method in class org.apache.qpid.protonj2.codec.encoders.transactions.DeclaredTypeEncoder
 
getElementCount(Discharge) - Method in class org.apache.qpid.protonj2.codec.encoders.transactions.DischargeTypeEncoder
 
getElementCount(TransactionalState) - Method in class org.apache.qpid.protonj2.codec.encoders.transactions.TransactionStateTypeEncoder
 
getElementCount(Attach) - Method in class org.apache.qpid.protonj2.codec.encoders.transport.AttachTypeEncoder
 
getElementCount(Begin) - Method in class org.apache.qpid.protonj2.codec.encoders.transport.BeginTypeEncoder
 
getElementCount(Close) - Method in class org.apache.qpid.protonj2.codec.encoders.transport.CloseTypeEncoder
 
getElementCount(Detach) - Method in class org.apache.qpid.protonj2.codec.encoders.transport.DetachTypeEncoder
 
getElementCount(Disposition) - Method in class org.apache.qpid.protonj2.codec.encoders.transport.DispositionTypeEncoder
 
getElementCount(End) - Method in class org.apache.qpid.protonj2.codec.encoders.transport.EndTypeEncoder
 
getElementCount(ErrorCondition) - Method in class org.apache.qpid.protonj2.codec.encoders.transport.ErrorConditionTypeEncoder
 
getElementCount(Flow) - Method in class org.apache.qpid.protonj2.codec.encoders.transport.FlowTypeEncoder
 
getElementCount(Open) - Method in class org.apache.qpid.protonj2.codec.encoders.transport.OpenTypeEncoder
 
getElementCount(Transfer) - Method in class org.apache.qpid.protonj2.codec.encoders.transport.TransferTypeEncoder
 
getElementCount(V) - Method in class org.apache.qpid.protonj2.codec.encoders.AbstractDescribedListTypeEncoder
Gets the number of elements that will result when this type is encoded into an AMQP List type.
getEncoder() - Static method in class org.apache.qpid.protonj2.codec.CodecFactory
 
getEncoder() - Method in class org.apache.qpid.protonj2.codec.encoders.ProtonEncoderState
 
getEncoder() - Method in interface org.apache.qpid.protonj2.codec.EncoderState
 
getEngine() - Method in interface org.apache.qpid.protonj2.engine.Endpoint
 
getEngine() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEndpoint
 
getError() - Method in class org.apache.qpid.protonj2.types.messaging.Rejected
 
getError() - Method in class org.apache.qpid.protonj2.types.transport.Close
 
getError() - Method in class org.apache.qpid.protonj2.types.transport.Detach
 
getError() - Method in class org.apache.qpid.protonj2.types.transport.End
 
getErrorCondition() - Method in exception org.apache.qpid.protonj2.client.exceptions.ClientConnectionRemotelyClosedException
 
getErrorCondition() - Method in exception org.apache.qpid.protonj2.client.exceptions.ClientResourceRemotelyClosedException
 
getErrorCondition() - Method in exception org.apache.qpid.protonj2.engine.exceptions.ProtocolViolationException
 
getExpiryPolicy() - Method in class org.apache.qpid.protonj2.types.messaging.Source
 
getExpiryPolicy() - Method in class org.apache.qpid.protonj2.types.messaging.Target
 
getFail() - Method in class org.apache.qpid.protonj2.types.transactions.Discharge
 
getFilter() - Method in class org.apache.qpid.protonj2.types.messaging.Source
 
getFirst() - Method in class org.apache.qpid.protonj2.types.transport.Disposition
 
getFloat(int) - Method in class org.apache.qpid.protonj2.buffer.ProtonAbstractBuffer
 
getFloat(int) - Method in interface org.apache.qpid.protonj2.buffer.ProtonBuffer
Gets a float from the specified index, this method will not modify the read or write index.
getFloat(int) - Method in class org.apache.qpid.protonj2.buffer.ProtonNettyByteBuffer
 
getFloat(int) - Method in class org.apache.qpid.protonj2.buffer.ProtonSlicedBuffer
 
getFrameType() - Method in class org.apache.qpid.protonj2.engine.PerformativeEnvelope
 
getGlobalId() - Method in class org.apache.qpid.protonj2.types.transactions.Declare
 
getGroupId() - Method in class org.apache.qpid.protonj2.types.messaging.Properties
 
getGroupSequence() - Method in class org.apache.qpid.protonj2.types.messaging.Properties
 
getHandle() - Method in class org.apache.qpid.protonj2.types.transport.Attach
 
getHandle() - Method in class org.apache.qpid.protonj2.types.transport.Detach
 
getHandle() - Method in class org.apache.qpid.protonj2.types.transport.Flow
 
getHandle() - Method in class org.apache.qpid.protonj2.types.transport.Transfer
 
getHandleMax() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonSession
 
getHandleMax() - Method in interface org.apache.qpid.protonj2.engine.Session
 
getHandleMax() - Method in class org.apache.qpid.protonj2.types.transport.Begin
 
getHost() - Method in class org.apache.qpid.protonj2.client.ReconnectLocation
 
getHost() - Method in class org.apache.qpid.protonj2.client.transport.TcpTransport
 
getHost() - Method in interface org.apache.qpid.protonj2.client.transport.Transport
 
getHostname() - Method in exception org.apache.qpid.protonj2.client.exceptions.ClientConnectionRedirectedException
the host name of the remote peer where the Connection is being redirected.
getHostname() - Method in exception org.apache.qpid.protonj2.client.exceptions.ClientLinkRedirectedException
the host name of the remote peer where the Sender or Receiver is being redirected.
getHostname() - Method in class org.apache.qpid.protonj2.client.impl.ClientRedirect
 
getHostname() - Method in interface org.apache.qpid.protonj2.engine.Connection
 
getHostname() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonConnection
 
getHostname() - Method in interface org.apache.qpid.protonj2.engine.sasl.SaslContext
The DNS name of the host (either fully qualified or relative) that was sent to the server which define the host the sending peer is connecting to.
getHostname() - Method in class org.apache.qpid.protonj2.types.security.SaslInit
 
getHostname() - Method in class org.apache.qpid.protonj2.types.transport.Open
 
getIdleTimeout() - Method in interface org.apache.qpid.protonj2.engine.Connection
 
getIdleTimeout() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonConnection
 
getIdleTimeout() - Method in class org.apache.qpid.protonj2.types.transport.Open
 
getIncomingBytes() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonSessionIncomingWindow
 
getIncomingCapacity() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonSession
 
getIncomingCapacity() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonSessionIncomingWindow
 
getIncomingCapacity() - Method in interface org.apache.qpid.protonj2.engine.Session
 
getIncomingLocales() - Method in class org.apache.qpid.protonj2.types.transport.Open
 
getIncomingWindow() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonSessionIncomingWindow
 
getIncomingWindow() - Method in class org.apache.qpid.protonj2.types.transport.Begin
 
getIncomingWindow() - Method in class org.apache.qpid.protonj2.types.transport.Flow
 
getIncompleteUnsettled() - Method in class org.apache.qpid.protonj2.types.transport.Attach
 
getInfo() - Method in class org.apache.qpid.protonj2.types.transport.ErrorCondition
 
getInitialDeliveryCount() - Method in class org.apache.qpid.protonj2.types.transport.Attach
 
getInitialResponse() - Method in class org.apache.qpid.protonj2.types.security.SaslInit
 
getInitialResponse(SaslCredentialsProvider) - Method in class org.apache.qpid.protonj2.engine.sasl.client.AbstractMechanism
 
getInitialResponse(SaslCredentialsProvider) - Method in class org.apache.qpid.protonj2.engine.sasl.client.CramMD5Mechanism
 
getInitialResponse(SaslCredentialsProvider) - Method in interface org.apache.qpid.protonj2.engine.sasl.client.Mechanism
Create an initial response based on selected mechanism.
getInitialResponse(SaslCredentialsProvider) - Method in class org.apache.qpid.protonj2.engine.sasl.client.PlainMechanism
 
getInitialResponse(SaslCredentialsProvider) - Method in class org.apache.qpid.protonj2.engine.sasl.client.XOauth2Mechanism
 
getInstance() - Static method in class org.apache.qpid.protonj2.client.impl.ClientDeliveryState.ClientAccepted
 
getInstance() - Static method in class org.apache.qpid.protonj2.client.impl.ClientDeliveryState.ClientReleased
 
getInstance() - Static method in class org.apache.qpid.protonj2.types.messaging.Accepted
 
getInstance() - Static method in class org.apache.qpid.protonj2.types.messaging.DeleteOnClose
 
getInstance() - Static method in class org.apache.qpid.protonj2.types.messaging.DeleteOnNoLinks
 
getInstance() - Static method in class org.apache.qpid.protonj2.types.messaging.DeleteOnNoLinksOrMessages
 
getInstance() - Static method in class org.apache.qpid.protonj2.types.messaging.DeleteOnNoMessages
 
getInstance() - Static method in class org.apache.qpid.protonj2.types.messaging.Released
 
getInt(int) - Method in interface org.apache.qpid.protonj2.buffer.ProtonBuffer
Gets a int from the specified index, this method will not modify the read or write index.
getInt(int) - Method in class org.apache.qpid.protonj2.buffer.ProtonByteBuffer
 
getInt(int) - Method in class org.apache.qpid.protonj2.buffer.ProtonCompositeBuffer
 
getInt(int) - Method in class org.apache.qpid.protonj2.buffer.ProtonDuplicatedBuffer
 
getInt(int) - Method in class org.apache.qpid.protonj2.buffer.ProtonNettyByteBuffer
 
getInt(int) - Method in class org.apache.qpid.protonj2.buffer.ProtonNioByteBuffer
 
getInt(int) - Method in class org.apache.qpid.protonj2.buffer.ProtonSlicedBuffer
 
getIntKey() - Method in class org.apache.qpid.protonj2.engine.util.SplayMap.SplayedEntry
 
getKey() - Method in class org.apache.qpid.protonj2.engine.util.SplayMap.ImmutableSplayMapEntry
 
getKey() - Method in class org.apache.qpid.protonj2.engine.util.SplayMap.SplayedEntry
 
getLast() - Method in class org.apache.qpid.protonj2.types.transport.Disposition
 
getLeastSignificantBits() - Method in class org.apache.qpid.protonj2.types.Decimal128
 
getLength() - Method in class org.apache.qpid.protonj2.types.Binary
 
getLength() - Method in class org.apache.qpid.protonj2.types.Symbol
 
getLink() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonIncomingDelivery
 
getLink() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonOutgoingDelivery
 
getLink() - Method in interface org.apache.qpid.protonj2.engine.IncomingDelivery
 
getLink() - Method in interface org.apache.qpid.protonj2.engine.OutgoingDelivery
 
getLinkCredit() - Method in class org.apache.qpid.protonj2.types.transport.Flow
 
getLinkedResource() - Method in interface org.apache.qpid.protonj2.engine.Endpoint
 
getLinkedResource() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEndpoint
 
getLinkedResource() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonIncomingDelivery
 
getLinkedResource() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonOutgoingDelivery
 
getLinkedResource() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonTransaction
 
getLinkedResource() - Method in interface org.apache.qpid.protonj2.engine.IncomingDelivery
 
getLinkedResource() - Method in interface org.apache.qpid.protonj2.engine.OutgoingDelivery
 
getLinkedResource() - Method in interface org.apache.qpid.protonj2.engine.Transaction
 
getLinkedResource(Class<T>) - Method in interface org.apache.qpid.protonj2.engine.Endpoint
Gets the linked resource (if set) and returns it using the type information provided to cast the returned value.
getLinkedResource(Class<T>) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonEndpoint
 
getLinkedResource(Class<T>) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonIncomingDelivery
 
getLinkedResource(Class<T>) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonOutgoingDelivery
 
getLinkedResource(Class<T>) - Method in class org.apache.qpid.protonj2.engine.impl.ProtonTransaction
 
getLinkedResource(Class<T>) - Method in interface org.apache.qpid.protonj2.engine.IncomingDelivery
Gets the linked resource (if set) and returns it using the type information provided to cast the returned value.
getLinkedResource(Class<T>) - Method in interface org.apache.qpid.protonj2.engine.OutgoingDelivery
Gets the linked resource (if set) and returns it using the type information provided to cast the returned value.
getLinkedResource(Class<T>) - Method in interface org.apache.qpid.protonj2.engine.Transaction
Gets the linked resource (if set) and returns it using the type information provided to cast the returned value.
getList() - Method in class org.apache.qpid.protonj2.client.util.ReconnectLocationPool
Gets the current list of ReconnectLocation values.
getListEncoding(Accepted) - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.AcceptedTypeEncoder
 
getListEncoding(DeleteOnClose) - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.DeleteOnCloseTypeEncoder
 
getListEncoding(DeleteOnNoLinks) - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.DeleteOnNoLinksTypeEncoder
 
getListEncoding(DeleteOnNoLinksOrMessages) - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.DeleteOnNoLinksOrMessagesTypeEncoder
 
getListEncoding(DeleteOnNoMessages) - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.DeleteOnNoMessagesTypeEncoder
 
getListEncoding(Header) - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.HeaderTypeEncoder
 
getListEncoding(Modified) - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.ModifiedTypeEncoder
 
getListEncoding(Properties) - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.PropertiesTypeEncoder
 
getListEncoding(Received) - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.ReceivedTypeEncoder
 
getListEncoding(Rejected) - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.RejectedTypeEncoder
 
getListEncoding(Released) - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.ReleasedTypeEncoder
 
getListEncoding(Source) - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.SourceTypeEncoder
 
getListEncoding(Target) - Method in class org.apache.qpid.protonj2.codec.encoders.messaging.TargetTypeEncoder
 
getListEncoding(SaslChallenge) - Method in class org.apache.qpid.protonj2.codec.encoders.security.SaslChallengeTypeEncoder
 
getListEncoding(SaslOutcome) - Method in class org.apache.qpid.protonj2.codec.encoders.security.SaslOutcomeTypeEncoder
 
getListEncoding(SaslResponse) - Method in class org.apache.qpid.protonj2.codec.encoders.security.SaslResponseTypeEncoder
 
getListEncoding(Coordinator) - Method in class org.apache.qpid.protonj2.codec.encoders.transactions.CoordinatorTypeEncoder
 
getListEncoding(Declare) - Method in class org.apache.qpid.protonj2.codec.encoders.transactions.DeclareTypeEncoder
 
getListEncoding(Declared) - Method in class org.apache.qpid.protonj2.codec.encoders.transactions.DeclaredTypeEncoder
 
getListEncoding(Discharge) - Method in class org.apache.qpid.protonj2.codec.encoders.transactions.DischargeTypeEncoder
 
getListEncoding(TransactionalState) - Method in class org.apache.qpid.protonj2.codec.encoders.transactions.TransactionStateTypeEncoder
 
getListEncoding(Attach) - Method in class org.apache.qpid.protonj2.codec.encoders.transport.AttachTypeEncoder
 
getListEncoding(Begin) - Method in class org.apache.qpid.protonj2.codec.encoders.transport.BeginTypeEncoder
 
getListEncoding(Close) - Method in class org.apache.qpid.protonj2.codec.encoders.transport.CloseTypeEncoder
 
getListEncoding(Detach) - Method in class org.apache.qpid.protonj2.codec.encoders.transport.DetachTypeEncoder
 
getListEncoding(Disposition) - Method in class org.apache.qpid.protonj2.codec.encoders.transport.DispositionTypeEncoder
 
getListEncoding(End) - Method in class org.apache.qpid.protonj2.codec.encoders.transport.EndTypeEncoder
 
getListEncoding(ErrorCondition) - Method in class org.apache.qpid.protonj2.codec.encoders.transport.ErrorConditionTypeEncoder
 
getListEncoding(Flow) - Method in class org.apache.qpid.protonj2.codec.encoders.transport.FlowTypeEncoder
 
getListEncoding(Open) - Method in class org.apache.qpid.protonj2.codec.encoders.transport.OpenTypeEncoder
 
getListEncoding(Transfer) - Method in class org.apache.qpid.protonj2.codec.encoders.transport.TransferTypeEncoder
 
getListEncoding(V) - Method in class org.apache.qpid.protonj2.codec.encoders.AbstractDescribedListTypeEncoder
Determine the list type the given value can be encoded to based on the number of bytes that would be needed to hold the encoded form of the resulting list entries.
getListener() - Method in interface org.apache.qpid.protonj2.engine.sasl.SaslClientContext
 
getListener() - Method in interface org.apache.qpid.protonj2.engine.sasl.SaslServerContext
 
getLocalChannel() - Method in class org.apache.qpid.protonj2.engine.impl.ProtonSession
 
getLocalPrincipal() - Method in class org.apache.qpid.protonj2.client.transport.TcpTransport
 
getLocalPrincipal() - Method in interface org.apache.qpid.protonj2.client.transport.Transport
 
getLogger(Class<?>) - Static method in class org.apache.qpid.protonj2.logging.ProtonLoggerFactory
Logger lookup based on the Class that will host the logger instance.
getLogger(String) - Static method in class org.apache.qpid.protonj2.logging.