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 

Copyright © 2005–2018 FuseSource, Corp.. All rights reserved.