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
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 thisStreamReceiverMessage
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 newUnsignedInteger
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 thisTransactionController
has been granted credit which would then allow for transactionDeclared
andDischarge
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 theTransactionController
to sendDeclare
andDischarge
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
- 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 returnsnull
. - annotations() - Method in interface org.apache.qpid.protonj2.client.Delivery
-
Decodes the
Delivery
payload and returns aMap
containing a copy of any associatedDeliveryAnnotations
that were transmitted with theMessage
payload of thisDelivery
. - 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 compositeProtonBuffer
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 returnsnull
. - 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 aDisposition
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 aDisposition
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 theTransport.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 assignedClientSynchronization
. - BalancedClientFuture(ClientSynchronization<V>) - Constructor for class org.apache.qpid.protonj2.client.futures.BalancedClientFuture
-
Create a new
BalancedClientFuture
instance with the assignedClientSynchronization
. - 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 AMQPData
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 theSection
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 theAdvancedMessage
. - 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 associatedSaslClientContext
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 AMQPClose
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
- 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 AMQPErrorCondition
. - 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
- 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 aClientSender
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 theClientConnectionRemotelyClosedException
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 aClientStreamSender
orClientStreamReceiver
and cannot create any further resources as the lifetime of the session is tied to the childStreamSender
orStreamReceiver
. - ClientStreamTracker - Class in org.apache.qpid.protonj2.client.impl
-
StreamTracker
implementation that relies on the ClientTracker to handle the basicOutgoingDelivery
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 configuredConnectionOptions.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 configuredReceiverOptions.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 configuredSenderOptions.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 configuredSessionOptions.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 configuredConnectionOptions.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 configuredReceiverOptions.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 configuredSenderOptions.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 configuredSessionOptions.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 aFuture
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 aFuture
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 aFuture
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 aFuture
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 aFuture
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 aFuture
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 aFuture
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 aFuture
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
orReceiver
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
orReceiver
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
- 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 thisStreamReceiverMessage
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 parentStreamSenderMessage
(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 thisEngine
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 creatingReceiver
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 specificConnection
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 assignedClientSynchronization
. - ConservativeClientFuture(ClientSynchronization<V>) - Constructor for class org.apache.qpid.protonj2.client.futures.ConservativeClientFuture
-
Create a new
ConservativeClientFuture
instance with the assignedClientSynchronization
. - 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 aClientMessage
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() - 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(E) - Static method in interface org.apache.qpid.protonj2.client.Message
- 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(Map<K, V>) - Static method in interface org.apache.qpid.protonj2.client.Message
- 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 bodySection
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 givenEngineFailedException
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
- 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 thisSender
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 theTransactionManager
responds with an error to theDeclare
action. - declared(Transaction<TransactionManager>, byte[]) - Method in interface org.apache.qpid.protonj2.engine.TransactionManager
-
Respond to a previous
Declare
request from the remoteTransactionController
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 remoteTransactionController
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 theTransactionManager
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 previousDeclare
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 remoteTransactionController
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 aTransaction
declaration with anRejected
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 givenDeclare
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 newProtonByteBuffer
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
forConnection.send(Message)
calls. - defaultSender() - Method in class org.apache.qpid.protonj2.client.impl.ClientConnection
- defaultSession() - Method in interface org.apache.qpid.protonj2.client.Connection
- 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 createdReceiver
instances. - deliveryMode(DeliveryMode) - Method in class org.apache.qpid.protonj2.client.SenderOptions
-
Sets the
DeliveryMode
value to assign to newly createdSender
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
- deliveryReadHandler(EventHandler<IncomingDelivery>) - Method in interface org.apache.qpid.protonj2.engine.Receiver
- 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 theseConnectionOptions
. - 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 configuredSenderOptions.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 configuredSenderOptions.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 configuredSenderOptions.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 configuredSenderOptions.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 aFuture
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 aFuture
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 aFuture
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 aFuture
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 thisLink
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 theTransactionManager
responds with an error to theDischarge
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 remoteTransactionController
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 aDischarge
has been requested and theTransactionManager
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 previousTransactionController.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 remoteTransactionController
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 previousTransactionController.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 givenDischarge
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 specificConnection
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 thisEndpoint
is shutdown via a call toEngine.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 establishedConnection
. - 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 theEnginePipeline
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 lastEngineHandler
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 lastEngineHandler
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 lastEngineHandler
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 lastEngineHandler
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 firstEngineHandler
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 firstEngineHandler
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 theEnginePipeline
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 firstEngineHandler
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 theEnginePipeline
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 firstEngineHandler
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 returnsnull
. - 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 returnsnull
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 theSplayMap
. - 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 thisMessage
. - forEachBodySection(Consumer<Section<?>>) - Method in interface org.apache.qpid.protonj2.client.AdvancedMessage
-
Performs the given action for each body
Section
of theAdvancedMessage
until all sections have been presented to the givenConsumer
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 thisMessage
. - 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 theProtonBuffer
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 thisMessage
. - 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 theErrorCondition
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 theTransaction.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
- 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.