Index (ActiveMQ :: AMQP 5.11.0.redhat-630283 API)

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

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
ActiveMQJMSVendor - Class in org.apache.activemq.transport.amqp.message
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_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_UUID_PREFIX - Static variable in class org.apache.activemq.transport.amqp.message.AMQPMessageIdHelper
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 Authenitcation 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
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
AMQPNativeInboundTransformer - Class in org.apache.activemq.transport.amqp.message
AMQPNativeInboundTransformer(JMSVendor) - Constructor for class org.apache.activemq.transport.amqp.message.AMQPNativeInboundTransformer
AMQPNativeOutboundTransformer - Class in org.apache.activemq.transport.amqp.message
AMQPNativeOutboundTransformer(JMSVendor) - Constructor for class org.apache.activemq.transport.amqp.message.AMQPNativeOutboundTransformer
AmqpNioSslTransport - Class in org.apache.activemq.transport.amqp
AmqpNioSslTransport(WireFormat, SocketFactory, URI, URI) - Constructor for class org.apache.activemq.transport.amqp.AmqpNioSslTransport
AmqpNioSslTransport(WireFormat, Socket) - 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, SocketFactory, URI, URI) - Constructor for class org.apache.activemq.transport.amqp.AmqpNioTransport
AmqpNioTransport(WireFormat, Socket) - 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 mechanincs 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, String) - 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, boolean, Throwable) - Constructor for exception org.apache.activemq.transport.amqp.AmqpProtocolException
AMQPRawInboundTransformer - Class in org.apache.activemq.transport.amqp.message
AMQPRawInboundTransformer(JMSVendor) - 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
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(JMSVendor) - Constructor for class org.apache.activemq.transport.amqp.message.AutoOutboundTransformer

C

close(ErrorCondition) - Method in class org.apache.activemq.transport.amqp.protocol.AmqpAbstractLink
close() - 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.
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
closeActions - Variable in class org.apache.activemq.transport.amqp.protocol.AmqpAbstractLink
closed - Variable in class org.apache.activemq.transport.amqp.protocol.AmqpAbstractLink
commit() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpAbstractReceiver
commit() - Method in interface org.apache.activemq.transport.amqp.protocol.AmqpLink: Handle work necessary on commit of transacted resources associated with this Link instance.
commit() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpSender
commit() - 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
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.
context - Variable in class org.apache.activemq.transport.amqp.AmqpNioSslTransportFactory
convert(Message) - Method in class org.apache.activemq.transport.amqp.message.JMSMappingOutboundTransformer: Perform the conversion between JMS Message and Proton Message without re-encoding it to array.
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
createBytesMessage() - Method in class org.apache.activemq.transport.amqp.message.ActiveMQJMSVendor
createBytesMessage() - Method in interface org.apache.activemq.transport.amqp.message.JMSVendor
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.
createDestination(String) - Method in class org.apache.activemq.transport.amqp.message.ActiveMQJMSVendor
createDestination(String) - Method in interface org.apache.activemq.transport.amqp.message.JMSVendor
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() - Method in class org.apache.activemq.transport.amqp.message.ActiveMQJMSVendor
createMapMessage() - Method in interface org.apache.activemq.transport.amqp.message.JMSVendor
createMessage() - Method in class org.apache.activemq.transport.amqp.message.ActiveMQJMSVendor
createMessage() - Method in interface org.apache.activemq.transport.amqp.message.JMSVendor
createObjectMessage() - Method in class org.apache.activemq.transport.amqp.message.ActiveMQJMSVendor
createObjectMessage() - Method in interface org.apache.activemq.transport.amqp.message.JMSVendor
createReceiver(Receiver) - Method in class org.apache.activemq.transport.amqp.protocol.AmqpSession
createSender(Sender) - Method in class org.apache.activemq.transport.amqp.protocol.AmqpSession
createStreamMessage() - Method in class org.apache.activemq.transport.amqp.message.ActiveMQJMSVendor
createStreamMessage() - Method in interface org.apache.activemq.transport.amqp.message.JMSVendor
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() - Method in class org.apache.activemq.transport.amqp.message.ActiveMQJMSVendor
createTextMessage() - Method in interface org.apache.activemq.transport.amqp.message.JMSVendor
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_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
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
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
doStart() - Method in class org.apache.activemq.transport.amqp.AmqpNioTransport
doStop(ServiceStopper) - Method in class org.apache.activemq.transport.amqp.AmqpNioTransport

E

EncodedMessage - Class in org.apache.activemq.transport.amqp.message
EncodedMessage(long, byte[], int, int) - Constructor for class org.apache.activemq.transport.amqp.message.EncodedMessage
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.
flow() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpAbstractReceiver
flow(int) - Method in class org.apache.activemq.transport.amqp.protocol.AmqpAbstractReceiver: Provide the receiver endpoint with the given amount of credits.
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
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.

G

getAmqpTransport() - Method in class org.apache.activemq.transport.amqp.AmqpInactivityMonitor
getArray() - Method in class org.apache.activemq.transport.amqp.message.EncodedMessage
getArrayOffset() - Method in class org.apache.activemq.transport.amqp.message.EncodedMessage
getBuffer() - Method in class org.apache.activemq.transport.amqp.AmqpHeader
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.
getConsumerId() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpSender
getDefaultDeliveryMode() - Method in class org.apache.activemq.transport.amqp.message.InboundTransformer
getDefaultPriority() - Method in class org.apache.activemq.transport.amqp.message.InboundTransformer
getDefaultTtl() - Method in class org.apache.activemq.transport.amqp.message.InboundTransformer
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
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
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
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
getMaxAmqpFrameSize() - Method in class org.apache.activemq.transport.amqp.AmqpWireFormat
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.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
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
getPrefixVendor() - Method in class org.apache.activemq.transport.amqp.message.InboundTransformer
getPrefixVendor() - Method in class org.apache.activemq.transport.amqp.message.OutboundTransformer
getProducerCredit() - Method in class org.apache.activemq.transport.amqp.AmqpTransportFilter
getProducerCredit() - Method in class org.apache.activemq.transport.amqp.AmqpWireFormat
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
getRemoteAddress() - Method in interface org.apache.activemq.transport.amqp.AmqpTransport
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
getSupportedMechanisms() - Method in class org.apache.activemq.transport.amqp.sasl.AmqpAuthenticator
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.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
getUsername() - Method in class org.apache.activemq.transport.amqp.sasl.AbstractSaslMechanism
getUsername() - Method in interface org.apache.activemq.transport.amqp.sasl.SaslMechanism
getVendor() - Method in class org.apache.activemq.transport.amqp.message.InboundTransformer
getVendor() - Method in class org.apache.activemq.transport.amqp.message.OutboundTransformer
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

H

handleException(IOException) - Method in class org.apache.activemq.transport.amqp.AmqpTransportFilter
hasValidPrefix() - Method in class org.apache.activemq.transport.amqp.AmqpHeader

I

InboundTransformer - Class in org.apache.activemq.transport.amqp.message
InboundTransformer(JMSVendor) - 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.ActiveMQJMSVendor
INSTANCE - Static variable in class org.apache.activemq.transport.amqp.message.AMQPMessageIdHelper
INVALID_FIELD - Static variable in class org.apache.activemq.transport.amqp.AmqpSupport
isAllowNonSaslConnections() - Method in class org.apache.activemq.transport.amqp.AmqpWireFormat
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
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
isHeaderValid(AmqpHeader) - 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
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_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(JMSVendor) - Constructor for class org.apache.activemq.transport.amqp.message.JMSMappingInboundTransformer
JMSMappingOutboundTransformer - Class in org.apache.activemq.transport.amqp.message
JMSMappingOutboundTransformer(JMSVendor) - Constructor for class org.apache.activemq.transport.amqp.message.JMSMappingOutboundTransformer
JMSVendor - Interface in org.apache.activemq.transport.amqp.message

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

LEGACY_JMS_DEST_TYPE_MSG_ANNOTATION - Static variable in class org.apache.activemq.transport.amqp.message.JMSMappingOutboundTransformer
LEGACY_JMS_REPLY_TO_TYPE_MSG_ANNOTATION - Static variable in class org.apache.activemq.transport.amqp.message.JMSMappingOutboundTransformer
LEGACY_QUEUE_TYPE - Static variable in class org.apache.activemq.transport.amqp.message.JMSMappingOutboundTransformer
LEGACY_TEMP_QUEUE_TYPE - Static variable in class org.apache.activemq.transport.amqp.message.JMSMappingOutboundTransformer
LEGACY_TEMP_TOPIC_TYPE - Static variable in class org.apache.activemq.transport.amqp.message.JMSMappingOutboundTransformer
LEGACY_TOPIC_TYPE - Static variable in class org.apache.activemq.transport.amqp.message.JMSMappingOutboundTransformer
LIFETIME_POLICY - Static variable in class org.apache.activemq.transport.amqp.AmqpSupport

M

marshal(Object) - Method in class org.apache.activemq.transport.amqp.AmqpWireFormat
marshal(Object, DataOutput) - Method in class org.apache.activemq.transport.amqp.AmqpWireFormat

N

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

O

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 porcessing.
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
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
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.ResponseHandler: Called when the Broker has handled a previously issued request and has a response ready.
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
OutboundTransformer - Class in org.apache.activemq.transport.amqp.message
OutboundTransformer(JMSVendor) - Constructor for class org.apache.activemq.transport.amqp.message.OutboundTransformer

P

parse(ByteBuffer) - Method in class org.apache.activemq.transport.amqp.AmqpFrameParser
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(Message, Message) - Method in class org.apache.activemq.transport.amqp.message.InboundTransformer
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, Buffer) - Method in class org.apache.activemq.transport.amqp.protocol.AmqpAbstractReceiver
processDelivery(Delivery) - Method in class org.apache.activemq.transport.amqp.protocol.AmqpConnection
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
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.

Q

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

recvBuffer - Variable in class org.apache.activemq.transport.amqp.protocol.AmqpAbstractReceiver
registerSender(ConsumerId, AmqpSender) - Method in class org.apache.activemq.transport.amqp.protocol.AmqpSession
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: 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() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpAbstractReceiver
rollback() - Method in interface org.apache.activemq.transport.amqp.protocol.AmqpLink: Handle work necessary on rollback of transacted resources associated with this Link instance.
rollback() - Method in class org.apache.activemq.transport.amqp.protocol.AmqpSender
rollback() - 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.
sendToActiveMQ(Command) - Method in interface org.apache.activemq.transport.amqp.AmqpTransport
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 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
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
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
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
setDefaultDeliveryMode(int) - Method in class org.apache.activemq.transport.amqp.message.InboundTransformer
setDefaultPriority(int) - Method in class org.apache.activemq.transport.amqp.message.InboundTransformer
setDefaultTtl(long) - Method in class org.apache.activemq.transport.amqp.message.InboundTransformer
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
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
setJMSXDeliveryCount(Message, long) - Method in class org.apache.activemq.transport.amqp.message.ActiveMQJMSVendor
setJMSXDeliveryCount(Message, long) - Method in interface org.apache.activemq.transport.amqp.message.JMSVendor
setJMSXGroupID(Message, String) - Method in class org.apache.activemq.transport.amqp.message.ActiveMQJMSVendor
setJMSXGroupID(Message, String) - Method in interface org.apache.activemq.transport.amqp.message.JMSVendor
setJMSXGroupSequence(Message, int) - Method in class org.apache.activemq.transport.amqp.message.ActiveMQJMSVendor
setJMSXGroupSequence(Message, int) - Method in interface org.apache.activemq.transport.amqp.message.JMSVendor
setJMSXUserID(Message, String) - Method in class org.apache.activemq.transport.amqp.message.ActiveMQJMSVendor
setJMSXUserID(Message, String) - Method in interface org.apache.activemq.transport.amqp.message.JMSVendor
setMajor(int) - Method in class org.apache.activemq.transport.amqp.AmqpHeader
setMaxAmqpFrameSize(int) - Method in class org.apache.activemq.transport.amqp.AmqpWireFormat
setMaxFrameSize(long) - Method in class org.apache.activemq.transport.amqp.AmqpTransportFilter
setMaxFrameSize(long) - Method in class org.apache.activemq.transport.amqp.AmqpWireFormat
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
setPrefixVendor(String) - Method in class org.apache.activemq.transport.amqp.message.InboundTransformer
setPrefixVendor(String) - Method in class org.apache.activemq.transport.amqp.message.OutboundTransformer
setProducerCredit(int) - Method in class org.apache.activemq.transport.amqp.AmqpTransportFilter
setProducerCredit(int) - Method in class org.apache.activemq.transport.amqp.AmqpWireFormat
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
setVendor(JMSVendor) - Method in class org.apache.activemq.transport.amqp.message.InboundTransformer
setVendor(JMSVendor) - Method in class org.apache.activemq.transport.amqp.message.OutboundTransformer
setVersion(int) - Method in class org.apache.activemq.transport.amqp.AmqpWireFormat
setWireFormat(AmqpWireFormat) - Method in class org.apache.activemq.transport.amqp.AmqpFrameParser
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
toAddress(Destination) - Method in class org.apache.activemq.transport.amqp.message.ActiveMQJMSVendor
toAddress(Destination) - Method in interface org.apache.activemq.transport.amqp.message.JMSVendor
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_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(EncodedMessage) - Method in class org.apache.activemq.transport.amqp.message.AMQPNativeInboundTransformer
transform(Message) - Method in class org.apache.activemq.transport.amqp.message.AMQPNativeOutboundTransformer
transform(EncodedMessage) - Method in class org.apache.activemq.transport.amqp.message.AMQPRawInboundTransformer
transform(Message) - Method in class org.apache.activemq.transport.amqp.message.AutoOutboundTransformer
transform(EncodedMessage) - Method in class org.apache.activemq.transport.amqp.message.InboundTransformer
transform(EncodedMessage) - Method in class org.apache.activemq.transport.amqp.message.JMSMappingInboundTransformer
transform(Message) - Method in class org.apache.activemq.transport.amqp.message.JMSMappingOutboundTransformer
transform(Message) - Method in class org.apache.activemq.transport.amqp.message.OutboundTransformer
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(ByteSequence) - Method in class org.apache.activemq.transport.amqp.AmqpWireFormat
unmarshal(DataInput) - 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

V

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

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