Index (ActiveMQ :: AMQP 5.17.1 API)

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

A

AbstractSaslMechanism - Class in org.apache.activemq.transport.amqp.sasl: Base class for SASL Mechanisms that provides common functionality.
AbstractSaslMechanism() - Constructor for class org.apache.activemq.transport.amqp.sasl.AbstractSaslMechanism
addCloseAction(Runnable) - Method in class org.apache.activemq.transport.amqp.protocol.AmqpAbstractLink
addCloseAction(Runnable) - Method in interface org.apache.activemq.transport.amqp.protocol.AmqpLink: Adds a new Runnable that is called on close of this link.
AMQP_BINARY_PREFIX - Static variable in class org.apache.activemq.transport.amqp.message.AMQPMessageIdHelper
AMQP_DATA - Static variable in class org.apache.activemq.transport.amqp.message.AmqpMessageSupport
AMQP_NULL - Static variable in class org.apache.activemq.transport.amqp.message.AmqpMessageSupport
AMQP_SEQUENCE - Static variable in class org.apache.activemq.transport.amqp.message.AmqpMessageSupport
AMQP_STRING_PREFIX - Static variable in class org.apache.activemq.transport.amqp.message.AMQPMessageIdHelper
AMQP_ULONG_PREFIX - Static variable in class org.apache.activemq.transport.amqp.message.AMQPMessageIdHelper
AMQP_UNKNOWN - Static variable in class org.apache.activemq.transport.amqp.message.AmqpMessageSupport
AMQP_UUID_PREFIX - Static variable in class org.apache.activemq.transport.amqp.message.AMQPMessageIdHelper
AMQP_VALUE_BINARY - Static variable in class org.apache.activemq.transport.amqp.message.AmqpMessageSupport
AMQP_VALUE_LIST - Static variable in class org.apache.activemq.transport.amqp.message.AmqpMessageSupport
AMQP_VALUE_MAP - Static variable in class org.apache.activemq.transport.amqp.message.AmqpMessageSupport
AMQP_VALUE_NULL - Static variable in class org.apache.activemq.transport.amqp.message.AmqpMessageSupport
AMQP_VALUE_STRING - Static variable in class org.apache.activemq.transport.amqp.message.AmqpMessageSupport
AmqpAbstractLink<LINK_TYPE extends org.apache.qpid.proton.engine.Link> - Class in org.apache.activemq.transport.amqp.protocol: Abstract AmqpLink implementation that provide basic Link services.
AmqpAbstractLink(AmqpSession, LINK_TYPE) - Constructor for class org.apache.activemq.transport.amqp.protocol.AmqpAbstractLink: Creates a new AmqpLink type.
AmqpAbstractReceiver - Class in org.apache.activemq.transport.amqp.protocol: Abstract base that provides common services for AMQP Receiver types.
AmqpAbstractReceiver(AmqpSession, Receiver) - Constructor for class org.apache.activemq.transport.amqp.protocol.AmqpAbstractReceiver: Handle create of new AMQP Receiver instance.
AmqpAuthenticator - Class in org.apache.activemq.transport.amqp.sasl: SASL Authentication engine.
AmqpAuthenticator(AmqpTransport, Sasl, BrokerService) - Constructor for class org.apache.activemq.transport.amqp.sasl.AmqpAuthenticator
AmqpConnection - Class in org.apache.activemq.transport.amqp.protocol: Implements the mechanics of managing a single remote peer connection.
AmqpConnection(AmqpTransport, BrokerService) - Constructor for class org.apache.activemq.transport.amqp.protocol.AmqpConnection
AmqpContentTypeSupport - Class in org.apache.activemq.transport.amqp.message
AmqpContentTypeSupport() - Constructor for class org.apache.activemq.transport.amqp.message.AmqpContentTypeSupport
AmqpFrameParser - Class in org.apache.activemq.transport.amqp: State based Frame reader that is used in the NIO based transports where AMQP frames can come in in partial or overlapping forms.
AmqpFrameParser(AmqpFrameParser.AMQPFrameSink) - Constructor for class org.apache.activemq.transport.amqp.AmqpFrameParser
AmqpFrameParser(TcpTransport) - Constructor for class org.apache.activemq.transport.amqp.AmqpFrameParser
AmqpFrameParser.AMQPFrameSink - Interface in org.apache.activemq.transport.amqp
AmqpHeader - Class in org.apache.activemq.transport.amqp: Represents the AMQP protocol handshake packet that is sent during the initial exchange with a remote peer.
AmqpHeader() - Constructor for class org.apache.activemq.transport.amqp.AmqpHeader
AmqpHeader(Buffer) - Constructor for class org.apache.activemq.transport.amqp.AmqpHeader
AmqpHeader(Buffer, boolean) - Constructor for class org.apache.activemq.transport.amqp.AmqpHeader
AmqpInactivityMonitor - Class in org.apache.activemq.transport.amqp
AmqpInactivityMonitor(Transport, WireFormat) - Constructor for class org.apache.activemq.transport.amqp.AmqpInactivityMonitor
AmqpJmsSelectorFilter - Class in org.apache.activemq.transport.amqp.protocol: A Described Type wrapper for JMS selector values.
AmqpJmsSelectorFilter(String) - Constructor for class org.apache.activemq.transport.amqp.protocol.AmqpJmsSelectorFilter
AmqpLink - Interface in org.apache.activemq.transport.amqp.protocol: Interface used to define the operations needed to implement an AMQP Link based endpoint, i.e.
AMQPMessageIdHelper - Class in org.apache.activemq.transport.amqp.message: Helper class for identifying and converting message-id and correlation-id values between the AMQP types and the Strings values used by JMS.
AMQPMessageIdHelper() - Constructor for class org.apache.activemq.transport.amqp.message.AMQPMessageIdHelper
AmqpMessageSupport - Class in org.apache.activemq.transport.amqp.message: Support class containing constant values and static methods that are used to map to / from AMQP Message types being sent or received.
AmqpMessageSupport() - Constructor for class org.apache.activemq.transport.amqp.message.AmqpMessageSupport
AMQPNativeInboundTransformer - Class in org.apache.activemq.transport.amqp.message
AMQPNativeInboundTransformer() - Constructor for class org.apache.activemq.transport.amqp.message.AMQPNativeInboundTransformer
AMQPNativeOutboundTransformer - Class in org.apache.activemq.transport.amqp.message
AMQPNativeOutboundTransformer() - Constructor for class org.apache.activemq.transport.amqp.message.AMQPNativeOutboundTransformer
AmqpNioSslTransport - Class in org.apache.activemq.transport.amqp
AmqpNioSslTransport(WireFormat, Socket) - Constructor for class org.apache.activemq.transport.amqp.AmqpNioSslTransport
AmqpNioSslTransport(WireFormat, Socket, SSLEngine, TcpTransport.InitBuffer, ByteBuffer) - Constructor for class org.apache.activemq.transport.amqp.AmqpNioSslTransport
AmqpNioSslTransport(WireFormat, SocketFactory, URI, URI) - Constructor for class org.apache.activemq.transport.amqp.AmqpNioSslTransport
AmqpNioSslTransportFactory - Class in org.apache.activemq.transport.amqp
AmqpNioSslTransportFactory() - Constructor for class org.apache.activemq.transport.amqp.AmqpNioSslTransportFactory
AmqpNioTransport - Class in org.apache.activemq.transport.amqp: An implementation of the Transport interface for using AMQP over NIO
AmqpNioTransport(WireFormat, Socket) - Constructor for class org.apache.activemq.transport.amqp.AmqpNioTransport
AmqpNioTransport(WireFormat, Socket, TcpTransport.InitBuffer) - Constructor for class org.apache.activemq.transport.amqp.AmqpNioTransport
AmqpNioTransport(WireFormat, SocketFactory, URI, URI) - Constructor for class org.apache.activemq.transport.amqp.AmqpNioTransport
AmqpNioTransportFactory - Class in org.apache.activemq.transport.amqp: A AMQP over NIO transport factory
AmqpNioTransportFactory() - Constructor for class org.apache.activemq.transport.amqp.AmqpNioTransportFactory
AmqpNoLocalFilter - Class in org.apache.activemq.transport.amqp.protocol: A Described Type wrapper for JMS no local option for MessageConsumer.
AmqpNoLocalFilter() - Constructor for class org.apache.activemq.transport.amqp.protocol.AmqpNoLocalFilter
AmqpProtocolConverter - Interface in org.apache.activemq.transport.amqp: Interface that defines the API for any AMQP protocol converter ised to map AMQP mechanics to ActiveMQ and back.
AmqpProtocolDiscriminator - Class in org.apache.activemq.transport.amqp: Used to assign the best implementation of a AmqpProtocolConverter to the AmqpTransport based on the AmqpHeader that the client sends us.
AmqpProtocolDiscriminator(AmqpTransport, BrokerService) - Constructor for class org.apache.activemq.transport.amqp.AmqpProtocolDiscriminator
AmqpProtocolException - Exception in org.apache.activemq.transport.amqp
AmqpProtocolException() - Constructor for exception org.apache.activemq.transport.amqp.AmqpProtocolException
AmqpProtocolException(String) - Constructor for exception org.apache.activemq.transport.amqp.AmqpProtocolException
AmqpProtocolException(String, boolean) - Constructor for exception org.apache.activemq.transport.amqp.AmqpProtocolException
AmqpProtocolException(String, boolean, Throwable) - Constructor for exception org.apache.activemq.transport.amqp.AmqpProtocolException
AmqpProtocolException(String, String) - Constructor for exception org.apache.activemq.transport.amqp.AmqpProtocolException
AmqpProtocolException(String, String, boolean, Throwable) - Constructor for exception org.apache.activemq.transport.amqp.AmqpProtocolException
AMQPRawInboundTransformer - Class in org.apache.activemq.transport.amqp.message
AMQPRawInboundTransformer() - Constructor for class org.apache.activemq.transport.amqp.message.AMQPRawInboundTransformer
AmqpReceiver - Class in org.apache.activemq.transport.amqp.protocol: An AmqpReceiver wraps the AMQP Receiver end of a link from the remote peer which holds the corresponding Sender which transfers message accross the link.
AmqpReceiver(AmqpSession, Receiver, ProducerInfo) - Constructor for class org.apache.activemq.transport.amqp.protocol.AmqpReceiver: Create a new instance of an AmqpReceiver
AmqpResource - Interface in org.apache.activemq.transport.amqp.protocol: Root interface for all endpoint objects.
AmqpSender - Class in org.apache.activemq.transport.amqp.protocol: An AmqpSender wraps the AMQP Sender end of a link from the remote peer which holds the corresponding Receiver which receives messages transfered across the link from the Broker.
AmqpSender(AmqpSession, Sender, ConsumerInfo) - Constructor for class org.apache.activemq.transport.amqp.protocol.AmqpSender: Creates a new AmqpSender instance that manages the given Sender
AmqpSession - Class in org.apache.activemq.transport.amqp.protocol: Wraps the AMQP Session and provides the services needed to manage the remote peer requests for link establishment.
AmqpSession(AmqpConnection, SessionId, Session) - Constructor for class org.apache.activemq.transport.amqp.protocol.AmqpSession: Create new AmqpSession instance whose parent is the given AmqpConnection.
AmqpSslTransportFactory - Class in org.apache.activemq.transport.amqp: A AMQP over SSL transport factory
AmqpSslTransportFactory() - Constructor for class org.apache.activemq.transport.amqp.AmqpSslTransportFactory
AmqpSupport - Class in org.apache.activemq.transport.amqp: Set of useful methods and definitions used in the AMQP protocol handling
AmqpSupport() - Constructor for class org.apache.activemq.transport.amqp.AmqpSupport
AmqpTransactionCoordinator - Class in org.apache.activemq.transport.amqp.protocol: Implements the AMQP Transaction Coordinator support to manage local transactions between an AMQP client and the broker.
AmqpTransactionCoordinator(AmqpSession, Receiver) - Constructor for class org.apache.activemq.transport.amqp.protocol.AmqpTransactionCoordinator: Creates a new Transaction coordinator used to manage AMQP transactions.
AmqpTransferTagGenerator - Class in org.apache.activemq.transport.amqp.protocol: Utility class that can generate and if enabled pool the binary tag values used to identify transfers over an AMQP link.
AmqpTransferTagGenerator() - Constructor for class org.apache.activemq.transport.amqp.protocol.AmqpTransferTagGenerator
AmqpTransferTagGenerator(boolean) - Constructor for class org.apache.activemq.transport.amqp.protocol.AmqpTransferTagGenerator
AmqpTransport - Interface in org.apache.activemq.transport.amqp: Basic interface that mediates between protocol converter and transport
AmqpTransportFactory - Class in org.apache.activemq.transport.amqp: A AMQP transport factory
AmqpTransportFactory() - Constructor for class org.apache.activemq.transport.amqp.AmqpTransportFactory
AmqpTransportFilter - Class in org.apache.activemq.transport.amqp: The AMQPTransportFilter normally sits on top of a TcpTransport that has been configured with the AmqpWireFormat and is used to convert AMQP commands to ActiveMQ commands.
AmqpTransportFilter(Transport, WireFormat, BrokerService) - Constructor for class org.apache.activemq.transport.amqp.AmqpTransportFilter
AmqpWireFormat - Class in org.apache.activemq.transport.amqp
AmqpWireFormat() - Constructor for class org.apache.activemq.transport.amqp.AmqpWireFormat
AmqpWireFormat.ResetListener - Interface in org.apache.activemq.transport.amqp
AmqpWireFormatFactory - Class in org.apache.activemq.transport.amqp: Creates the default AMQP WireFormat object used to configure the protocol support.
AmqpWireFormatFactory() - Constructor for class org.apache.activemq.transport.amqp.AmqpWireFormatFactory
AmqpWritableBuffer - Class in org.apache.activemq.transport.amqp.message
AmqpWritableBuffer() - Constructor for class org.apache.activemq.transport.amqp.message.AmqpWritableBuffer: Creates a new WritableBuffer with default capacity.
AmqpWritableBuffer(int) - Constructor for class org.apache.activemq.transport.amqp.message.AmqpWritableBuffer: Create a new WritableBuffer with the given capacity.
AmqpWSTransport - Class in org.apache.activemq.transport.amqp: An AMQP based WebSocket transport implementation.
AmqpWSTransport(URI, WireFormat) - Constructor for class org.apache.activemq.transport.amqp.AmqpWSTransport: Create a new Transport instance.
AmqpWSTransportFactory - Class in org.apache.activemq.transport.amqp: Factory for creating WebSocket aware AMQP Transports.
AmqpWSTransportFactory() - Constructor for class org.apache.activemq.transport.amqp.AmqpWSTransportFactory
ANONYMOUS_RELAY - Static variable in class org.apache.activemq.transport.amqp.AmqpSupport
AnonymousMechanism - Class in org.apache.activemq.transport.amqp.sasl: SASL Anonymous mechanism implementation.
AnonymousMechanism() - Constructor for class org.apache.activemq.transport.amqp.sasl.AnonymousMechanism
AutoOutboundTransformer - Class in org.apache.activemq.transport.amqp.message
AutoOutboundTransformer() - Constructor for class org.apache.activemq.transport.amqp.message.AutoOutboundTransformer

C

close() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpAbstractLink
close() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpReceiver
close() - Method in interface org.apache.activemq.transport.amqp.protocol.AmqpResource: Request from the remote peer to close this resource.
close() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpSender
close() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpSession
close(ErrorCondition) - Method in class org.apache.activemq.transport.amqp.protocol.AmqpAbstractLink
close(ErrorCondition) - Method in interface org.apache.activemq.transport.amqp.protocol.AmqpLink: Close the Link with an error indicating the reson for the close.
closeActions - Variable in class org.apache.activemq.transport.amqp.protocol.AmqpAbstractLink
closed - Variable in class org.apache.activemq.transport.amqp.protocol.AmqpAbstractLink
commit(LocalTransactionId) - Method in class org.apache.activemq.transport.amqp.protocol.AmqpAbstractReceiver
commit(LocalTransactionId) - Method in interface org.apache.activemq.transport.amqp.protocol.AmqpLink: Handle work necessary on commit of transacted resources associated with this Link instance.
commit(LocalTransactionId) - Method in class org.apache.activemq.transport.amqp.protocol.AmqpSender
commit(LocalTransactionId) - Method in class org.apache.activemq.transport.amqp.protocol.AmqpSession: Commits all pending work for all resources managed under this session.
compositeConfigure(Transport, WireFormat, Map) - Method in class org.apache.activemq.transport.amqp.AmqpNioTransportFactory
compositeConfigure(Transport, WireFormat, Map) - Method in class org.apache.activemq.transport.amqp.AmqpSslTransportFactory
compositeConfigure(Transport, WireFormat, Map) - Method in class org.apache.activemq.transport.amqp.AmqpTransportFactory
compositeConfigure(Transport, WireFormat, Map) - Method in class org.apache.activemq.transport.amqp.AmqpWSTransportFactory
configuredCredit - Variable in class org.apache.activemq.transport.amqp.protocol.AmqpAbstractReceiver
CONNECTION_OPEN_FAILED - Static variable in class org.apache.activemq.transport.amqp.AmqpSupport
CONTAINER_ID - Static variable in class org.apache.activemq.transport.amqp.AmqpSupport
contains(Symbol[], Symbol) - Static method in class org.apache.activemq.transport.amqp.AmqpSupport: Search for a given Symbol in a given array of Symbol object.
CONTENT_ENCODING - Static variable in class org.apache.activemq.transport.amqp.message.AmqpMessageSupport
CONTENT_TYPE - Static variable in class org.apache.activemq.transport.amqp.message.AmqpMessageSupport
context - Variable in class org.apache.activemq.transport.amqp.AmqpNioSslTransportFactory
convertBinaryToHexString(byte[]) - Method in class org.apache.activemq.transport.amqp.message.AMQPMessageIdHelper: Convert the provided binary into a hex-string representation where each character represents 4 bits of the provided binary, i.e each byte requires two characters.
convertHexStringToBinary(String) - Method in class org.apache.activemq.transport.amqp.message.AMQPMessageIdHelper: Convert the provided hex-string into a binary representation where each byte represents two characters of the hex string.
COPY - Static variable in class org.apache.activemq.transport.amqp.AmqpSupport
createCoordinator(Receiver) - Method in class org.apache.activemq.transport.amqp.protocol.AmqpSession
createDestination(Object) - Static method in class org.apache.activemq.transport.amqp.AmqpSupport: Given an AMQP endpoint, deduce the appropriate ActiveMQDestination type and create a new instance.
createInactivityMonitor(AmqpTransportFilter, WireFormat) - Method in class org.apache.activemq.transport.amqp.AmqpWSTransportFactory
createInactivityMonitor(Transport, WireFormat) - Method in class org.apache.activemq.transport.amqp.AmqpNioTransportFactory
createInactivityMonitor(Transport, WireFormat) - Method in class org.apache.activemq.transport.amqp.AmqpSslTransportFactory
createInactivityMonitor(Transport, WireFormat) - Method in class org.apache.activemq.transport.amqp.AmqpTransportFactory
createMapMessage(Map<String, Object>) - Static method in class org.apache.activemq.transport.amqp.message.JMSMappingInboundTransformer
createObjectMessage(byte[], int, int) - Static method in class org.apache.activemq.transport.amqp.message.JMSMappingInboundTransformer
createReceiver(Receiver) - Method in class org.apache.activemq.transport.amqp.protocol.AmqpSession
createSender(Sender) - Method in class org.apache.activemq.transport.amqp.protocol.AmqpSession
createTcpTransport(WireFormat, SocketFactory, URI, URI) - Method in class org.apache.activemq.transport.amqp.AmqpNioSslTransportFactory
createTcpTransport(WireFormat, SocketFactory, URI, URI) - Method in class org.apache.activemq.transport.amqp.AmqpNioTransportFactory
createTcpTransportServer(URI, ServerSocketFactory) - Method in class org.apache.activemq.transport.amqp.AmqpNioSslTransportFactory
createTcpTransportServer(URI, ServerSocketFactory) - Method in class org.apache.activemq.transport.amqp.AmqpNioTransportFactory
createTextMessage(String) - Static method in class org.apache.activemq.transport.amqp.message.JMSMappingInboundTransformer
createTransport(URI, WireFormat) - Method in class org.apache.activemq.transport.amqp.AmqpWSTransportFactory: Factory method to create a new transport
createTransport(WireFormat, Socket, SSLEngine, TcpTransport.InitBuffer, ByteBuffer) - Method in class org.apache.activemq.transport.amqp.AmqpNioSslTransportFactory
createTransport(WireFormat, Socket, TcpTransport.InitBuffer) - Method in class org.apache.activemq.transport.amqp.AmqpNioTransportFactory
createWireFormat() - Method in class org.apache.activemq.transport.amqp.AmqpWireFormatFactory
current - Variable in class org.apache.activemq.transport.amqp.protocol.AmqpAbstractReceiver

D

decode() - Method in class org.apache.activemq.transport.amqp.message.EncodedMessage
DEFAULT_ALLOW_NON_SASL_CONNECTIONS - Static variable in class org.apache.activemq.transport.amqp.AmqpWireFormat
DEFAULT_ANQP_FRAME_SIZE - Static variable in class org.apache.activemq.transport.amqp.AmqpWireFormat
DEFAULT_CAPACITY - Static variable in class org.apache.activemq.transport.amqp.message.AmqpWritableBuffer
DEFAULT_CONNECTION_TIMEOUT - Static variable in class org.apache.activemq.transport.amqp.AmqpWireFormat
DEFAULT_IDLE_TIMEOUT - Static variable in class org.apache.activemq.transport.amqp.AmqpWireFormat
DEFAULT_MAX_FRAME_SIZE - Static variable in class org.apache.activemq.transport.amqp.AmqpWireFormat
DEFAULT_PREFETCH - Static variable in class org.apache.activemq.transport.amqp.AmqpProtocolDiscriminator
DEFAULT_PRODUCER_CREDIT - Static variable in class org.apache.activemq.transport.amqp.AmqpWireFormat
DEFAULT_TAG_POOL_SIZE - Static variable in class org.apache.activemq.transport.amqp.protocol.AmqpTransferTagGenerator
DELAYED_DELIVERY - Static variable in class org.apache.activemq.transport.amqp.AmqpSupport
delivery(Delivery) - Method in class org.apache.activemq.transport.amqp.protocol.AmqpAbstractReceiver
delivery(Delivery) - Method in interface org.apache.activemq.transport.amqp.protocol.AmqpLink: Called when a new Delivery arrives for the given Link.
delivery(Delivery) - Method in class org.apache.activemq.transport.amqp.protocol.AmqpSender
DELIVERY_ANNOTATION_PREFIX - Static variable in class org.apache.activemq.transport.amqp.message.AmqpMessageSupport
detach() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpAbstractLink
detach() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpAbstractReceiver
detach() - Method in interface org.apache.activemq.transport.amqp.protocol.AmqpLink: Request from the remote peer to detach this resource.
detach() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpSender
doBind(URI) - Method in class org.apache.activemq.transport.amqp.AmqpNioSslTransportFactory
doBind(URI) - Method in class org.apache.activemq.transport.amqp.AmqpWSTransportFactory
doInit() - Method in class org.apache.activemq.transport.amqp.AmqpNioSslTransport
doStart() - Method in class org.apache.activemq.transport.amqp.AmqpNioTransport
doStart() - Method in class org.apache.activemq.transport.amqp.AmqpWSTransport
doStop(ServiceStopper) - Method in class org.apache.activemq.transport.amqp.AmqpNioTransport
doStop(ServiceStopper) - Method in class org.apache.activemq.transport.amqp.AmqpWSTransport
doTransform(EncodedMessage) - Method in class org.apache.activemq.transport.amqp.message.AMQPNativeInboundTransformer
doTransform(EncodedMessage) - Method in class org.apache.activemq.transport.amqp.message.AMQPRawInboundTransformer
doTransform(EncodedMessage) - Method in class org.apache.activemq.transport.amqp.message.InboundTransformer
doTransform(EncodedMessage) - Method in class org.apache.activemq.transport.amqp.message.JMSMappingInboundTransformer

E

EMPTY_BINARY - Static variable in class org.apache.activemq.transport.amqp.message.AmqpMessageSupport
EMPTY_BODY - Static variable in class org.apache.activemq.transport.amqp.message.AmqpMessageSupport
EncodedMessage - Class in org.apache.activemq.transport.amqp.message
EncodedMessage(long, byte[], int, int) - Constructor for class org.apache.activemq.transport.amqp.message.EncodedMessage
encodesJavaPrimitive() - Method in class org.apache.activemq.transport.amqp.message.UTF8BufferType.UTF8BufferEncoding
encodesSuperset(TypeEncoding<UTF8Buffer>) - Method in class org.apache.activemq.transport.amqp.message.UTF8BufferType.UTF8BufferEncoding
endpoint - Variable in class org.apache.activemq.transport.amqp.protocol.AmqpAbstractLink
enlist(TransactionId) - Method in class org.apache.activemq.transport.amqp.protocol.AmqpSession
enlist(AmqpSession) - Method in class org.apache.activemq.transport.amqp.protocol.AmqpTransactionCoordinator

F

failed - Variable in class org.apache.activemq.transport.amqp.sasl.AbstractSaslMechanism
failureReason - Variable in class org.apache.activemq.transport.amqp.sasl.AbstractSaslMechanism
findFilter(Map<Symbol, Object>, Object[]) - Static method in class org.apache.activemq.transport.amqp.AmqpSupport: Search for a particular filter using a set of known indentification values in the Map of filters.
FIRST_ACQUIRER - Static variable in class org.apache.activemq.transport.amqp.message.AmqpMessageSupport
flow() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpAbstractReceiver
flow() - Method in interface org.apache.activemq.transport.amqp.protocol.AmqpLink: Handles an incoming flow control.
flow() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpSender
flow(int) - Method in class org.apache.activemq.transport.amqp.protocol.AmqpAbstractReceiver: Provide the receiver endpoint with the given amount of credits.
flushPendingMessages() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpSession: Used to direct all Session managed Senders to push any queued Messages out to the remote peer.
FOOTER_PREFIX - Static variable in class org.apache.activemq.transport.amqp.message.AmqpMessageSupport

G

getAllEncodings() - Method in class org.apache.activemq.transport.amqp.message.UTF8BufferType
getAmqpTransport() - Method in class org.apache.activemq.transport.amqp.AmqpInactivityMonitor
getArray() - Method in class org.apache.activemq.transport.amqp.message.AmqpWritableBuffer
getArray() - Method in class org.apache.activemq.transport.amqp.message.EncodedMessage
getArrayLength() - Method in class org.apache.activemq.transport.amqp.message.AmqpWritableBuffer
getArrayOffset() - Method in class org.apache.activemq.transport.amqp.message.EncodedMessage
getBinaryFromMessageBody(ActiveMQBytesMessage) - Static method in class org.apache.activemq.transport.amqp.message.AmqpMessageSupport: Return the encoded form of the BytesMessage as an AMQP Binary instance.
getBinaryFromMessageBody(ActiveMQObjectMessage) - Static method in class org.apache.activemq.transport.amqp.message.AmqpMessageSupport: Return the encoded form of the BytesMessage as an AMQP Binary instance.
getBinaryFromMessageBody(ActiveMQTextMessage) - Static method in class org.apache.activemq.transport.amqp.message.AmqpMessageSupport: Return the encoded form of the Message as an AMQP Binary instance.
getBuffer() - Method in class org.apache.activemq.transport.amqp.AmqpHeader
getCanonicalEncoding() - Method in class org.apache.activemq.transport.amqp.message.UTF8BufferType
getCharsetForTextualContent(String) - Static method in class org.apache.activemq.transport.amqp.message.AmqpMessageSupport
getClientId() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpConnection
getConfiguredReceiverCredit() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpAbstractReceiver: Returns the amount of receiver credit that has been configured for this AMQP transport.
getConfiguredReceiverCredit() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpConnection
getConfiguredTransformer() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpConnection
getConnectAttemptTimeout() - Method in class org.apache.activemq.transport.amqp.AmqpTransportFilter
getConnectAttemptTimeout() - Method in class org.apache.activemq.transport.amqp.AmqpWireFormat
getConnection() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpSession
getConnectionCapabilitiesOffered() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpConnection: Load and return a []Symbol that contains the connection capabilities offered to new connections
getConnectionId() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpConnection
getConnetionProperties() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpConnection: Load and return a Map that contains the properties that this connection supplies to incoming connections.
getConstructorSize() - Method in class org.apache.activemq.transport.amqp.message.UTF8BufferType.UTF8BufferEncoding
getConsumerId() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpSender
getDecoder() - Method in class org.apache.activemq.transport.amqp.message.UTF8BufferType.UTF8BufferEncoding
getDefaultWireFormatType() - Method in class org.apache.activemq.transport.amqp.AmqpNioTransportFactory
getDefaultWireFormatType() - Method in class org.apache.activemq.transport.amqp.AmqpSslTransportFactory
getDefaultWireFormatType() - Method in class org.apache.activemq.transport.amqp.AmqpTransportFactory
getDefaultWireFormatType() - Method in class org.apache.activemq.transport.amqp.AmqpWSTransportFactory
getDescribed() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpJmsSelectorFilter
getDescribed() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpNoLocalFilter
getDescriptor() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpJmsSelectorFilter
getDescriptor() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpNoLocalFilter
getDestination() - Method in interface org.apache.activemq.transport.amqp.protocol.AmqpLink
getDestination() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpReceiver
getDestination() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpSender
getDestination() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpTransactionCoordinator
getDestinationTypeSymbol(ActiveMQDestination) - Static method in class org.apache.activemq.transport.amqp.AmqpSupport: Given an ActiveMQDestination return the proper Capability value for the concrete destination type.
getEncoder() - Method in class org.apache.activemq.transport.amqp.message.UTF8BufferType.UTF8BufferEncoding
getEncoding(UTF8Buffer) - Method in class org.apache.activemq.transport.amqp.message.UTF8BufferType
getEncodingCode() - Method in class org.apache.activemq.transport.amqp.message.UTF8BufferType.LargeUTF8BufferEncoding
getEncodingCode() - Method in class org.apache.activemq.transport.amqp.message.UTF8BufferType.SmallUTF8BufferEncoding
getEndpoint() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpAbstractLink
getEndpoint() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpSession
getFailedConnetionProperties() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpConnection: Load and return a Map that contains the properties that this connection supplies to incoming connections when the open has failed and the remote should expect a close to follow.
getFailureReason() - Method in class org.apache.activemq.transport.amqp.sasl.AbstractSaslMechanism
getFailureReason() - Method in interface org.apache.activemq.transport.amqp.sasl.SaslMechanism
getFallbackTransformer() - Method in class org.apache.activemq.transport.amqp.message.AMQPNativeInboundTransformer
getFallbackTransformer() - Method in class org.apache.activemq.transport.amqp.message.AMQPRawInboundTransformer
getFallbackTransformer() - Method in class org.apache.activemq.transport.amqp.message.InboundTransformer
getFallbackTransformer() - Method in class org.apache.activemq.transport.amqp.message.JMSMappingInboundTransformer
getIdelTimeout() - Method in class org.apache.activemq.transport.amqp.AmqpWireFormatFactory
getIdleTimeout() - Method in class org.apache.activemq.transport.amqp.AmqpWireFormat
getInactivityMonitor() - Method in interface org.apache.activemq.transport.amqp.AmqpTransport
getInactivityMonitor() - Method in class org.apache.activemq.transport.amqp.AmqpTransportFilter
getLength() - Method in class org.apache.activemq.transport.amqp.message.EncodedMessage
getMajor() - Method in class org.apache.activemq.transport.amqp.AmqpHeader
getMapFromMessageBody(ActiveMQMapMessage) - Static method in class org.apache.activemq.transport.amqp.message.AmqpMessageSupport: Return the underlying Map from the JMS MapMessage instance.
getMaxAmqpFrameSize() - Method in class org.apache.activemq.transport.amqp.AmqpWireFormat
getMaxAmqpFrameSize() - Method in class org.apache.activemq.transport.amqp.AmqpWireFormatFactory
getMaxFrameSize() - Method in class org.apache.activemq.transport.amqp.AmqpTransportFilter
getMaxFrameSize() - Method in class org.apache.activemq.transport.amqp.AmqpWireFormat
getMaxFrameSize() - Method in class org.apache.activemq.transport.amqp.AmqpWireFormatFactory
getMaxFrameSize() - Method in class org.apache.activemq.transport.amqp.AmqpWSTransport
getMaxFrameSize() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpConnection
getMaxFrameSize() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpSession
getMaxPoolSize() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpTransferTagGenerator: Gets the current max pool size value.
getMechanismName() - Method in class org.apache.activemq.transport.amqp.sasl.AnonymousMechanism
getMechanismName() - Method in class org.apache.activemq.transport.amqp.sasl.PlainMechanism
getMechanismName() - Method in interface org.apache.activemq.transport.amqp.sasl.SaslMechanism
getMessageAnnotation(String, Message) - Static method in class org.apache.activemq.transport.amqp.message.AmqpMessageSupport: Safe way to access message annotations which will check internal structure and either return the annotation if it exists or null if the annotation or any annotations are present.
getMessageFormat() - Method in class org.apache.activemq.transport.amqp.message.EncodedMessage
getMinimallySupportedHeader() - Method in class org.apache.activemq.transport.amqp.AmqpWireFormat: Returns an AMQP Header object that represents the minimally protocol versions supported by this transport.
getMinor() - Method in class org.apache.activemq.transport.amqp.AmqpHeader
getNextTag() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpTransferTagGenerator: Retrieves the next available tag.
getPassword() - Method in class org.apache.activemq.transport.amqp.sasl.AbstractSaslMechanism
getPassword() - Method in interface org.apache.activemq.transport.amqp.sasl.SaslMechanism
getPeerCertificates() - Method in interface org.apache.activemq.transport.amqp.AmqpTransport
getPeerCertificates() - Method in class org.apache.activemq.transport.amqp.AmqpTransportFilter
getPeerCertificates() - Method in class org.apache.activemq.transport.amqp.AmqpWSTransport
getProducerCredit() - Method in class org.apache.activemq.transport.amqp.AmqpTransportFilter
getProducerCredit() - Method in class org.apache.activemq.transport.amqp.AmqpWireFormat
getProducerCredit() - Method in class org.apache.activemq.transport.amqp.AmqpWireFormatFactory
getProducerId() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpReceiver
getProtocolConverter() - Method in interface org.apache.activemq.transport.amqp.AmqpTransport
getProtocolConverter() - Method in class org.apache.activemq.transport.amqp.AmqpTransportFilter
getProtocolId() - Method in class org.apache.activemq.transport.amqp.AmqpHeader
getReceiveCounter() - Method in class org.apache.activemq.transport.amqp.AmqpWSTransport
getRemoteAddress() - Method in interface org.apache.activemq.transport.amqp.AmqpTransport
getRemoteAddress() - Method in class org.apache.activemq.transport.amqp.AmqpWSTransport
getRevision() - Method in class org.apache.activemq.transport.amqp.AmqpHeader
getSession() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpAbstractLink
getSessionId() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpSession
getSizeBytes() - Method in class org.apache.activemq.transport.amqp.message.UTF8BufferType.LargeUTF8BufferEncoding
getSizeBytes() - Method in class org.apache.activemq.transport.amqp.message.UTF8BufferType.SmallUTF8BufferEncoding
getSizeBytes() - Method in class org.apache.activemq.transport.amqp.message.UTF8BufferType.UTF8BufferEncoding
getSubProtocol() - Method in class org.apache.activemq.transport.amqp.AmqpWSTransport
getSupportedMechanisms() - Method in class org.apache.activemq.transport.amqp.sasl.AmqpAuthenticator
getSymbol(String) - Static method in class org.apache.activemq.transport.amqp.message.AmqpMessageSupport: Lookup and return the correct Proton Symbol instance based on the given key.
getSymbolicName() - Method in exception org.apache.activemq.transport.amqp.AmqpProtocolException
getTransformer() - Method in interface org.apache.activemq.transport.amqp.AmqpTransport
getTransformer() - Method in class org.apache.activemq.transport.amqp.AmqpTransportFilter
getTransformer() - Method in class org.apache.activemq.transport.amqp.AmqpWireFormat
getTransformer() - Method in class org.apache.activemq.transport.amqp.AmqpWireFormatFactory
getTransformer() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpReceiver
getTransformerName() - Method in class org.apache.activemq.transport.amqp.message.AMQPNativeInboundTransformer
getTransformerName() - Method in class org.apache.activemq.transport.amqp.message.AMQPRawInboundTransformer
getTransformerName() - Method in class org.apache.activemq.transport.amqp.message.InboundTransformer
getTransformerName() - Method in class org.apache.activemq.transport.amqp.message.JMSMappingInboundTransformer
getType() - Method in class org.apache.activemq.transport.amqp.message.UTF8BufferType.UTF8BufferEncoding
getTypeClass() - Method in class org.apache.activemq.transport.amqp.message.UTF8BufferType
getTypeClass() - Method in class org.apache.activemq.transport.amqp.message.UTF8BufferType.UTF8BufferEncoding
getUsername() - Method in class org.apache.activemq.transport.amqp.sasl.AbstractSaslMechanism
getUsername() - Method in interface org.apache.activemq.transport.amqp.sasl.SaslMechanism
getValueSize(UTF8Buffer) - Method in class org.apache.activemq.transport.amqp.message.UTF8BufferType.UTF8BufferEncoding
getVersion() - Method in class org.apache.activemq.transport.amqp.AmqpWireFormat
getWireFormat() - Method in class org.apache.activemq.transport.amqp.AmqpFrameParser
getWireFormat() - Method in interface org.apache.activemq.transport.amqp.AmqpTransport
getWireFormat() - Method in class org.apache.activemq.transport.amqp.AmqpTransportFilter
getWireFormat() - Method in class org.apache.activemq.transport.amqp.AmqpWSTransport

H

handleException(IOException) - Method in class org.apache.activemq.transport.amqp.AmqpTransportFilter
hasRemaining() - Method in class org.apache.activemq.transport.amqp.message.AmqpWritableBuffer
hasValidPrefix() - Method in class org.apache.activemq.transport.amqp.AmqpHeader
HEADER - Static variable in class org.apache.activemq.transport.amqp.message.AmqpMessageSupport

I

InboundTransformer - Class in org.apache.activemq.transport.amqp.message
InboundTransformer() - Constructor for class org.apache.activemq.transport.amqp.message.InboundTransformer
initializeStreams() - Method in class org.apache.activemq.transport.amqp.AmqpNioSslTransport
initializeStreams() - Method in class org.apache.activemq.transport.amqp.AmqpNioTransport
INSTANCE - Static variable in class org.apache.activemq.transport.amqp.message.AMQPMessageIdHelper
INVALID_FIELD - Static variable in class org.apache.activemq.transport.amqp.AmqpSupport
InvalidContentTypeException - Exception in org.apache.activemq.transport.amqp.message
InvalidContentTypeException(String) - Constructor for exception org.apache.activemq.transport.amqp.message.InvalidContentTypeException
isAllowNonSaslConnections() - Method in class org.apache.activemq.transport.amqp.AmqpWireFormat
isAllowNonSaslConnections() - Method in class org.apache.activemq.transport.amqp.AmqpWireFormatFactory
isAnonymous() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpReceiver: If the Sender that initiated this Receiver endpoint did not define an address then it is using anonymous mode and message are to be routed to the address that is defined in the AMQP message 'To' field.
isClosed() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpAbstractLink
isContentType(String, Message) - Static method in class org.apache.activemq.transport.amqp.message.AmqpMessageSupport: Check whether the content-type field of the properties section (if present) in the given message matches the provided string (where null matches if there is no content type present.
isDone() - Method in class org.apache.activemq.transport.amqp.sasl.AmqpAuthenticator
isFailed() - Method in class org.apache.activemq.transport.amqp.sasl.AbstractSaslMechanism
isFailed() - Method in interface org.apache.activemq.transport.amqp.sasl.SaslMechanism
isFatal() - Method in exception org.apache.activemq.transport.amqp.AmqpProtocolException
isFixedSizeVal() - Method in class org.apache.activemq.transport.amqp.message.UTF8BufferType.UTF8BufferEncoding
isHeaderValid(AmqpHeader, boolean) - Method in class org.apache.activemq.transport.amqp.AmqpWireFormat: Given an AMQP header validate that the AMQP magic is present and if so that the version and protocol values align with what we support.
isMagicRead() - Method in class org.apache.activemq.transport.amqp.AmqpWireFormat
isOpened() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpAbstractLink
isPooling() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpTransferTagGenerator
isTrace() - Method in interface org.apache.activemq.transport.amqp.AmqpTransport
isTrace() - Method in class org.apache.activemq.transport.amqp.AmqpTransportFilter
isUseInactivityMonitor() - Method in interface org.apache.activemq.transport.amqp.AmqpTransport
isUseInactivityMonitor() - Method in class org.apache.activemq.transport.amqp.AmqpTransportFilter

J

JMS_AMQP_CONTENT_ENCODING - Static variable in class org.apache.activemq.transport.amqp.message.AmqpMessageSupport
JMS_AMQP_CONTENT_TYPE - Static variable in class org.apache.activemq.transport.amqp.message.AmqpMessageSupport
JMS_AMQP_DELIVERY_ANNOTATION_PREFIX - Static variable in class org.apache.activemq.transport.amqp.message.AmqpMessageSupport
JMS_AMQP_FIRST_ACQUIRER - Static variable in class org.apache.activemq.transport.amqp.message.AmqpMessageSupport
JMS_AMQP_FOOTER_PREFIX - Static variable in class org.apache.activemq.transport.amqp.message.AmqpMessageSupport
JMS_AMQP_HEADER - Static variable in class org.apache.activemq.transport.amqp.message.AmqpMessageSupport
JMS_AMQP_MESSAGE_ANNOTATION_PREFIX - Static variable in class org.apache.activemq.transport.amqp.message.AmqpMessageSupport
JMS_AMQP_MESSAGE_FORMAT - Static variable in class org.apache.activemq.transport.amqp.message.AmqpMessageSupport
JMS_AMQP_NATIVE - Static variable in class org.apache.activemq.transport.amqp.message.AmqpMessageSupport
JMS_AMQP_ORIGINAL_ENCODING - Static variable in class org.apache.activemq.transport.amqp.message.AmqpMessageSupport
JMS_AMQP_PREFIX - Static variable in class org.apache.activemq.transport.amqp.message.AmqpMessageSupport
JMS_AMQP_PREFIX_LENGTH - Static variable in class org.apache.activemq.transport.amqp.message.AmqpMessageSupport
JMS_AMQP_PROPERTIES - Static variable in class org.apache.activemq.transport.amqp.message.AmqpMessageSupport
JMS_AMQP_REPLYTO_GROUP_ID - Static variable in class org.apache.activemq.transport.amqp.message.AmqpMessageSupport
JMS_DEST_TYPE_MSG_ANNOTATION - Static variable in class org.apache.activemq.transport.amqp.message.JMSMappingOutboundTransformer
JMS_REPLY_TO_TYPE_MSG_ANNOTATION - Static variable in class org.apache.activemq.transport.amqp.message.JMSMappingOutboundTransformer
JMS_SELECTOR_CODE - Static variable in class org.apache.activemq.transport.amqp.AmqpSupport
JMS_SELECTOR_FILTER_IDS - Static variable in class org.apache.activemq.transport.amqp.AmqpSupport
JMS_SELECTOR_NAME - Static variable in class org.apache.activemq.transport.amqp.AmqpSupport
JMSMappingInboundTransformer - Class in org.apache.activemq.transport.amqp.message
JMSMappingInboundTransformer() - Constructor for class org.apache.activemq.transport.amqp.message.JMSMappingInboundTransformer
JMSMappingOutboundTransformer - Class in org.apache.activemq.transport.amqp.message
JMSMappingOutboundTransformer() - Constructor for class org.apache.activemq.transport.amqp.message.JMSMappingOutboundTransformer

K

keepAlive() - Method in interface org.apache.activemq.transport.amqp.AmqpProtocolConverter: Perform any keep alive processing for the connection such as sending empty frames or closing connections due to remote end being inactive for to long.
keepAlive() - Method in class org.apache.activemq.transport.amqp.AmqpProtocolDiscriminator
keepAlive() - Method in interface org.apache.activemq.transport.amqp.AmqpTransport
keepAlive() - Method in class org.apache.activemq.transport.amqp.AmqpTransportFilter
keepAlive() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpConnection

L

LargeUTF8BufferEncoding(EncoderImpl, DecoderImpl) - Constructor for class org.apache.activemq.transport.amqp.message.UTF8BufferType.LargeUTF8BufferEncoding
LIFETIME_POLICY - Static variable in class org.apache.activemq.transport.amqp.AmqpSupport
limit() - Method in class org.apache.activemq.transport.amqp.message.AmqpWritableBuffer

M

marshal(Object) - Method in class org.apache.activemq.transport.amqp.AmqpWireFormat
marshal(Object, DataOutput) - Method in class org.apache.activemq.transport.amqp.AmqpWireFormat
MESSAGE_ANNOTATION_PREFIX - Static variable in class org.apache.activemq.transport.amqp.message.AmqpMessageSupport
MESSAGE_FORMAT - Static variable in class org.apache.activemq.transport.amqp.message.AmqpMessageSupport

N

NATIVE - Static variable in class org.apache.activemq.transport.amqp.message.AmqpMessageSupport
NO_AMQP_MAX_FRAME_SIZE - Static variable in class org.apache.activemq.transport.amqp.AmqpWireFormat
NO_LOCAL - Static variable in class org.apache.activemq.transport.amqp.protocol.AmqpNoLocalFilter
NO_LOCAL_CODE - Static variable in class org.apache.activemq.transport.amqp.AmqpSupport
NO_LOCAL_FILTER_IDS - Static variable in class org.apache.activemq.transport.amqp.AmqpSupport
NO_LOCAL_NAME - Static variable in class org.apache.activemq.transport.amqp.AmqpSupport
NULL_OBJECT_BODY - Static variable in class org.apache.activemq.transport.amqp.message.AmqpMessageSupport

O

OCTET_STREAM_CONTENT_TYPE - Static variable in class org.apache.activemq.transport.amqp.message.AmqpMessageSupport: Content type used to mark Data sections as containing arbitrary bytes.
onActiveMQCommand(Command) - Method in interface org.apache.activemq.transport.amqp.AmqpProtocolConverter: Incoming Command object from ActiveMQ.
onActiveMQCommand(Command) - Method in class org.apache.activemq.transport.amqp.AmqpProtocolDiscriminator
onActiveMQCommand(Command) - Method in class org.apache.activemq.transport.amqp.protocol.AmqpConnection
onAMQPData(Object) - Method in interface org.apache.activemq.transport.amqp.AmqpProtocolConverter: A new incoming data packet from the remote peer is handed off to the protocol converter for processing.
onAMQPData(Object) - Method in class org.apache.activemq.transport.amqp.AmqpProtocolDiscriminator
onAMQPData(Object) - Method in class org.apache.activemq.transport.amqp.protocol.AmqpConnection
onAMQPException(IOException) - Method in interface org.apache.activemq.transport.amqp.AmqpProtocolConverter: Called when the transport detects an exception that the converter needs to respond to.
onAMQPException(IOException) - Method in class org.apache.activemq.transport.amqp.AmqpProtocolDiscriminator
onAMQPException(IOException) - Method in class org.apache.activemq.transport.amqp.protocol.AmqpConnection
onCommand(Object) - Method in class org.apache.activemq.transport.amqp.AmqpTransportFilter
onConsumerControl(ConsumerControl) - Method in class org.apache.activemq.transport.amqp.protocol.AmqpSender: Called when the Broker sends a ConsumerControl command to the Consumer that this sender creates to obtain messages to dispatch via the sender for this end of the open link.
oneway(Object) - Method in class org.apache.activemq.transport.amqp.AmqpTransportFilter
oneway(Object) - Method in class org.apache.activemq.transport.amqp.AmqpWSTransport
onException(IOException) - Method in class org.apache.activemq.transport.amqp.AmqpInactivityMonitor
onException(IOException) - Method in interface org.apache.activemq.transport.amqp.AmqpTransport
onException(IOException) - Method in class org.apache.activemq.transport.amqp.AmqpTransportFilter
onFrame(Object) - Method in interface org.apache.activemq.transport.amqp.AmqpFrameParser.AMQPFrameSink
onFrame(Object) - Method in class org.apache.activemq.transport.amqp.AmqpWSTransport
onMessageDispatch(MessageDispatch) - Method in class org.apache.activemq.transport.amqp.protocol.AmqpSender: Event point for incoming message from ActiveMQ on this Sender's corresponding subscription.
onProtocolReset() - Method in interface org.apache.activemq.transport.amqp.AmqpWireFormat.ResetListener
onResponse(AmqpProtocolConverter, Response) - Method in interface org.apache.activemq.transport.amqp.protocol.ResponseHandler: Called when the Broker has handled a previously issued request and has a response ready.
onWebSocketBinary(ByteBuffer) - Method in class org.apache.activemq.transport.amqp.AmqpWSTransport
onWebSocketClosed() - Method in class org.apache.activemq.transport.amqp.AmqpWSTransport
onWebSocketText(String) - Method in class org.apache.activemq.transport.amqp.AmqpWSTransport
open() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpAbstractLink
open() - Method in interface org.apache.activemq.transport.amqp.protocol.AmqpResource: Request from the remote peer to open this resource.
open() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpSender
open() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpSession
opened - Variable in class org.apache.activemq.transport.amqp.protocol.AmqpAbstractLink
org.apache.activemq.transport.amqp - package org.apache.activemq.transport.amqp: A Broker side implementation of the AMQP 3.1 protocol - see http://amqp.org/
org.apache.activemq.transport.amqp.message - package org.apache.activemq.transport.amqp.message
org.apache.activemq.transport.amqp.protocol - package org.apache.activemq.transport.amqp.protocol
org.apache.activemq.transport.amqp.sasl - package org.apache.activemq.transport.amqp.sasl
ORIGINAL_ENCODING - Static variable in class org.apache.activemq.transport.amqp.message.AmqpMessageSupport
OutboundTransformer - Interface in org.apache.activemq.transport.amqp.message

P

parse(ByteBuffer) - Method in class org.apache.activemq.transport.amqp.AmqpFrameParser
parseContentTypeForTextualCharset(String) - Static method in class org.apache.activemq.transport.amqp.message.AmqpContentTypeSupport
password - Variable in class org.apache.activemq.transport.amqp.sasl.AbstractSaslMechanism
PlainMechanism - Class in org.apache.activemq.transport.amqp.sasl: Implements the SASL Plain mechanism.
PlainMechanism() - Constructor for class org.apache.activemq.transport.amqp.sasl.PlainMechanism
PLATFORM - Static variable in class org.apache.activemq.transport.amqp.AmqpSupport
populateMessage(ActiveMQMessage, Message) - Method in class org.apache.activemq.transport.amqp.message.InboundTransformer
position() - Method in class org.apache.activemq.transport.amqp.message.AmqpWritableBuffer
position(int) - Method in class org.apache.activemq.transport.amqp.message.AmqpWritableBuffer
processBuffer(ByteBuffer, int) - Method in class org.apache.activemq.transport.amqp.AmqpNioTransport
processCommand(ByteBuffer) - Method in class org.apache.activemq.transport.amqp.AmqpNioSslTransport
processConnectionClose(Connection) - Method in class org.apache.activemq.transport.amqp.protocol.AmqpConnection
processConnectionOpen(Connection) - Method in class org.apache.activemq.transport.amqp.protocol.AmqpConnection
processDelivery(Delivery) - Method in class org.apache.activemq.transport.amqp.protocol.AmqpConnection
processDelivery(Delivery, Buffer) - Method in class org.apache.activemq.transport.amqp.protocol.AmqpAbstractReceiver
processDelivery(Delivery, Buffer) - Method in class org.apache.activemq.transport.amqp.protocol.AmqpReceiver
processDelivery(Delivery, Buffer) - Method in class org.apache.activemq.transport.amqp.protocol.AmqpTransactionCoordinator
processLinkClose(Link) - Method in class org.apache.activemq.transport.amqp.protocol.AmqpConnection
processLinkDetach(Link) - Method in class org.apache.activemq.transport.amqp.protocol.AmqpConnection
processLinkFlow(Link) - Method in class org.apache.activemq.transport.amqp.protocol.AmqpConnection
processLinkOpen(Link) - Method in class org.apache.activemq.transport.amqp.protocol.AmqpConnection
processSaslExchange(ConnectionInfo) - Method in class org.apache.activemq.transport.amqp.sasl.AmqpAuthenticator
processSaslStep(Sasl) - Method in class org.apache.activemq.transport.amqp.sasl.AnonymousMechanism
processSaslStep(Sasl) - Method in class org.apache.activemq.transport.amqp.sasl.PlainMechanism
processSaslStep(Sasl) - Method in interface org.apache.activemq.transport.amqp.sasl.SaslMechanism: Perform the SASL processing for this mechanism type.
processSessionClose(Session) - Method in class org.apache.activemq.transport.amqp.protocol.AmqpConnection
processSessionOpen(Session) - Method in class org.apache.activemq.transport.amqp.protocol.AmqpConnection
PRODUCT - Static variable in class org.apache.activemq.transport.amqp.AmqpSupport
PROPERTIES - Static variable in class org.apache.activemq.transport.amqp.message.AmqpMessageSupport
pumpOutbound() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpSender
pumpProtonToSocket() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpSession: Send all pending work out to the remote peer.
put(byte) - Method in class org.apache.activemq.transport.amqp.message.AmqpWritableBuffer
put(byte[], int, int) - Method in class org.apache.activemq.transport.amqp.message.AmqpWritableBuffer
put(ByteBuffer) - Method in class org.apache.activemq.transport.amqp.message.AmqpWritableBuffer
put(ReadableBuffer) - Method in class org.apache.activemq.transport.amqp.message.AmqpWritableBuffer
putDouble(double) - Method in class org.apache.activemq.transport.amqp.message.AmqpWritableBuffer
putFloat(float) - Method in class org.apache.activemq.transport.amqp.message.AmqpWritableBuffer
putInt(int) - Method in class org.apache.activemq.transport.amqp.message.AmqpWritableBuffer
putLong(long) - Method in class org.apache.activemq.transport.amqp.message.AmqpWritableBuffer
putShort(short) - Method in class org.apache.activemq.transport.amqp.message.AmqpWritableBuffer

Q

QUEUE_CAPABILITY - Static variable in class org.apache.activemq.transport.amqp.AmqpSupport
QUEUE_PREFIX - Static variable in class org.apache.activemq.transport.amqp.AmqpSupport
QUEUE_TYPE - Static variable in class org.apache.activemq.transport.amqp.message.JMSMappingOutboundTransformer

R

readValue() - Method in class org.apache.activemq.transport.amqp.message.UTF8BufferType.UTF8BufferEncoding
recvBuffer - Variable in class org.apache.activemq.transport.amqp.protocol.AmqpAbstractReceiver
registerSender(ConsumerId, AmqpSender) - Method in class org.apache.activemq.transport.amqp.protocol.AmqpSession
remaining() - Method in class org.apache.activemq.transport.amqp.message.AmqpWritableBuffer
REPLYTO_GROUP_ID - Static variable in class org.apache.activemq.transport.amqp.message.AmqpMessageSupport
reset() - Method in class org.apache.activemq.transport.amqp.AmqpFrameParser
resetMagicRead() - Method in class org.apache.activemq.transport.amqp.AmqpWireFormat
ResponseHandler - Interface in org.apache.activemq.transport.amqp.protocol: Interface used by the AmqpProtocolConverter for callbacks from the broker.
returnTag(byte[]) - Method in class org.apache.activemq.transport.amqp.protocol.AmqpTransferTagGenerator: When used as a pooled cache of tags the unused tags should always be returned once the transfer has been settled.
rollback(LocalTransactionId) - Method in class org.apache.activemq.transport.amqp.protocol.AmqpAbstractReceiver
rollback(LocalTransactionId) - Method in interface org.apache.activemq.transport.amqp.protocol.AmqpLink: Handle work necessary on rollback of transacted resources associated with this Link instance.
rollback(LocalTransactionId) - Method in class org.apache.activemq.transport.amqp.protocol.AmqpSender
rollback(LocalTransactionId) - Method in class org.apache.activemq.transport.amqp.protocol.AmqpSession: Rolls back any pending work being down under this session.

S

SaslMechanism - Interface in org.apache.activemq.transport.amqp.sasl: A SASL Mechanism implements this interface in order to provide the AmqpAuthenticator with the means of providing authentication services in the SASL handshake step.
secureRead(ByteBuffer) - Method in class org.apache.activemq.transport.amqp.AmqpNioSslTransport
sendToActiveMQ(IOException) - Method in interface org.apache.activemq.transport.amqp.AmqpTransport
sendToActiveMQ(IOException) - Method in class org.apache.activemq.transport.amqp.AmqpTransportFilter
sendToActiveMQ(Command) - Method in interface org.apache.activemq.transport.amqp.AmqpTransport
sendToActiveMQ(Command) - Method in class org.apache.activemq.transport.amqp.AmqpTransportFilter
sendToActiveMQ(Command) - Method in class org.apache.activemq.transport.amqp.protocol.AmqpAbstractLink: Shortcut method to hand off an ActiveMQ Command to the broker and assign a ResponseHandler to deal with any reply from the broker.
sendToActiveMQ(Command, ResponseHandler) - Method in class org.apache.activemq.transport.amqp.protocol.AmqpAbstractLink: Shortcut method to hand off an ActiveMQ Command to the broker and assign a ResponseHandler to deal with any reply from the broker.
sendToAmqp(Object) - Method in interface org.apache.activemq.transport.amqp.AmqpTransport
sendToAmqp(Object) - Method in class org.apache.activemq.transport.amqp.AmqpTransportFilter
SERIALIZED_JAVA_OBJECT_CONTENT_TYPE - Static variable in class org.apache.activemq.transport.amqp.message.AmqpMessageSupport: Content type used to mark Data sections as containing a serialized java object.
serverConfigure(Transport, WireFormat, HashMap) - Method in class org.apache.activemq.transport.amqp.AmqpNioTransportFactory
serverConfigure(Transport, WireFormat, HashMap) - Method in class org.apache.activemq.transport.amqp.AmqpSslTransportFactory
serverConfigure(Transport, WireFormat, HashMap) - Method in class org.apache.activemq.transport.amqp.AmqpTransportFactory
session - Variable in class org.apache.activemq.transport.amqp.protocol.AmqpAbstractLink
setAllowNonSaslConnections(boolean) - Method in class org.apache.activemq.transport.amqp.AmqpWireFormat
setAllowNonSaslConnections(boolean) - Method in class org.apache.activemq.transport.amqp.AmqpWireFormatFactory
setAmqpTransport(AmqpTransport) - Method in class org.apache.activemq.transport.amqp.AmqpInactivityMonitor
setBrokerService(BrokerService) - Method in class org.apache.activemq.transport.amqp.AmqpNioTransportFactory
setBrokerService(BrokerService) - Method in class org.apache.activemq.transport.amqp.AmqpSslTransportFactory
setBrokerService(BrokerService) - Method in class org.apache.activemq.transport.amqp.AmqpTransportFactory
setBrokerService(BrokerService) - Method in class org.apache.activemq.transport.amqp.AmqpWSTransportFactory
setBuffer(Buffer) - Method in class org.apache.activemq.transport.amqp.AmqpHeader
setBuffer(Buffer, boolean) - Method in class org.apache.activemq.transport.amqp.AmqpHeader
setConnectAttemptTimeout(int) - Method in class org.apache.activemq.transport.amqp.AmqpTransportFilter
setConnectAttemptTimeout(int) - Method in class org.apache.activemq.transport.amqp.AmqpWireFormat
setDestination(ActiveMQDestination) - Method in interface org.apache.activemq.transport.amqp.protocol.AmqpLink: Sets the ActiveMQDestination that this link will be servicing.
setDestination(ActiveMQDestination) - Method in class org.apache.activemq.transport.amqp.protocol.AmqpReceiver
setDestination(ActiveMQDestination) - Method in class org.apache.activemq.transport.amqp.protocol.AmqpSender
setDestination(ActiveMQDestination) - Method in class org.apache.activemq.transport.amqp.protocol.AmqpTransactionCoordinator
setIdelTimeout(int) - Method in class org.apache.activemq.transport.amqp.AmqpWireFormatFactory
setIdleTimeout(int) - Method in class org.apache.activemq.transport.amqp.AmqpWireFormat
setInactivityMonitor(AmqpInactivityMonitor) - Method in interface org.apache.activemq.transport.amqp.AmqpTransport
setInactivityMonitor(AmqpInactivityMonitor) - Method in class org.apache.activemq.transport.amqp.AmqpTransportFilter
setMajor(int) - Method in class org.apache.activemq.transport.amqp.AmqpHeader
setMaxAmqpFrameSize(int) - Method in class org.apache.activemq.transport.amqp.AmqpWireFormat
setMaxAmqpFrameSize(int) - Method in class org.apache.activemq.transport.amqp.AmqpWireFormatFactory
setMaxFrameSize(long) - Method in class org.apache.activemq.transport.amqp.AmqpTransportFilter
setMaxFrameSize(long) - Method in class org.apache.activemq.transport.amqp.AmqpWireFormat
setMaxFrameSize(long) - Method in class org.apache.activemq.transport.amqp.AmqpWireFormatFactory
setMaxPoolSize(int) - Method in class org.apache.activemq.transport.amqp.protocol.AmqpTransferTagGenerator: Sets the max tag pool size.
setMinor(int) - Method in class org.apache.activemq.transport.amqp.AmqpHeader
setPeerCertificates(X509Certificate[]) - Method in class org.apache.activemq.transport.amqp.AmqpWSTransport
setProducerCredit(int) - Method in class org.apache.activemq.transport.amqp.AmqpTransportFilter
setProducerCredit(int) - Method in class org.apache.activemq.transport.amqp.AmqpWireFormat
setProducerCredit(int) - Method in class org.apache.activemq.transport.amqp.AmqpWireFormatFactory
setProtocolConverter(AmqpProtocolConverter) - Method in interface org.apache.activemq.transport.amqp.AmqpTransport
setProtocolConverter(AmqpProtocolConverter) - Method in class org.apache.activemq.transport.amqp.AmqpTransportFilter
setProtocolId(int) - Method in class org.apache.activemq.transport.amqp.AmqpHeader
setProtocolResetListener(AmqpWireFormat.ResetListener) - Method in class org.apache.activemq.transport.amqp.AmqpWireFormat
setRevision(int) - Method in class org.apache.activemq.transport.amqp.AmqpHeader
setTrace(boolean) - Method in class org.apache.activemq.transport.amqp.AmqpTransportFilter
setTransformer(String) - Method in class org.apache.activemq.transport.amqp.AmqpTransportFilter
setTransformer(String) - Method in class org.apache.activemq.transport.amqp.AmqpWireFormat
setTransformer(String) - Method in class org.apache.activemq.transport.amqp.AmqpWireFormatFactory
setTransportSink(WSTransport.WSTransportSink) - Method in class org.apache.activemq.transport.amqp.AmqpWSTransport
setVersion(int) - Method in class org.apache.activemq.transport.amqp.AmqpWireFormat
setWireFormat(AmqpWireFormat) - Method in class org.apache.activemq.transport.amqp.AmqpFrameParser
skipValue() - Method in class org.apache.activemq.transport.amqp.message.UTF8BufferType.UTF8BufferEncoding
SmallUTF8BufferEncoding(EncoderImpl, DecoderImpl) - Constructor for class org.apache.activemq.transport.amqp.message.UTF8BufferType.SmallUTF8BufferEncoding
start() - Method in class org.apache.activemq.transport.amqp.AmqpInactivityMonitor
start() - Method in class org.apache.activemq.transport.amqp.AmqpTransportFilter
startConnectionTimeoutChecker(long) - Method in class org.apache.activemq.transport.amqp.AmqpInactivityMonitor
startKeepAliveTask(long) - Method in class org.apache.activemq.transport.amqp.AmqpInactivityMonitor: Starts the keep alive task which will run after the given delay.
stop() - Method in class org.apache.activemq.transport.amqp.AmqpInactivityMonitor
stop() - Method in interface org.apache.activemq.transport.amqp.AmqpTransport
stopConnectionTimeoutChecker() - Method in class org.apache.activemq.transport.amqp.AmqpInactivityMonitor
stopKeepAliveTask() - Method in class org.apache.activemq.transport.amqp.AmqpInactivityMonitor

T

TEMP_QUEUE_CAPABILITY - Static variable in class org.apache.activemq.transport.amqp.AmqpSupport
TEMP_QUEUE_TYPE - Static variable in class org.apache.activemq.transport.amqp.message.JMSMappingOutboundTransformer
TEMP_TOPIC_CAPABILITY - Static variable in class org.apache.activemq.transport.amqp.AmqpSupport
TEMP_TOPIC_TYPE - Static variable in class org.apache.activemq.transport.amqp.message.JMSMappingOutboundTransformer
toBaseMessageIdString(Object) - Method in class org.apache.activemq.transport.amqp.message.AMQPMessageIdHelper: Takes the provided AMQP messageId style object, and convert it to a base string.
toBuffer(ByteBuffer) - Static method in class org.apache.activemq.transport.amqp.AmqpSupport: Conversion from Java ByteBuffer to a HawtBuf buffer.
toBytes(long) - Static method in class org.apache.activemq.transport.amqp.AmqpSupport: Given a long value, convert it to a byte array for marshalling.
toIdObject(String) - Method in class org.apache.activemq.transport.amqp.message.AMQPMessageIdHelper: Takes the provided base id string and return the appropriate amqp messageId style object.
toLong(Binary) - Static method in class org.apache.activemq.transport.amqp.AmqpSupport: Converts a Binary value to a long assuming that the contained value is stored in Big Endian encoding.
TOPIC_CAPABILITY - Static variable in class org.apache.activemq.transport.amqp.AmqpSupport
TOPIC_PREFIX - Static variable in class org.apache.activemq.transport.amqp.AmqpSupport
TOPIC_TYPE - Static variable in class org.apache.activemq.transport.amqp.message.JMSMappingOutboundTransformer
toString() - Method in class org.apache.activemq.transport.amqp.AmqpHeader
toString() - Method in class org.apache.activemq.transport.amqp.message.EncodedMessage
toString() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpJmsSelectorFilter
toString() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpSender
TRACE_FRAMES - Static variable in class org.apache.activemq.transport.amqp.AmqpTransportFilter
transform(ActiveMQMessage) - Method in class org.apache.activemq.transport.amqp.message.AMQPNativeOutboundTransformer
transform(ActiveMQMessage) - Method in class org.apache.activemq.transport.amqp.message.AutoOutboundTransformer
transform(ActiveMQMessage) - Method in class org.apache.activemq.transport.amqp.message.JMSMappingOutboundTransformer
transform(ActiveMQMessage) - Method in interface org.apache.activemq.transport.amqp.message.OutboundTransformer
transform(EncodedMessage) - Method in class org.apache.activemq.transport.amqp.message.InboundTransformer
TRANSFORMER_JMS - Static variable in class org.apache.activemq.transport.amqp.message.InboundTransformer
TRANSFORMER_NATIVE - Static variable in class org.apache.activemq.transport.amqp.message.InboundTransformer
TRANSFORMER_RAW - Static variable in class org.apache.activemq.transport.amqp.message.InboundTransformer

U

unmarshal(DataInput) - Method in class org.apache.activemq.transport.amqp.AmqpWireFormat
unmarshal(ByteSequence) - Method in class org.apache.activemq.transport.amqp.AmqpWireFormat
unregisterSender(ConsumerId) - Method in class org.apache.activemq.transport.amqp.protocol.AmqpSession
updateTracer() - Method in interface org.apache.activemq.transport.amqp.AmqpProtocolConverter: On changes to the transport tracing options the Protocol Converter should update its internal state so that the proper AMQP data is logged.
updateTracer() - Method in class org.apache.activemq.transport.amqp.AmqpProtocolDiscriminator
updateTracer() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpConnection
username - Variable in class org.apache.activemq.transport.amqp.sasl.AbstractSaslMechanism
UTF8BufferEncoding(EncoderImpl, DecoderImpl) - Constructor for class org.apache.activemq.transport.amqp.message.UTF8BufferType.UTF8BufferEncoding
UTF8BufferType - Class in org.apache.activemq.transport.amqp.message: AMQP Type used to allow to proton-j codec to deal with UTF8Buffer types as if they were String elements.
UTF8BufferType(EncoderImpl, DecoderImpl) - Constructor for class org.apache.activemq.transport.amqp.message.UTF8BufferType
UTF8BufferType.LargeUTF8BufferEncoding - Class in org.apache.activemq.transport.amqp.message
UTF8BufferType.SmallUTF8BufferEncoding - Class in org.apache.activemq.transport.amqp.message
UTF8BufferType.UTF8BufferEncoding - Class in org.apache.activemq.transport.amqp.message

V

VERSION - Static variable in class org.apache.activemq.transport.amqp.AmqpSupport

W

write(UTF8Buffer) - Method in class org.apache.activemq.transport.amqp.message.UTF8BufferType
writeConstructor() - Method in class org.apache.activemq.transport.amqp.message.UTF8BufferType.UTF8BufferEncoding
writeSize(UTF8Buffer) - Method in class org.apache.activemq.transport.amqp.message.UTF8BufferType.LargeUTF8BufferEncoding
writeSize(UTF8Buffer) - Method in class org.apache.activemq.transport.amqp.message.UTF8BufferType.SmallUTF8BufferEncoding
writeSize(UTF8Buffer) - Method in class org.apache.activemq.transport.amqp.message.UTF8BufferType.UTF8BufferEncoding: Write the size of the buffer using the appropriate type (byte or int) depending on the encoding type being used.
writeValue(UTF8Buffer) - Method in class org.apache.activemq.transport.amqp.message.UTF8BufferType.UTF8BufferEncoding

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