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

A

ABORT - Static variable in interface org.apache.activemq.transport.stomp.Stomp.Commands
 
ABORT_TRANSACTION - Static variable in interface org.apache.activemq.transport.stomp.Stomp.Commands
 
AbstractDeadLetterStrategy - Class in org.apache.activemq.broker.region.policy
A strategy for choosing which destination is used for dead letter queue messages.
AbstractDeadLetterStrategy() - Constructor for class org.apache.activemq.broker.region.policy.AbstractDeadLetterStrategy
 
AbstractPendingMessageCursor - Class in org.apache.activemq.broker.region.cursors
Abstract method holder for pending message (messages awaiting disptach to a consumer) cursor
AbstractPendingMessageCursor() - Constructor for class org.apache.activemq.broker.region.cursors.AbstractPendingMessageCursor
 
AbstractRegion - Class in org.apache.activemq.broker.region
 
AbstractRegion(RegionBroker, DestinationStatistics, SystemUsage, TaskRunnerFactory, DestinationFactory) - Constructor for class org.apache.activemq.broker.region.AbstractRegion
 
AbstractStoreCursor - Class in org.apache.activemq.broker.region.cursors
Store based cursor
AbstractStoreCursor(Destination) - Constructor for class org.apache.activemq.broker.region.cursors.AbstractStoreCursor
 
AbstractSubscription - Class in org.apache.activemq.broker.region
 
AbstractSubscription(Broker, ConnectionContext, ConsumerInfo) - Constructor for class org.apache.activemq.broker.region.AbstractSubscription
 
AbstractTempRegion - Class in org.apache.activemq.broker.region
 
AbstractTempRegion(RegionBroker, DestinationStatistics, SystemUsage, TaskRunnerFactory, DestinationFactory) - Constructor for class org.apache.activemq.broker.region.AbstractTempRegion
 
accessorPool - Variable in class org.apache.activemq.kaha.impl.async.AsyncDataManager
 
ACK - Static variable in interface org.apache.activemq.transport.stomp.Stomp.Commands
 
ACK_MODE - Static variable in interface org.apache.activemq.transport.stomp.Stomp.Headers.Subscribe
 
ACK_OPERATION_TYPE - Static variable in class org.apache.activemq.store.amq.AMQTxOperation
 
ackContainer - Variable in class org.apache.activemq.store.kahadaptor.KahaTopicMessageStore
 
ackContainer - Variable in class org.apache.activemq.store.kahadaptor.KahaTopicReferenceStore
 
acknowledge() - Method in class org.apache.activemq.ActiveMQMessageConsumer
Acknowledge all the messages that have been delivered to the client upto this point.
acknowledge() - Method in class org.apache.activemq.ActiveMQSession
Acknowledges all consumed messages of the session of this consumed message.
acknowledge(ConsumerBrokerExchange, MessageAck) - Method in class org.apache.activemq.broker.BrokerBroadcaster
 
acknowledge(ConsumerBrokerExchange, MessageAck) - Method in class org.apache.activemq.broker.BrokerFilter
 
acknowledge(ConsumerBrokerExchange, MessageAck) - Method in class org.apache.activemq.broker.EmptyBroker
 
acknowledge(ConsumerBrokerExchange, MessageAck) - Method in class org.apache.activemq.broker.ErrorBroker
 
acknowledge(ConsumerBrokerExchange, MessageAck) - Method in class org.apache.activemq.broker.ft.MasterBroker
 
acknowledge(ConsumerBrokerExchange, MessageAck) - Method in class org.apache.activemq.broker.MutableBrokerFilter
 
acknowledge(ConsumerBrokerExchange, MessageAck) - Method in class org.apache.activemq.broker.region.AbstractRegion
 
acknowledge(ConnectionContext, Subscription, MessageAck, MessageReference) - Method in interface org.apache.activemq.broker.region.Destination
 
acknowledge(ConnectionContext, Subscription, MessageAck, MessageReference) - Method in class org.apache.activemq.broker.region.DestinationFilter
 
acknowledge(ConnectionContext, MessageAck, MessageReference) - Method in class org.apache.activemq.broker.region.DurableTopicSubscription
 
acknowledge(ConnectionContext, MessageAck) - Method in class org.apache.activemq.broker.region.PrefetchSubscription
 
acknowledge(ConnectionContext, MessageAck, MessageReference) - Method in class org.apache.activemq.broker.region.PrefetchSubscription
Used during acknowledgment to remove the message.
acknowledge(ConnectionContext, Subscription, MessageAck, MessageReference) - Method in class org.apache.activemq.broker.region.Queue
 
acknowledge(ConnectionContext, MessageAck, MessageReference) - Method in class org.apache.activemq.broker.region.QueueBrowserSubscription
Since we are a browser we don't really remove the message from the queue.
acknowledge(ConnectionContext, MessageAck, MessageReference) - Method in class org.apache.activemq.broker.region.QueueSubscription
In the queue case, mark the node as dropped and then a gc cycle will remove it from the queue.
acknowledge(ConsumerBrokerExchange, MessageAck) - Method in interface org.apache.activemq.broker.region.Region
Used to acknowledge the receipt of a message by a client.
acknowledge(ConsumerBrokerExchange, MessageAck) - Method in class org.apache.activemq.broker.region.RegionBroker
 
acknowledge(ConnectionContext, MessageAck) - Method in interface org.apache.activemq.broker.region.Subscription
Used when client acknowledge receipt of dispatched message.
acknowledge(ConnectionContext, Subscription, MessageAck, MessageReference) - Method in class org.apache.activemq.broker.region.Topic
 
acknowledge(ConnectionContext, MessageAck) - Method in class org.apache.activemq.broker.region.TopicSubscription
 
acknowledge(ConsumerBrokerExchange, MessageAck) - Method in class org.apache.activemq.broker.TransactionBroker
 
acknowledge(ConsumerBrokerExchange, MessageAck) - Method in class org.apache.activemq.broker.util.LoggingBrokerPlugin
 
acknowledge(ConsumerBrokerExchange, MessageAck) - Method in class org.apache.activemq.broker.util.UDPTraceBrokerPlugin
 
acknowledge() - Method in class org.apache.activemq.command.ActiveMQMessage
 
acknowledge(ConnectionContext, String, String, MessageId) - Method in class org.apache.activemq.store.amq.AMQTopicMessageStore
 
acknowledge(ConnectionContext, MessageId, Location, String, String) - Method in class org.apache.activemq.store.amq.AMQTopicMessageStore
 
acknowledge(AMQTopicMessageStore, JournalTopicAck, Location) - Method in class org.apache.activemq.store.amq.AMQTransactionStore
 
acknowledge(ConnectionContext, String, String, MessageId) - Method in class org.apache.activemq.store.jdbc.JDBCTopicMessageStore
 
acknowledge(ConnectionContext, String, String, MessageId) - Method in class org.apache.activemq.store.journal.JournalTopicMessageStore
 
acknowledge(MessageId, RecordLocation, SubscriptionKey) - Method in class org.apache.activemq.store.journal.JournalTopicMessageStore
 
acknowledge(JournalTopicMessageStore, JournalTopicAck, RecordLocation) - Method in class org.apache.activemq.store.journal.JournalTransactionStore
 
acknowledge(ConnectionContext, String, String, MessageId) - Method in class org.apache.activemq.store.kahadaptor.KahaTopicMessageStore
 
acknowledge(ConnectionContext, String, String, MessageId) - Method in class org.apache.activemq.store.kahadaptor.KahaTopicReferenceStore
 
acknowledge(ConnectionContext, String, String, MessageId) - Method in class org.apache.activemq.store.memory.MemoryTopicMessageStore
 
acknowledge(ConnectionContext, String, String, MessageId) - Method in class org.apache.activemq.store.ProxyTopicMessageStore
 
acknowledge(ConnectionContext, String, String, MessageId) - Method in interface org.apache.activemq.store.TopicMessageStore
Stores the last acknowledged messgeID for the given subscription so that we can recover and commence dispatching messages from the last checkpoint
acknowledgeCallback - Variable in class org.apache.activemq.command.ActiveMQMessage
 
acknowledgementMode - Variable in class org.apache.activemq.ActiveMQSession
 
acknowledgeReference(ConnectionContext, String, String, MessageId) - Method in class org.apache.activemq.store.kahadaptor.KahaTopicReferenceStore
 
acknowledgeReference(ConnectionContext, String, String, MessageId) - Method in interface org.apache.activemq.store.TopicReferenceStore
Removes the last acknowledged messgeID for the given subscription so that we can recover and commence dispatching messages from the last checkpoint N.B.
ackType - Variable in class org.apache.activemq.command.MessageAck
 
activate(SystemUsage, ConnectionContext, ConsumerInfo) - Method in class org.apache.activemq.broker.region.DurableTopicSubscription
 
activate(ConnectionContext, DurableTopicSubscription) - Method in class org.apache.activemq.broker.region.Topic
 
ACTIVE - Static variable in interface org.apache.activemq.kaha.impl.data.Item
 
ACTIVEMQ_BLOB_MESSAGE - Static variable in interface org.apache.activemq.command.CommandTypes
 
ACTIVEMQ_BYTES_MESSAGE - Static variable in interface org.apache.activemq.command.CommandTypes
 
ACTIVEMQ_LOCAL_TRANSACTION_ID - Static variable in interface org.apache.activemq.command.CommandTypes
 
ACTIVEMQ_MAP_MESSAGE - Static variable in interface org.apache.activemq.command.CommandTypes
 
ACTIVEMQ_MESSAGE - Static variable in interface org.apache.activemq.command.CommandTypes
 
ACTIVEMQ_OBJECT_MESSAGE - Static variable in interface org.apache.activemq.command.CommandTypes
 
ACTIVEMQ_QUEUE - Static variable in interface org.apache.activemq.command.CommandTypes
 
ACTIVEMQ_STREAM_MESSAGE - Static variable in interface org.apache.activemq.command.CommandTypes
 
ACTIVEMQ_TEMP_QUEUE - Static variable in interface org.apache.activemq.command.CommandTypes
 
ACTIVEMQ_TEMP_TOPIC - Static variable in interface org.apache.activemq.command.CommandTypes
 
ACTIVEMQ_TEXT_MESSAGE - Static variable in interface org.apache.activemq.command.CommandTypes
 
ACTIVEMQ_TOPIC - Static variable in interface org.apache.activemq.command.CommandTypes
 
ACTIVEMQ_XA_TRANSACTION_ID - Static variable in interface org.apache.activemq.command.CommandTypes
 
ActiveMQBlobMessage - Class in org.apache.activemq.command
An implementation of BlobMessage for out of band BLOB transfer
ActiveMQBlobMessage() - Constructor for class org.apache.activemq.command.ActiveMQBlobMessage
 
ActiveMQBlobMessageMarshaller - Class in org.apache.activemq.openwire.v3
Marshalling code for Open Wire Format for ActiveMQBlobMessageMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
ActiveMQBlobMessageMarshaller() - Constructor for class org.apache.activemq.openwire.v3.ActiveMQBlobMessageMarshaller
 
ActiveMQBytesMessage - Class in org.apache.activemq.command
A BytesMessage object is used to send a message containing a stream of uninterpreted bytes.
ActiveMQBytesMessage() - Constructor for class org.apache.activemq.command.ActiveMQBytesMessage
 
ActiveMQBytesMessageMarshaller - Class in org.apache.activemq.openwire.v1
Marshalling code for Open Wire Format for ActiveMQBytesMessageMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
ActiveMQBytesMessageMarshaller() - Constructor for class org.apache.activemq.openwire.v1.ActiveMQBytesMessageMarshaller
 
ActiveMQBytesMessageMarshaller - Class in org.apache.activemq.openwire.v2
Marshalling code for Open Wire Format for ActiveMQBytesMessageMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
ActiveMQBytesMessageMarshaller() - Constructor for class org.apache.activemq.openwire.v2.ActiveMQBytesMessageMarshaller
 
ActiveMQBytesMessageMarshaller - Class in org.apache.activemq.openwire.v3
Marshalling code for Open Wire Format for ActiveMQBytesMessageMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
ActiveMQBytesMessageMarshaller() - Constructor for class org.apache.activemq.openwire.v3.ActiveMQBytesMessageMarshaller
 
ActiveMQConnection - Class in org.apache.activemq
 
ActiveMQConnection(Transport, IdGenerator, JMSStatsImpl) - Constructor for class org.apache.activemq.ActiveMQConnection
Construct an ActiveMQConnection
ActiveMQConnectionConsumer - Class in org.apache.activemq
For application servers, Connection objects provide a special facility for creating a ConnectionConsumer (optional).
ActiveMQConnectionConsumer(ActiveMQConnection, ServerSessionPool, ConsumerInfo) - Constructor for class org.apache.activemq.ActiveMQConnectionConsumer
Create a ConnectionConsumer
ActiveMQConnectionFactory - Class in org.apache.activemq
A ConnectionFactory is an an Administered object, and is used for creating Connections.
ActiveMQConnectionFactory() - Constructor for class org.apache.activemq.ActiveMQConnectionFactory
 
ActiveMQConnectionFactory(String) - Constructor for class org.apache.activemq.ActiveMQConnectionFactory
 
ActiveMQConnectionFactory(URI) - Constructor for class org.apache.activemq.ActiveMQConnectionFactory
 
ActiveMQConnectionFactory(String, String, URI) - Constructor for class org.apache.activemq.ActiveMQConnectionFactory
 
ActiveMQConnectionFactory(String, String, String) - Constructor for class org.apache.activemq.ActiveMQConnectionFactory
 
ActiveMQConnectionFactory - Class in org.apache.activemq.spring
A Spring enhanced connection factory which will automatically use the Spring bean name as the clientIDPrefix property so that connections created have client IDs related to your Spring.xml file for easier comprehension from JMX.
ActiveMQConnectionFactory() - Constructor for class org.apache.activemq.spring.ActiveMQConnectionFactory
 
ActiveMQConnectionFactoryFactoryBean - Class in org.apache.activemq.spring
A helper class for creating a failover configured ActiveMQConnectionFactory which supports one or more TCP based hostname/ports which can all be configured in a consistent way without too much URL hacking.
ActiveMQConnectionFactoryFactoryBean() - Constructor for class org.apache.activemq.spring.ActiveMQConnectionFactoryFactoryBean
 
ActiveMQConnectionMetaData - Class in org.apache.activemq
A ConnectionMetaData object provides information describing the Connection object.
ActiveMQDestination - Class in org.apache.activemq.command
 
ActiveMQDestination() - Constructor for class org.apache.activemq.command.ActiveMQDestination
 
ActiveMQDestination(String) - Constructor for class org.apache.activemq.command.ActiveMQDestination
 
ActiveMQDestination(ActiveMQDestination[]) - Constructor for class org.apache.activemq.command.ActiveMQDestination
 
ActiveMQDestinationMarshaller - Class in org.apache.activemq.openwire.v1
Marshalling code for Open Wire Format for ActiveMQDestinationMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
ActiveMQDestinationMarshaller() - Constructor for class org.apache.activemq.openwire.v1.ActiveMQDestinationMarshaller
 
ActiveMQDestinationMarshaller - Class in org.apache.activemq.openwire.v2
Marshalling code for Open Wire Format for ActiveMQDestinationMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
ActiveMQDestinationMarshaller() - Constructor for class org.apache.activemq.openwire.v2.ActiveMQDestinationMarshaller
 
ActiveMQDestinationMarshaller - Class in org.apache.activemq.openwire.v3
Marshalling code for Open Wire Format for ActiveMQDestinationMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
ActiveMQDestinationMarshaller() - Constructor for class org.apache.activemq.openwire.v3.ActiveMQDestinationMarshaller
 
ActiveMQDispatcher - Interface in org.apache.activemq
 
ActiveMQInitialContextFactory - Class in org.apache.activemq.jndi
A factory of the ActiveMQ InitialContext which contains ConnectionFactory instances as well as a child context called destinations which contain all of the current active destinations, in child context depending on the QoS such as transient or durable and queue or topic.
ActiveMQInitialContextFactory() - Constructor for class org.apache.activemq.jndi.ActiveMQInitialContextFactory
 
ActiveMQInputStream - Class in org.apache.activemq
 
ActiveMQInputStream(ActiveMQConnection, ConsumerId, ActiveMQDestination, String, boolean, String, int) - Constructor for class org.apache.activemq.ActiveMQInputStream
 
ActiveMQMapMessage - Class in org.apache.activemq.command
A MapMessage object is used to send a set of name-value pairs.
ActiveMQMapMessage() - Constructor for class org.apache.activemq.command.ActiveMQMapMessage
 
ActiveMQMapMessageMarshaller - Class in org.apache.activemq.openwire.v1
Marshalling code for Open Wire Format for ActiveMQMapMessageMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
ActiveMQMapMessageMarshaller() - Constructor for class org.apache.activemq.openwire.v1.ActiveMQMapMessageMarshaller
 
ActiveMQMapMessageMarshaller - Class in org.apache.activemq.openwire.v2
Marshalling code for Open Wire Format for ActiveMQMapMessageMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
ActiveMQMapMessageMarshaller() - Constructor for class org.apache.activemq.openwire.v2.ActiveMQMapMessageMarshaller
 
ActiveMQMapMessageMarshaller - Class in org.apache.activemq.openwire.v3
Marshalling code for Open Wire Format for ActiveMQMapMessageMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
ActiveMQMapMessageMarshaller() - Constructor for class org.apache.activemq.openwire.v3.ActiveMQMapMessageMarshaller
 
ActiveMQMessage - Class in org.apache.activemq.command
 
ActiveMQMessage() - Constructor for class org.apache.activemq.command.ActiveMQMessage
 
ActiveMQMessageAudit - Class in org.apache.activemq
Provides basic audit functions for Messages
ActiveMQMessageAudit() - Constructor for class org.apache.activemq.ActiveMQMessageAudit
Default Constructor windowSize = 1024, maximumNumberOfProducersToTrack = 128
ActiveMQMessageAudit(int, int) - Constructor for class org.apache.activemq.ActiveMQMessageAudit
Construct a MessageAudit
ActiveMQMessageConsumer - Class in org.apache.activemq
A client uses a MessageConsumer object to receive messages from a destination.
ActiveMQMessageConsumer(ActiveMQSession, ConsumerId, ActiveMQDestination, String, String, int, int, boolean, boolean, boolean, MessageListener) - Constructor for class org.apache.activemq.ActiveMQMessageConsumer
Create a MessageConsumer
ActiveMQMessageMarshaller - Class in org.apache.activemq.openwire.v1
Marshalling code for Open Wire Format for ActiveMQMessageMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
ActiveMQMessageMarshaller() - Constructor for class org.apache.activemq.openwire.v1.ActiveMQMessageMarshaller
 
ActiveMQMessageMarshaller - Class in org.apache.activemq.openwire.v2
Marshalling code for Open Wire Format for ActiveMQMessageMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
ActiveMQMessageMarshaller() - Constructor for class org.apache.activemq.openwire.v2.ActiveMQMessageMarshaller
 
ActiveMQMessageMarshaller - Class in org.apache.activemq.openwire.v3
Marshalling code for Open Wire Format for ActiveMQMessageMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
ActiveMQMessageMarshaller() - Constructor for class org.apache.activemq.openwire.v3.ActiveMQMessageMarshaller
 
ActiveMQMessageProducer - Class in org.apache.activemq
A client uses a MessageProducer object to send messages to a destination.
ActiveMQMessageProducer(ActiveMQSession, ProducerId, ActiveMQDestination, int) - Constructor for class org.apache.activemq.ActiveMQMessageProducer
 
ActiveMQMessageProducerSupport - Class in org.apache.activemq
A useful base class for implementing a MessageProducer
ActiveMQMessageProducerSupport(ActiveMQSession) - Constructor for class org.apache.activemq.ActiveMQMessageProducerSupport
 
ActiveMQMessageTransformation - Class in org.apache.activemq
A helper class for converting normal JMS interfaces into ActiveMQ specific ones.
ActiveMQMessageUtils - Class in org.apache.activemq.util
Message utilities
ActiveMQMessageUtils() - Constructor for class org.apache.activemq.util.ActiveMQMessageUtils
 
ActiveMQObjectMessage - Class in org.apache.activemq.command
An ObjectMessage object is used to send a message that contains a serializable object in the Java programming language ("Java object").
ActiveMQObjectMessage() - Constructor for class org.apache.activemq.command.ActiveMQObjectMessage
 
ActiveMQObjectMessageMarshaller - Class in org.apache.activemq.openwire.v1
Marshalling code for Open Wire Format for ActiveMQObjectMessageMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
ActiveMQObjectMessageMarshaller() - Constructor for class org.apache.activemq.openwire.v1.ActiveMQObjectMessageMarshaller
 
ActiveMQObjectMessageMarshaller - Class in org.apache.activemq.openwire.v2
Marshalling code for Open Wire Format for ActiveMQObjectMessageMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
ActiveMQObjectMessageMarshaller() - Constructor for class org.apache.activemq.openwire.v2.ActiveMQObjectMessageMarshaller
 
ActiveMQObjectMessageMarshaller - Class in org.apache.activemq.openwire.v3
Marshalling code for Open Wire Format for ActiveMQObjectMessageMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
ActiveMQObjectMessageMarshaller() - Constructor for class org.apache.activemq.openwire.v3.ActiveMQObjectMessageMarshaller
 
ActiveMQOutputStream - Class in org.apache.activemq
 
ActiveMQOutputStream(ActiveMQConnection, ProducerId, ActiveMQDestination, Map<String, Object>, int, int, long) - Constructor for class org.apache.activemq.ActiveMQOutputStream
 
ActiveMQPrefetchPolicy - Class in org.apache.activemq
Defines the prefetch message policies for different types of consumers
ActiveMQPrefetchPolicy() - Constructor for class org.apache.activemq.ActiveMQPrefetchPolicy
Initialize default prefetch policies
ActiveMQQueue - Class in org.apache.activemq.command
 
ActiveMQQueue() - Constructor for class org.apache.activemq.command.ActiveMQQueue
 
ActiveMQQueue(String) - Constructor for class org.apache.activemq.command.ActiveMQQueue
 
ActiveMQQueueBrowser - Class in org.apache.activemq
A client uses a QueueBrowser object to look at messages on a queue without removing them.
ActiveMQQueueBrowser(ActiveMQSession, ConsumerId, ActiveMQDestination, String, boolean) - Constructor for class org.apache.activemq.ActiveMQQueueBrowser
Constructor for an ActiveMQQueueBrowser - used internally
ActiveMQQueueMarshaller - Class in org.apache.activemq.openwire.v1
Marshalling code for Open Wire Format for ActiveMQQueueMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
ActiveMQQueueMarshaller() - Constructor for class org.apache.activemq.openwire.v1.ActiveMQQueueMarshaller
 
ActiveMQQueueMarshaller - Class in org.apache.activemq.openwire.v2
Marshalling code for Open Wire Format for ActiveMQQueueMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
ActiveMQQueueMarshaller() - Constructor for class org.apache.activemq.openwire.v2.ActiveMQQueueMarshaller
 
ActiveMQQueueMarshaller - Class in org.apache.activemq.openwire.v3
Marshalling code for Open Wire Format for ActiveMQQueueMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
ActiveMQQueueMarshaller() - Constructor for class org.apache.activemq.openwire.v3.ActiveMQQueueMarshaller
 
ActiveMQQueueReceiver - Class in org.apache.activemq
A client uses a QueueReceiver object to receive messages that have been delivered to a queue.
ActiveMQQueueReceiver(ActiveMQSession, ConsumerId, ActiveMQDestination, String, int, int, boolean) - Constructor for class org.apache.activemq.ActiveMQQueueReceiver
 
ActiveMQQueueSender - Class in org.apache.activemq
A client uses a QueueSender object to send messages to a queue.
ActiveMQQueueSender(ActiveMQSession, ActiveMQDestination, int) - Constructor for class org.apache.activemq.ActiveMQQueueSender
 
ActiveMQQueueSession - Class in org.apache.activemq
A QueueSession implementation that throws IllegalStateExceptions when Topic operations are attempted but which delegates to another QueueSession for all other operations.
ActiveMQQueueSession(QueueSession) - Constructor for class org.apache.activemq.ActiveMQQueueSession
 
ActiveMQSession - Class in org.apache.activemq
A Session object is a single-threaded context for producing and consuming messages.
ActiveMQSession(ActiveMQConnection, SessionId, int, boolean, boolean) - Constructor for class org.apache.activemq.ActiveMQSession
Construct the Session
ActiveMQSession(ActiveMQConnection, SessionId, int, boolean) - Constructor for class org.apache.activemq.ActiveMQSession
 
ActiveMQSession.DeliveryListener - Interface in org.apache.activemq
 
ActiveMQSessionExecutor - Class in org.apache.activemq
A utility class used by the Session for dispatching messages asynchronously to consumers
ActiveMQSslConnectionFactory - Class in org.apache.activemq
An ActiveMQConnectionFactory that allows access to the key and trust managers used for SslConnections.
ActiveMQSslConnectionFactory() - Constructor for class org.apache.activemq.ActiveMQSslConnectionFactory
 
ActiveMQStreamMessage - Class in org.apache.activemq.command
A StreamMessage object is used to send a stream of primitive types in the Java programming language.
ActiveMQStreamMessage() - Constructor for class org.apache.activemq.command.ActiveMQStreamMessage
 
ActiveMQStreamMessageMarshaller - Class in org.apache.activemq.openwire.v1
Marshalling code for Open Wire Format for ActiveMQStreamMessageMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
ActiveMQStreamMessageMarshaller() - Constructor for class org.apache.activemq.openwire.v1.ActiveMQStreamMessageMarshaller
 
ActiveMQStreamMessageMarshaller - Class in org.apache.activemq.openwire.v2
Marshalling code for Open Wire Format for ActiveMQStreamMessageMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
ActiveMQStreamMessageMarshaller() - Constructor for class org.apache.activemq.openwire.v2.ActiveMQStreamMessageMarshaller
 
ActiveMQStreamMessageMarshaller - Class in org.apache.activemq.openwire.v3
Marshalling code for Open Wire Format for ActiveMQStreamMessageMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
ActiveMQStreamMessageMarshaller() - Constructor for class org.apache.activemq.openwire.v3.ActiveMQStreamMessageMarshaller
 
ActiveMQTempDestination - Class in org.apache.activemq.command
 
ActiveMQTempDestination() - Constructor for class org.apache.activemq.command.ActiveMQTempDestination
 
ActiveMQTempDestination(String) - Constructor for class org.apache.activemq.command.ActiveMQTempDestination
 
ActiveMQTempDestination(String, long) - Constructor for class org.apache.activemq.command.ActiveMQTempDestination
 
ActiveMQTempDestinationMarshaller - Class in org.apache.activemq.openwire.v1
Marshalling code for Open Wire Format for ActiveMQTempDestinationMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
ActiveMQTempDestinationMarshaller() - Constructor for class org.apache.activemq.openwire.v1.ActiveMQTempDestinationMarshaller
 
ActiveMQTempDestinationMarshaller - Class in org.apache.activemq.openwire.v2
Marshalling code for Open Wire Format for ActiveMQTempDestinationMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
ActiveMQTempDestinationMarshaller() - Constructor for class org.apache.activemq.openwire.v2.ActiveMQTempDestinationMarshaller
 
ActiveMQTempDestinationMarshaller - Class in org.apache.activemq.openwire.v3
Marshalling code for Open Wire Format for ActiveMQTempDestinationMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
ActiveMQTempDestinationMarshaller() - Constructor for class org.apache.activemq.openwire.v3.ActiveMQTempDestinationMarshaller
 
ActiveMQTempQueue - Class in org.apache.activemq.command
 
ActiveMQTempQueue() - Constructor for class org.apache.activemq.command.ActiveMQTempQueue
 
ActiveMQTempQueue(String) - Constructor for class org.apache.activemq.command.ActiveMQTempQueue
 
ActiveMQTempQueue(ConnectionId, long) - Constructor for class org.apache.activemq.command.ActiveMQTempQueue
 
ActiveMQTempQueueMarshaller - Class in org.apache.activemq.openwire.v1
Marshalling code for Open Wire Format for ActiveMQTempQueueMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
ActiveMQTempQueueMarshaller() - Constructor for class org.apache.activemq.openwire.v1.ActiveMQTempQueueMarshaller
 
ActiveMQTempQueueMarshaller - Class in org.apache.activemq.openwire.v2
Marshalling code for Open Wire Format for ActiveMQTempQueueMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
ActiveMQTempQueueMarshaller() - Constructor for class org.apache.activemq.openwire.v2.ActiveMQTempQueueMarshaller
 
ActiveMQTempQueueMarshaller - Class in org.apache.activemq.openwire.v3
Marshalling code for Open Wire Format for ActiveMQTempQueueMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
ActiveMQTempQueueMarshaller() - Constructor for class org.apache.activemq.openwire.v3.ActiveMQTempQueueMarshaller
 
ActiveMQTempTopic - Class in org.apache.activemq.command
 
ActiveMQTempTopic() - Constructor for class org.apache.activemq.command.ActiveMQTempTopic
 
ActiveMQTempTopic(String) - Constructor for class org.apache.activemq.command.ActiveMQTempTopic
 
ActiveMQTempTopic(ConnectionId, long) - Constructor for class org.apache.activemq.command.ActiveMQTempTopic
 
ActiveMQTempTopicMarshaller - Class in org.apache.activemq.openwire.v1
Marshalling code for Open Wire Format for ActiveMQTempTopicMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
ActiveMQTempTopicMarshaller() - Constructor for class org.apache.activemq.openwire.v1.ActiveMQTempTopicMarshaller
 
ActiveMQTempTopicMarshaller - Class in org.apache.activemq.openwire.v2
Marshalling code for Open Wire Format for ActiveMQTempTopicMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
ActiveMQTempTopicMarshaller() - Constructor for class org.apache.activemq.openwire.v2.ActiveMQTempTopicMarshaller
 
ActiveMQTempTopicMarshaller - Class in org.apache.activemq.openwire.v3
Marshalling code for Open Wire Format for ActiveMQTempTopicMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
ActiveMQTempTopicMarshaller() - Constructor for class org.apache.activemq.openwire.v3.ActiveMQTempTopicMarshaller
 
ActiveMQTextMessage - Class in org.apache.activemq.command
 
ActiveMQTextMessage() - Constructor for class org.apache.activemq.command.ActiveMQTextMessage
 
ActiveMQTextMessageMarshaller - Class in org.apache.activemq.openwire.v1
Marshalling code for Open Wire Format for ActiveMQTextMessageMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
ActiveMQTextMessageMarshaller() - Constructor for class org.apache.activemq.openwire.v1.ActiveMQTextMessageMarshaller
 
ActiveMQTextMessageMarshaller - Class in org.apache.activemq.openwire.v2
Marshalling code for Open Wire Format for ActiveMQTextMessageMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
ActiveMQTextMessageMarshaller() - Constructor for class org.apache.activemq.openwire.v2.ActiveMQTextMessageMarshaller
 
ActiveMQTextMessageMarshaller - Class in org.apache.activemq.openwire.v3
Marshalling code for Open Wire Format for ActiveMQTextMessageMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
ActiveMQTextMessageMarshaller() - Constructor for class org.apache.activemq.openwire.v3.ActiveMQTextMessageMarshaller
 
ActiveMQTopic - Class in org.apache.activemq.command
 
ActiveMQTopic() - Constructor for class org.apache.activemq.command.ActiveMQTopic
 
ActiveMQTopic(String) - Constructor for class org.apache.activemq.command.ActiveMQTopic
 
ActiveMQTopicMarshaller - Class in org.apache.activemq.openwire.v1
Marshalling code for Open Wire Format for ActiveMQTopicMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
ActiveMQTopicMarshaller() - Constructor for class org.apache.activemq.openwire.v1.ActiveMQTopicMarshaller
 
ActiveMQTopicMarshaller - Class in org.apache.activemq.openwire.v2
Marshalling code for Open Wire Format for ActiveMQTopicMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
ActiveMQTopicMarshaller() - Constructor for class org.apache.activemq.openwire.v2.ActiveMQTopicMarshaller
 
ActiveMQTopicMarshaller - Class in org.apache.activemq.openwire.v3
Marshalling code for Open Wire Format for ActiveMQTopicMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
ActiveMQTopicMarshaller() - Constructor for class org.apache.activemq.openwire.v3.ActiveMQTopicMarshaller
 
ActiveMQTopicPublisher - Class in org.apache.activemq
A client uses a TopicPublisher object to publish messages on a topic.
ActiveMQTopicPublisher(ActiveMQSession, ActiveMQDestination, int) - Constructor for class org.apache.activemq.ActiveMQTopicPublisher
 
ActiveMQTopicSession - Class in org.apache.activemq
A TopicSession implementation that throws IllegalStateExceptions when Queue operations are attempted but which delegates to another TopicSession for all other operations.
ActiveMQTopicSession(TopicSession) - Constructor for class org.apache.activemq.ActiveMQTopicSession
 
ActiveMQTopicSubscriber - Class in org.apache.activemq
A client uses a TopicSubscriber object to receive messages that have been published to a topic.
ActiveMQTopicSubscriber(ActiveMQSession, ConsumerId, ActiveMQDestination, String, String, int, int, boolean, boolean, boolean) - Constructor for class org.apache.activemq.ActiveMQTopicSubscriber
 
ActiveMQWASInitialContextFactory - Class in org.apache.activemq.jndi
This implementation of InitialContextFactory should be used when ActiveMQ is used as WebSphere Generic JMS Provider.
ActiveMQWASInitialContextFactory() - Constructor for class org.apache.activemq.jndi.ActiveMQWASInitialContextFactory
 
ActiveMQXAConnection - Class in org.apache.activemq
The XAConnection interface extends the capability of Connection by providing an XASession (optional).
ActiveMQXAConnection(Transport, IdGenerator, JMSStatsImpl) - Constructor for class org.apache.activemq.ActiveMQXAConnection
 
ActiveMQXAConnectionFactory - Class in org.apache.activemq
A factory of XAConnection instances
ActiveMQXAConnectionFactory() - Constructor for class org.apache.activemq.ActiveMQXAConnectionFactory
 
ActiveMQXAConnectionFactory(String, String, String) - Constructor for class org.apache.activemq.ActiveMQXAConnectionFactory
 
ActiveMQXAConnectionFactory(String, String, URI) - Constructor for class org.apache.activemq.ActiveMQXAConnectionFactory
 
ActiveMQXAConnectionFactory(String) - Constructor for class org.apache.activemq.ActiveMQXAConnectionFactory
 
ActiveMQXAConnectionFactory(URI) - Constructor for class org.apache.activemq.ActiveMQXAConnectionFactory
 
ActiveMQXAConnectionFactory - Class in org.apache.activemq.spring
A Spring enhanced XA connection factory which will automatically use the Spring bean name as the clientIDPrefix property so that connections created have client IDs related to your Spring.xml file for easier comprehension from JMX.
ActiveMQXAConnectionFactory() - Constructor for class org.apache.activemq.spring.ActiveMQXAConnectionFactory
 
ActiveMQXASession - Class in org.apache.activemq
The XASession interface extends the capability of Session by adding access to a JMS provider's support for the Java Transaction API (JTA) (optional).
ActiveMQXASession(ActiveMQXAConnection, SessionId, int, boolean) - Constructor for class org.apache.activemq.ActiveMQXASession
 
activeTempDestinations - Variable in class org.apache.activemq.ActiveMQConnection
 
adapter - Variable in class org.apache.activemq.store.jdbc.JDBCMessageStore
 
adapter - Variable in class org.apache.activemq.store.kahadaptor.KahaReferenceStore
 
add(ConnectionContext, Destination) - Method in class org.apache.activemq.broker.region.AbstractSubscription
 
add(ConnectionContext, Destination) - Method in class org.apache.activemq.broker.region.cursors.AbstractPendingMessageCursor
 
add(ConnectionContext, Destination) - Method in interface org.apache.activemq.broker.region.cursors.PendingMessageCursor
Add a destination
add(ConnectionContext, Destination) - Method in class org.apache.activemq.broker.region.cursors.StoreDurableSubscriberCursor
Add a destination
add(ConnectionContext, Destination) - Method in class org.apache.activemq.broker.region.DurableTopicSubscription
 
add(MessageReference) - Method in class org.apache.activemq.broker.region.DurableTopicSubscription
 
add(String) - Method in class org.apache.activemq.broker.region.group.SimpleMessageGroupSet
 
add(ConnectionContext, MessageReference) - Method in class org.apache.activemq.broker.region.policy.FixedCountSubscriptionRecoveryPolicy
 
add(ConnectionContext, MessageReference) - Method in class org.apache.activemq.broker.region.policy.FixedSizedSubscriptionRecoveryPolicy
 
add(ConnectionContext, MessageReference) - Method in class org.apache.activemq.broker.region.policy.LastImageSubscriptionRecoveryPolicy
 
add(ConnectionContext, MessageReference) - Method in class org.apache.activemq.broker.region.policy.NoSubscriptionRecoveryPolicy
 
add(ConnectionContext, MessageReference) - Method in class org.apache.activemq.broker.region.policy.QueryBasedSubscriptionRecoveryPolicy
 
add(ConnectionContext, MessageReference) - Method in interface org.apache.activemq.broker.region.policy.SubscriptionRecoveryPolicy
A message was sent to the destination.
add(ConnectionContext, MessageReference) - Method in class org.apache.activemq.broker.region.policy.TimedSubscriptionRecoveryPolicy
 
add(MessageReference) - Method in class org.apache.activemq.broker.region.PrefetchSubscription
 
add(ConnectionContext, Destination) - Method in class org.apache.activemq.broker.region.PrefetchSubscription
 
add(MessageReference) - Method in interface org.apache.activemq.broker.region.Subscription
Used to add messages that match the subscription.
add(ConnectionContext, Destination) - Method in interface org.apache.activemq.broker.region.Subscription
The subscription will be receiving messages from the destination.
add(MessageReference) - Method in class org.apache.activemq.broker.region.TopicSubscription
 
add(String[], int, Object) - Method in class org.apache.activemq.filter.DestinationMapNode
 
add(Object) - Method in class org.apache.activemq.kaha.impl.container.ContainerEntrySet
 
add(Object) - Method in class org.apache.activemq.kaha.impl.container.ContainerKeySet
 
add(Object) - Method in class org.apache.activemq.kaha.impl.container.ContainerListIterator
 
add(Object) - Method in class org.apache.activemq.kaha.impl.container.ListContainerImpl
 
add(int, Object) - Method in class org.apache.activemq.kaha.impl.container.ListContainerImpl
 
add(IndexItem) - Method in class org.apache.activemq.kaha.impl.index.DiskIndexLinkedList
Appends the specified element to the end of this list.
add(int, IndexItem) - Method in class org.apache.activemq.kaha.impl.index.DiskIndexLinkedList
Inserts the specified element at the specified position in this list.
add(IndexItem) - Method in interface org.apache.activemq.kaha.impl.index.IndexLinkedList
Appends the specified element to the end of this list.
add(int, IndexItem) - Method in interface org.apache.activemq.kaha.impl.index.IndexLinkedList
Inserts the specified element at the specified position in this list.
add(IndexItem) - Method in class org.apache.activemq.kaha.impl.index.VMIndexLinkedList
 
add(int, IndexItem) - Method in class org.apache.activemq.kaha.impl.index.VMIndexLinkedList
 
add(long) - Method in class org.apache.activemq.management.CountStatisticImpl
 
add(MessageReference) - Method in class org.apache.activemq.memory.buffer.MessageQueue
 
add(ActiveMQMessage) - Method in class org.apache.activemq.memory.buffer.MessageQueue
 
add(CacheEntry) - Method in class org.apache.activemq.memory.CacheEntryList
 
add(CacheEvictor) - Method in class org.apache.activemq.memory.CacheEvictionUsageListener
 
add(MessageReference) - Method in class org.apache.activemq.memory.list.DestinationBasedMessageList
 
add(MessageReference) - Method in interface org.apache.activemq.memory.list.MessageList
 
add(MessageReference) - Method in class org.apache.activemq.memory.list.SimpleMessageList
 
add(ConsumerId) - Method in class org.apache.activemq.network.DemandSubscription
Increment the consumers associated with this subscription
add(AMQMessageStore, Message, Location) - Method in class org.apache.activemq.store.amq.AMQTx
 
add(AMQMessageStore, MessageAck) - Method in class org.apache.activemq.store.amq.AMQTx
 
add(AMQTopicMessageStore, JournalTopicAck) - Method in class org.apache.activemq.store.amq.AMQTx
 
add(JournalMessageStore, Message) - Method in class org.apache.activemq.store.journal.JournalTransactionStore.Tx
 
add(JournalMessageStore, MessageAck) - Method in class org.apache.activemq.store.journal.JournalTransactionStore.Tx
 
add(JournalTopicMessageStore, JournalTopicAck) - Method in class org.apache.activemq.store.journal.JournalTransactionStore.Tx
 
add(ConsumerMessageRef) - Method in class org.apache.activemq.store.kahadaptor.TopicSubContainer
 
add(MemoryTransactionStore.AddMessageCommand) - Method in class org.apache.activemq.store.memory.MemoryTransactionStore.Tx
 
add(MemoryTransactionStore.RemoveMessageCommand) - Method in class org.apache.activemq.store.memory.MemoryTransactionStore.Tx
 
add(URI[]) - Method in interface org.apache.activemq.transport.CompositeTransport
 
add(URI[]) - Method in class org.apache.activemq.transport.failover.FailoverTransport
 
add(String) - Method in class org.apache.activemq.transport.failover.FailoverTransport
 
add(URI[]) - Method in class org.apache.activemq.transport.fanout.FanoutTransport
 
add(E) - Method in class org.apache.activemq.util.LRUSet
 
add_escapes(String) - Method in exception org.apache.activemq.selector.ParseException
Used to convert raw characters to their escaped version when these raw version cannot be used as part of an ASCII string literal.
ADD_OPERATION_TYPE - Static variable in class org.apache.activemq.command.DestinationInfo
 
ADD_OPERATION_TYPE - Static variable in class org.apache.activemq.store.amq.AMQTxOperation
 
addAll(Collection) - Method in class org.apache.activemq.kaha.impl.container.ContainerEntrySet
 
addAll(Collection) - Method in class org.apache.activemq.kaha.impl.container.ContainerKeySet
 
addAll(Collection) - Method in class org.apache.activemq.kaha.impl.container.ListContainerImpl
 
addAll(int, Collection) - Method in class org.apache.activemq.kaha.impl.container.ListContainerImpl
 
addAttributeValues(String, Attributes, Set<String>) - Method in class org.apache.activemq.security.LDAPAuthorizationMap
 
addBefore(IndexItem, IndexItem) - Method in class org.apache.activemq.kaha.impl.index.VMIndexLinkedList
 
addBroker(Connection, BrokerInfo) - Method in interface org.apache.activemq.broker.Broker
A remote Broker connects
addBroker(Connection, BrokerInfo) - Method in class org.apache.activemq.broker.BrokerBroadcaster
 
addBroker(Connection, BrokerInfo) - Method in class org.apache.activemq.broker.BrokerFilter
 
addBroker(Connection, BrokerInfo) - Method in class org.apache.activemq.broker.EmptyBroker
 
addBroker(Connection, BrokerInfo) - Method in class org.apache.activemq.broker.ErrorBroker
 
addBroker(Connection, BrokerInfo) - Method in class org.apache.activemq.broker.MutableBrokerFilter
 
addBroker(Connection, BrokerInfo) - Method in class org.apache.activemq.broker.region.RegionBroker
 
addBuffer(int, Object) - Method in class org.apache.activemq.transport.reliable.DefaultReplayBuffer
 
addBuffer(int, Object) - Method in interface org.apache.activemq.transport.reliable.ReplayBuffer
Submit a buffer for caching around for a period of time, during which time it can be replayed to users interested in it.
addCommand(Command) - Method in class org.apache.activemq.state.TransactionState
 
addConnection(ConnectionContext, ConnectionInfo) - Method in class org.apache.activemq.advisory.AdvisoryBroker
 
addConnection(ConnectionContext, ConnectionInfo) - Method in interface org.apache.activemq.broker.Broker
A client is establishing a connection with the broker.
addConnection(ConnectionContext, ConnectionInfo) - Method in class org.apache.activemq.broker.BrokerBroadcaster
 
addConnection(ConnectionContext, ConnectionInfo) - Method in class org.apache.activemq.broker.BrokerFilter
 
addConnection(ConnectionContext, ConnectionInfo) - Method in class org.apache.activemq.broker.EmptyBroker
 
addConnection(ConnectionContext, ConnectionInfo) - Method in class org.apache.activemq.broker.ErrorBroker
 
addConnection(ConnectionContext, ConnectionInfo) - Method in class org.apache.activemq.broker.ft.MasterBroker
A client is establishing a connection with the broker.
addConnection(ConnectionContext, ConnectionInfo) - Method in class org.apache.activemq.broker.MutableBrokerFilter
 
addConnection(ConnectionContext, ConnectionInfo) - Method in class org.apache.activemq.broker.region.RegionBroker
 
addConnection(ConnectionContext, ConnectionInfo) - Method in class org.apache.activemq.broker.util.UDPTraceBrokerPlugin
 
addConnection(ActiveMQConnection) - Method in class org.apache.activemq.management.JMSStatsImpl
 
addConnection(ConnectionContext, ConnectionInfo) - Method in class org.apache.activemq.security.JaasAuthenticationBroker
 
addConnection(ConnectionContext, ConnectionInfo) - Method in class org.apache.activemq.security.JaasCertificateAuthenticationBroker
Overridden to allow for authentication based on client certificates.
addConnection(ConnectionContext, ConnectionInfo) - Method in class org.apache.activemq.security.SimpleAuthenticationBroker
 
addConnectionConsumer(ActiveMQConnectionConsumer) - Method in class org.apache.activemq.ActiveMQConnection
Add a ConnectionConsumer
addConnector(String) - Method in class org.apache.activemq.broker.BrokerService
Adds a new transport connector for the given bind address
addConnector(URI) - Method in class org.apache.activemq.broker.BrokerService
Adds a new transport connector for the given bind address
addConnector(TransportServer) - Method in class org.apache.activemq.broker.BrokerService
Adds a new transport connector for the given TransportServer transport
addConnector(TransportConnector) - Method in class org.apache.activemq.broker.BrokerService
Adds a new transport connector
addConnector(String) - Method in class org.apache.activemq.broker.jmx.BrokerView
 
addConnector(String) - Method in interface org.apache.activemq.broker.jmx.BrokerViewMBean
 
addConnector(SearchResult) - Method in class org.apache.activemq.network.LdapNetworkConnector
add connector of the given URI
addConsumer(ActiveMQMessageConsumer) - Method in class org.apache.activemq.ActiveMQSession
Add a message consumer.
addConsumer(ConnectionContext, ConsumerInfo) - Method in class org.apache.activemq.advisory.AdvisoryBroker
 
addConsumer(ConnectionContext, ConsumerInfo) - Method in class org.apache.activemq.broker.BrokerBroadcaster
 
addConsumer(ConnectionContext, ConsumerInfo) - Method in class org.apache.activemq.broker.BrokerFilter
 
addConsumer(ConnectionContext, ConsumerInfo) - Method in class org.apache.activemq.broker.cluster.ConnectionSplitBroker
 
addConsumer(ConnectionContext, ConsumerInfo) - Method in class org.apache.activemq.broker.EmptyBroker
 
addConsumer(ConnectionContext, ConsumerInfo) - Method in class org.apache.activemq.broker.ErrorBroker
 
addConsumer(ConnectionContext, ConsumerInfo) - Method in class org.apache.activemq.broker.ft.MasterBroker
add a consumer
addConsumer(ConnectionContext, ConsumerInfo) - Method in class org.apache.activemq.broker.MutableBrokerFilter
 
addConsumer(ConnectionContext, ConsumerInfo) - Method in class org.apache.activemq.broker.region.AbstractRegion
 
addConsumer(ConnectionContext, ConsumerInfo) - Method in interface org.apache.activemq.broker.region.Region
Adds a consumer.
addConsumer(ConnectionContext, ConsumerInfo) - Method in class org.apache.activemq.broker.region.RegionBroker
 
addConsumer(ConnectionContext, ConsumerInfo) - Method in class org.apache.activemq.broker.region.TopicRegion
 
addConsumer(ConnectionContext, ConsumerInfo) - Method in class org.apache.activemq.broker.util.UDPTraceBrokerPlugin
 
addConsumer(ConnectionContext, ConsumerInfo) - Method in class org.apache.activemq.broker.view.ConnectionDotFileInterceptor
 
addConsumer(ConnectionContext, ConsumerInfo) - Method in class org.apache.activemq.security.AuthorizationBroker
 
addConsumer(ConsumerInfo) - Method in class org.apache.activemq.state.SessionState
 
addConsumerInfo(ConsumerInfo) - Method in class org.apache.activemq.network.DemandForwardingBridgeSupport
 
addDestination(ConnectionContext, ActiveMQDestination) - Method in class org.apache.activemq.advisory.AdvisoryBroker
 
addDestination(ConnectionContext, ActiveMQDestination) - Method in class org.apache.activemq.broker.BrokerBroadcaster
 
addDestination(ConnectionContext, ActiveMQDestination) - Method in class org.apache.activemq.broker.BrokerFilter
 
addDestination(ConnectionContext, ActiveMQDestination) - Method in class org.apache.activemq.broker.EmptyBroker
 
addDestination(ConnectionContext, ActiveMQDestination) - Method in class org.apache.activemq.broker.ErrorBroker
 
addDestination(ConnectionContext, ActiveMQDestination) - Method in class org.apache.activemq.broker.MutableBrokerFilter
 
addDestination(ConnectionContext, ActiveMQDestination) - Method in class org.apache.activemq.broker.region.AbstractRegion
 
addDestination(Destination) - Method in class org.apache.activemq.broker.region.AbstractSubscription
Add a destination
addDestination(ConnectionContext, ActiveMQDestination) - Method in interface org.apache.activemq.broker.region.Region
Used to create a destination.
addDestination(ConnectionContext, ActiveMQDestination) - Method in class org.apache.activemq.broker.region.RegionBroker
 
addDestination(ConnectionContext, ActiveMQDestination) - Method in class org.apache.activemq.broker.view.DestinationDotFileInterceptor
 
addDestination(ConnectionContext, ActiveMQDestination) - Method in class org.apache.activemq.security.AuthorizationBroker
 
addDestinationInfo(ConnectionContext, DestinationInfo) - Method in class org.apache.activemq.advisory.AdvisoryBroker
 
addDestinationInfo(ConnectionContext, DestinationInfo) - Method in interface org.apache.activemq.broker.Broker
Add and process a DestinationInfo object
addDestinationInfo(ConnectionContext, DestinationInfo) - Method in class org.apache.activemq.broker.BrokerFilter
 
addDestinationInfo(ConnectionContext, DestinationInfo) - Method in class org.apache.activemq.broker.EmptyBroker
 
addDestinationInfo(ConnectionContext, DestinationInfo) - Method in class org.apache.activemq.broker.ErrorBroker
 
addDestinationInfo(ConnectionContext, DestinationInfo) - Method in class org.apache.activemq.broker.ft.MasterBroker
 
addDestinationInfo(ConnectionContext, DestinationInfo) - Method in class org.apache.activemq.broker.MutableBrokerFilter
 
addDestinationInfo(ConnectionContext, DestinationInfo) - Method in class org.apache.activemq.broker.region.RegionBroker
 
addDestinationInfo(ConnectionContext, DestinationInfo) - Method in class org.apache.activemq.broker.util.UDPTraceBrokerPlugin
 
addDestinationRole(Destination, String, String) - Method in class org.apache.activemq.security.AuthorizationBroker
 
addDispatcher(ConsumerId, ActiveMQDispatcher) - Method in class org.apache.activemq.ActiveMQConnection
 
addDynamicallyIncludedDestination(ActiveMQDestination) - Method in class org.apache.activemq.network.NetworkConnector
 
addEscapes(String) - Static method in error org.apache.activemq.selector.TokenMgrError
Replaces unprintable characters by their espaced (or unicode escaped) equivalents in the given string
addExcludedDestination(ActiveMQDestination) - Method in class org.apache.activemq.network.NetworkConnector
 
addExpression() - Method in class org.apache.activemq.selector.SelectorParser
 
addExpressionListner(Expression, MultiExpressionEvaluator.ExpressionListener) - Method in class org.apache.activemq.filter.MultiExpressionEvaluator
Adds an ExpressionListener to a given expression.
addFirst(Object) - Method in class org.apache.activemq.kaha.impl.container.ListContainerImpl
 
addFirst(IndexItem) - Method in class org.apache.activemq.kaha.impl.index.DiskIndexLinkedList
Inserts the given element at the beginning of this list.
addFirst(IndexItem) - Method in interface org.apache.activemq.kaha.impl.index.IndexLinkedList
Inserts the given element at the beginning of this list.
addFirst(IndexItem) - Method in class org.apache.activemq.kaha.impl.index.VMIndexLinkedList
 
addFirst(V) - Method in interface org.apache.activemq.kaha.ListContainer
Inserts the given element at the beginning of this list.
addInactiveSubscription(SubscriptionKey, SubscriptionInfo) - Method in class org.apache.activemq.broker.jmx.ManagedRegionBroker
 
addInboundBridge(DestinationBridge) - Method in class org.apache.activemq.network.jms.JmsConnector
 
addInProgressDataFile(AMQMessageStore, int) - Method in class org.apache.activemq.store.amq.AMQPersistenceAdapter
 
addInputStream(ActiveMQInputStream) - Method in class org.apache.activemq.ActiveMQConnection
 
addInterceptors(Broker) - Method in class org.apache.activemq.broker.BrokerService
Strategy method to add interceptors to the broker
addInterestInFile(int) - Method in class org.apache.activemq.kaha.impl.async.AsyncDataManager
 
addInterestInFile(int) - Method in class org.apache.activemq.kaha.impl.async.DataManagerFacade
 
addInterestInFile(int) - Method in class org.apache.activemq.kaha.impl.data.DataManagerImpl
 
addInterestInFile(int) - Method in interface org.apache.activemq.kaha.impl.DataManager
 
additionalPredicate - Variable in class org.apache.activemq.command.ConsumerInfo
 
addJmsConnector(JmsConnector) - Method in class org.apache.activemq.broker.BrokerService
 
addKeyManager(KeyManager) - Method in class org.apache.activemq.broker.SslContext
 
addLast(Object) - Method in class org.apache.activemq.kaha.impl.container.ListContainerImpl
 
addLast(IndexItem) - Method in class org.apache.activemq.kaha.impl.index.DiskIndexLinkedList
Appends the given element to the end of this list.
addLast(IndexItem) - Method in interface org.apache.activemq.kaha.impl.index.IndexLinkedList
Appends the given element to the end of this list.
addLast(IndexItem) - Method in class org.apache.activemq.kaha.impl.index.VMIndexLinkedList
 
addLast(V) - Method in interface org.apache.activemq.kaha.ListContainer
Appends the given element to the end of this list.
addListener(Broker) - Method in class org.apache.activemq.broker.BrokerBroadcaster
 
addMessage(ConnectionContext, Message) - Method in class org.apache.activemq.store.amq.AMQMessageStore
Not synchronize since the Journal has better throughput if you increase the number of concurrent writes that it is doing.
addMessage(ConnectionContext, Message) - Method in class org.apache.activemq.store.jdbc.JDBCMessageStore
 
addMessage(ConnectionContext, Message) - Method in class org.apache.activemq.store.journal.JournalMessageStore
Not synchronized since the Journal has better throughput if you increase the number of concurrent writes that it is doing.
addMessage(ConnectionContext, Message) - Method in class org.apache.activemq.store.journal.JournalTopicMessageStore
 
addMessage(ConnectionContext, Message) - Method in class org.apache.activemq.store.kahadaptor.KahaMessageStore
 
addMessage(ConnectionContext, Message) - Method in class org.apache.activemq.store.kahadaptor.KahaReferenceStore
 
addMessage(ConnectionContext, Message) - Method in class org.apache.activemq.store.kahadaptor.KahaTopicMessageStore
 
addMessage(ConnectionContext, Message) - Method in class org.apache.activemq.store.kahadaptor.KahaTopicReferenceStore
 
addMessage(ConnectionContext, Message) - Method in class org.apache.activemq.store.memory.MemoryMessageStore
 
addMessage(ConnectionContext, Message) - Method in class org.apache.activemq.store.memory.MemoryTopicMessageStore
 
addMessage(ConnectionContext, Message) - Method in interface org.apache.activemq.store.MessageStore
Adds a message to the message store
addMessage(ConnectionContext, Message) - Method in class org.apache.activemq.store.ProxyMessageStore
 
addMessage(ConnectionContext, Message) - Method in class org.apache.activemq.store.ProxyTopicMessageStore
 
addMessageFirst(MessageReference) - Method in class org.apache.activemq.broker.region.cursors.AbstractPendingMessageCursor
 
addMessageFirst(MessageReference) - Method in class org.apache.activemq.broker.region.cursors.AbstractStoreCursor
 
addMessageFirst(MessageReference) - Method in class org.apache.activemq.broker.region.cursors.FilePendingMessageCursor
add message to await dispatch
addMessageFirst(MessageReference) - Method in interface org.apache.activemq.broker.region.cursors.PendingMessageCursor
add message to await dispatch
addMessageFirst(MessageReference) - Method in class org.apache.activemq.broker.region.cursors.StoreQueueCursor
 
addMessageFirst(MessageReference) - Method in class org.apache.activemq.broker.region.cursors.VMPendingMessageCursor
add message to await dispatch
addMessageLast(MessageReference) - Method in class org.apache.activemq.broker.region.cursors.AbstractPendingMessageCursor
 
addMessageLast(MessageReference) - Method in class org.apache.activemq.broker.region.cursors.AbstractStoreCursor
 
addMessageLast(MessageReference) - Method in class org.apache.activemq.broker.region.cursors.FilePendingMessageCursor
add message to await dispatch
addMessageLast(MessageReference) - Method in interface org.apache.activemq.broker.region.cursors.PendingMessageCursor
add message to await dispatch
addMessageLast(MessageReference) - Method in class org.apache.activemq.broker.region.cursors.StoreDurableSubscriberCursor
 
addMessageLast(MessageReference) - Method in class org.apache.activemq.broker.region.cursors.StoreQueueCursor
 
addMessageLast(MessageReference) - Method in class org.apache.activemq.broker.region.cursors.VMPendingMessageCursor
add message to await dispatch
addMessageReference(ConnectionContext, MessageId, long, String) - Method in class org.apache.activemq.store.amq.AMQMessageStore
 
addMessageReference(ConnectionContext, MessageId, long, String) - Method in class org.apache.activemq.store.jdbc.JDBCMessageStore
 
addMessageReference(ConnectionContext, MessageId, long, String) - Method in class org.apache.activemq.store.journal.JournalMessageStore
 
addMessageReference(ConnectionContext, MessageId, ReferenceStore.ReferenceData) - Method in class org.apache.activemq.store.kahadaptor.KahaReferenceStore
 
addMessageReference(ConnectionContext, MessageId, ReferenceStore.ReferenceData) - Method in class org.apache.activemq.store.kahadaptor.KahaTopicReferenceStore
 
addMessageReference(ConnectionContext, MessageId, ReferenceStore.ReferenceData) - Method in interface org.apache.activemq.store.ReferenceStore
Adds a message reference to the message store
addNetworkConnector(String) - Method in class org.apache.activemq.broker.BrokerService
Adds a new network connector using the given discovery address
addNetworkConnector(URI) - Method in class org.apache.activemq.broker.BrokerService
Adds a new network connector using the given discovery address
addNetworkConnector(NetworkConnector) - Method in class org.apache.activemq.broker.BrokerService
Adds a new network connector to connect this broker to a federated network
addNetworkConnector(String) - Method in class org.apache.activemq.broker.jmx.BrokerView
 
addNetworkConnector(String) - Method in interface org.apache.activemq.broker.jmx.BrokerViewMBean
 
addNetworkConsumerId(ConsumerId) - Method in class org.apache.activemq.command.ConsumerInfo
 
addOutboundBridge(DestinationBridge) - Method in class org.apache.activemq.network.jms.JmsConnector
 
addOutputStream(ActiveMQOutputStream) - Method in class org.apache.activemq.ActiveMQConnection
 
addProducer(ProducerId, ActiveMQMessageProducer) - Method in class org.apache.activemq.ActiveMQConnection
 
addProducer(ActiveMQMessageProducer) - Method in class org.apache.activemq.ActiveMQSession
Adds a message producer.
addProducer(ConnectionContext, ProducerInfo) - Method in class org.apache.activemq.advisory.AdvisoryBroker
 
addProducer(ConnectionContext, ProducerInfo) - Method in interface org.apache.activemq.broker.Broker
Adds a producer.
addProducer(ConnectionContext, ProducerInfo) - Method in class org.apache.activemq.broker.BrokerBroadcaster
 
addProducer(ConnectionContext, ProducerInfo) - Method in class org.apache.activemq.broker.BrokerFilter
 
addProducer(ConnectionContext, ProducerInfo) - Method in class org.apache.activemq.broker.CompositeDestinationBroker
A producer may register to send to multiple destinations via a composite destination.
addProducer(ConnectionContext, ProducerInfo) - Method in class org.apache.activemq.broker.EmptyBroker
 
addProducer(ConnectionContext, ProducerInfo) - Method in class org.apache.activemq.broker.ErrorBroker
 
addProducer(ConnectionContext, ProducerInfo) - Method in class org.apache.activemq.broker.ft.MasterBroker
Adds a producer.
addProducer(ConnectionContext, ProducerInfo) - Method in class org.apache.activemq.broker.MutableBrokerFilter
 
addProducer(ConnectionContext, ProducerInfo) - Method in class org.apache.activemq.broker.region.AbstractRegion
 
addProducer(ConnectionContext, ProducerInfo) - Method in class org.apache.activemq.broker.region.BaseDestination
 
addProducer(ConnectionContext, ProducerInfo) - Method in interface org.apache.activemq.broker.region.Destination
 
addProducer(ConnectionContext, ProducerInfo) - Method in class org.apache.activemq.broker.region.DestinationFilter
 
addProducer(ConnectionContext, ProducerInfo) - Method in interface org.apache.activemq.broker.region.Region
Adds a Producer.
addProducer(ConnectionContext, ProducerInfo) - Method in class org.apache.activemq.broker.region.RegionBroker
 
addProducer(ConnectionContext, ProducerInfo) - Method in class org.apache.activemq.broker.util.UDPTraceBrokerPlugin
 
addProducer(ConnectionContext, ProducerInfo) - Method in class org.apache.activemq.broker.view.ConnectionDotFileInterceptor
 
addProducer(ConnectionContext, ProducerInfo) - Method in class org.apache.activemq.security.AuthorizationBroker
 
addProducer(ProducerInfo) - Method in class org.apache.activemq.state.SessionState
 
addProxyConnector(String) - Method in class org.apache.activemq.broker.BrokerService
Adds a new proxy connector using the given bind address
addProxyConnector(URI) - Method in class org.apache.activemq.broker.BrokerService
Adds a new proxy connector using the given bind address
addProxyConnector(ProxyConnector) - Method in class org.apache.activemq.broker.BrokerService
 
addQueue(String) - Method in class org.apache.activemq.broker.jmx.BrokerView
 
addQueue(String) - Method in interface org.apache.activemq.broker.jmx.BrokerViewMBean
Adds a Queue destination to the broker.
addQueueRole(String, String, String) - Method in class org.apache.activemq.security.AuthorizationBroker
 
addQueueRole(String, String, String) - Method in interface org.apache.activemq.security.SecurityAdminMBean
 
addRecoveredMessage(ConnectionContext, MessageReference) - Method in class org.apache.activemq.broker.region.AbstractSubscription
 
addRecoveredMessage(MessageReference) - Method in class org.apache.activemq.broker.region.cursors.AbstractPendingMessageCursor
 
addRecoveredMessage(MessageReference) - Method in interface org.apache.activemq.broker.region.cursors.PendingMessageCursor
Add a message recovered from a retroactive policy
addRecoveredMessage(MessageReference) - Method in class org.apache.activemq.broker.region.cursors.StoreDurableSubscriberCursor
 
addRecoveredMessage(ConnectionContext, MessageReference) - Method in interface org.apache.activemq.broker.region.SubscriptionRecovery
Add a message to the SubscriptionRecovery
addReferenceFileIdsInUse() - Method in class org.apache.activemq.store.kahadaptor.KahaReferenceStore
 
addReferenceFileIdsInUse() - Method in class org.apache.activemq.store.kahadaptor.KahaTopicReferenceStore
 
addRemoteBrokerToBrokerPath(ConsumerInfo) - Method in class org.apache.activemq.network.CompositeDemandForwardingBridge
 
addRemoteBrokerToBrokerPath(ConsumerInfo) - Method in class org.apache.activemq.network.DemandForwardingBridge
 
addRemoteBrokerToBrokerPath(ConsumerInfo) - Method in class org.apache.activemq.network.DemandForwardingBridgeSupport
 
addReplyHeaders(TextMessage, Message) - Method in class org.apache.activemq.broker.util.CommandMessageListener
 
address - Variable in class org.apache.activemq.broker.util.UDPTraceBrokerPlugin
 
addRole(String) - Method in class org.apache.activemq.security.AuthorizationBroker
 
addRole(String) - Method in interface org.apache.activemq.security.SecurityAdminMBean
 
addService(Service) - Method in class org.apache.activemq.broker.BrokerService
Adds a new service so that it will be started as part of the broker lifecycle
addService(JmDNS, String, String) - Method in class org.apache.activemq.transport.discovery.rendezvous.RendezvousDiscoveryAgent
 
addServiceListener(ServiceListener) - Method in class org.apache.activemq.util.ServiceSupport
 
addSession(ActiveMQSession) - Method in class org.apache.activemq.ActiveMQConnection
Used internally for adding Sessions to the Connection
addSession(ConnectionContext, SessionInfo) - Method in interface org.apache.activemq.broker.Broker
Adds a session.
addSession(ConnectionContext, SessionInfo) - Method in class org.apache.activemq.broker.BrokerBroadcaster
 
addSession(ConnectionContext, SessionInfo) - Method in class org.apache.activemq.broker.BrokerFilter
 
addSession(ConnectionContext, SessionInfo) - Method in class org.apache.activemq.broker.EmptyBroker
 
addSession(ConnectionContext, SessionInfo) - Method in class org.apache.activemq.broker.ErrorBroker
 
addSession(ConnectionContext, SessionInfo) - Method in class org.apache.activemq.broker.ft.MasterBroker
Adds a session.
addSession(ConnectionContext, SessionInfo) - Method in class org.apache.activemq.broker.MutableBrokerFilter
 
addSession(ConnectionContext, SessionInfo) - Method in class org.apache.activemq.broker.util.UDPTraceBrokerPlugin
 
addSession(SessionInfo) - Method in class org.apache.activemq.state.ConnectionState
 
addShutdownHook() - Method in class org.apache.activemq.broker.BrokerService
 
addShutdownHook(Runnable) - Method in class org.apache.activemq.broker.BrokerService
 
addSslConnector(String, KeyManager[], TrustManager[], SecureRandom) - Method in class org.apache.activemq.broker.SslBrokerService
Adds a new transport connector for the given bind address.
addSslConnector(URI, KeyManager[], TrustManager[], SecureRandom) - Method in class org.apache.activemq.broker.SslBrokerService
Adds a new transport connector for the given bind address.
addStaticallyIncludedDestination(ActiveMQDestination) - Method in class org.apache.activemq.network.NetworkConnector
 
addStatistic(String, StatisticImpl) - Method in class org.apache.activemq.management.StatsImpl
 
addSubsciption(SubscriptionInfo, boolean) - Method in class org.apache.activemq.store.amq.AMQTopicMessageStore
 
addSubsciption(SubscriptionInfo, boolean) - Method in class org.apache.activemq.store.jdbc.JDBCTopicMessageStore
 
addSubsciption(SubscriptionInfo, boolean) - Method in class org.apache.activemq.store.journal.JournalTopicMessageStore
 
addSubsciption(SubscriptionInfo, boolean) - Method in class org.apache.activemq.store.kahadaptor.KahaTopicMessageStore
 
addSubsciption(SubscriptionInfo, boolean) - Method in class org.apache.activemq.store.kahadaptor.KahaTopicReferenceStore
 
addSubsciption(SubscriptionInfo, boolean) - Method in class org.apache.activemq.store.memory.MemoryTopicMessageStore
 
addSubsciption(SubscriptionInfo, boolean) - Method in class org.apache.activemq.store.ProxyTopicMessageStore
 
addSubsciption(SubscriptionInfo, boolean) - Method in interface org.apache.activemq.store.TopicMessageStore
Inserts the subscriber info due to a subscription change

If this is a new subscription and the retroactive is false, then the last message sent to the topic should be set as the last message acknowledged by they new subscription.

addSubsciption(SubscriptionInfo, boolean) - Method in interface org.apache.activemq.store.TopicReferenceStore
Inserts the subscriber info due to a subscription change

If this is a new subscription and the retroactive is false, then the last message sent to the topic should be set as the last message acknowledged by they new subscription.

addSubscriberMessageContainer(Object) - Method in class org.apache.activemq.store.kahadaptor.KahaTopicMessageStore
 
addSubscriberMessageContainer(String, String) - Method in class org.apache.activemq.store.kahadaptor.KahaTopicReferenceStore
 
addSubscriberState(SubscriptionInfo) - Method in class org.apache.activemq.store.kahadaptor.KahaReferenceStoreAdapter
 
addSubscription(ConnectionContext, Subscription) - Method in interface org.apache.activemq.broker.region.Destination
 
addSubscription(ConnectionContext, Subscription) - Method in class org.apache.activemq.broker.region.DestinationFilter
 
addSubscription(ConnectionContext, Subscription) - Method in class org.apache.activemq.broker.region.Queue
 
addSubscription(ConnectionContext, Subscription) - Method in class org.apache.activemq.broker.region.TempQueue
 
addSubscription(ConnectionContext, Subscription) - Method in class org.apache.activemq.broker.region.TempTopic
 
addSubscription(ConnectionContext, Subscription) - Method in class org.apache.activemq.broker.region.Topic
 
addSubscription(DemandSubscription) - Method in class org.apache.activemq.network.DemandForwardingBridgeSupport
 
addSubscriptionsForDestination(ConnectionContext, Destination) - Method in class org.apache.activemq.broker.region.AbstractRegion
 
addSubscriptionsForDestination(ConnectionContext, Destination) - Method in class org.apache.activemq.broker.region.TopicRegion
 
addSynchronization(Synchronization) - Method in class org.apache.activemq.transaction.Transaction
 
addSynchronization(Synchronization) - Method in class org.apache.activemq.TransactionContext
 
addTempDestination(DestinationInfo) - Method in class org.apache.activemq.state.ConnectionState
 
addTime(long) - Method in class org.apache.activemq.management.TimeStatisticImpl
 
addToAlreadyInterestedConsumers(ConsumerInfo) - Method in class org.apache.activemq.network.ConduitBridge
 
addToEnvironment(String, Object) - Method in class org.apache.activemq.jndi.ReadOnlyContext
 
addToMarshallCache(DataStructure) - Method in class org.apache.activemq.openwire.OpenWireFormat
 
addTopic(String) - Method in class org.apache.activemq.broker.jmx.BrokerView
 
addTopic(String) - Method in interface org.apache.activemq.broker.jmx.BrokerViewMBean
Adds a Topic destination to the broker.
addTopicRole(String, String, String) - Method in class org.apache.activemq.security.AuthorizationBroker
 
addTopicRole(String, String, String) - Method in interface org.apache.activemq.security.SecurityAdminMBean
 
addTransactionState(TransactionId) - Method in class org.apache.activemq.state.ConnectionState
 
addTransportListener(TransportListener) - Method in class org.apache.activemq.ActiveMQConnection
Adds a transport listener so that a client can be notified of events in the underlying transport
addTrustManager(TrustManager) - Method in class org.apache.activemq.broker.SslContext
 
addUsageListener(UsageListener) - Method in class org.apache.activemq.usage.Usage
 
addUserRole(String, String) - Method in class org.apache.activemq.security.AuthorizationBroker
 
addUserRole(String, String) - Method in interface org.apache.activemq.security.SecurityAdminMBean
 
ADIVSORY_MESSAGE_TYPE - Static variable in class org.apache.activemq.advisory.AdvisorySupport
 
adjustBeginLineColumn(int, int) - Method in class org.apache.activemq.selector.SimpleCharStream
Method to adjust line and column numbers for the start of a token.
ADMIN_ATTRIBUTE - Static variable in class org.apache.activemq.security.LDAPAuthorizationMap
 
ADMIN_BASE - Static variable in class org.apache.activemq.security.LDAPAuthorizationMap
 
ADVISORY_TOPIC_PREFIX - Static variable in class org.apache.activemq.advisory.AdvisorySupport
 
AdvisoryBroker - Class in org.apache.activemq.advisory
This broker filter handles tracking the state of the broker for purposes of publishing advisory messages to advisory consumers.
AdvisoryBroker(Broker) - Constructor for class org.apache.activemq.advisory.AdvisoryBroker
 
AdvisoryConsumer - Class in org.apache.activemq
 
AdvisoryConsumer(ActiveMQConnection, ConsumerId) - Constructor for class org.apache.activemq.AdvisoryConsumer
 
advisoryProducerId - Variable in class org.apache.activemq.advisory.AdvisoryBroker
 
AdvisorySupport - Class in org.apache.activemq.advisory
 
afterCommit() - Method in class org.apache.activemq.transaction.Synchronization
 
afterDelivery(ActiveMQSession, Message) - Method in interface org.apache.activemq.ActiveMQSession.DeliveryListener
 
afterMarshall(WireFormat) - Method in interface org.apache.activemq.command.MarshallAware
 
afterMarshall(WireFormat) - Method in class org.apache.activemq.command.Message
 
afterMarshall(WireFormat) - Method in class org.apache.activemq.command.WireFormatInfo
 
afterPropertiesSet() - Method in class org.apache.activemq.broker.util.CommandAgent
 
afterPropertiesSet() - Method in class org.apache.activemq.filter.DestinationMapEntry
 
afterPropertiesSet() - Method in class org.apache.activemq.security.AuthorizationEntry
 
afterPropertiesSet() - Method in class org.apache.activemq.security.TempDestinationAuthorizationEntry
 
afterPropertiesSet() - Method in class org.apache.activemq.spring.ActiveMQConnectionFactory
 
afterPropertiesSet() - Method in class org.apache.activemq.spring.ActiveMQXAConnectionFactory
 
afterPropertiesSet() - Method in class org.apache.activemq.spring.SpringSslContext
 
afterPropertiesSet() - Method in class org.apache.activemq.xbean.BrokerFactoryBean
 
afterPropertiesSet() - Method in class org.apache.activemq.xbean.PooledBrokerFactoryBean
 
afterPropertiesSet() - Method in class org.apache.activemq.xbean.XBeanBrokerService
 
afterRollback() - Method in class org.apache.activemq.transaction.Synchronization
 
afterUnmarshall(WireFormat) - Method in interface org.apache.activemq.command.MarshallAware
 
afterUnmarshall(WireFormat) - Method in class org.apache.activemq.command.Message
 
afterUnmarshall(WireFormat) - Method in class org.apache.activemq.command.WireFormatInfo
 
AGENT_TOPIC - Static variable in class org.apache.activemq.advisory.AdvisorySupport
 
AlreadyClosedException - Exception in org.apache.activemq
An exception which is closed if you try to access a resource which has already been closed
AlreadyClosedException() - Constructor for exception org.apache.activemq.AlreadyClosedException
 
AlreadyClosedException(String) - Constructor for exception org.apache.activemq.AlreadyClosedException
 
alwaysSessionAsync - Variable in class org.apache.activemq.ActiveMQConnection
 
alwaysSessionAsync - Variable in class org.apache.activemq.ActiveMQConnectionFactory
 
AMQMessageStore - Class in org.apache.activemq.store.amq
A MessageStore that uses a Journal to store it's messages.
AMQMessageStore(AMQPersistenceAdapter, ReferenceStore, ActiveMQDestination) - Constructor for class org.apache.activemq.store.amq.AMQMessageStore
 
AMQPersistenceAdapter - Class in org.apache.activemq.store.amq
An implementation of PersistenceAdapter designed for use with a Journal and then check pointing asynchronously on a timeout with some other long term persistent storage.
AMQPersistenceAdapter() - Constructor for class org.apache.activemq.store.amq.AMQPersistenceAdapter
 
AMQPersistenceAdapterFactory - Class in org.apache.activemq.store.amq
An implementation of PersistenceAdapterFactory
AMQPersistenceAdapterFactory() - Constructor for class org.apache.activemq.store.amq.AMQPersistenceAdapterFactory
 
AMQTopicMessageStore - Class in org.apache.activemq.store.amq
A MessageStore that uses a Journal to store it's messages.
AMQTopicMessageStore(AMQPersistenceAdapter, TopicReferenceStore, ActiveMQTopic) - Constructor for class org.apache.activemq.store.amq.AMQTopicMessageStore
 
AMQTransactionStore - Class in org.apache.activemq.store.amq
 
AMQTransactionStore(AMQPersistenceAdapter) - Constructor for class org.apache.activemq.store.amq.AMQTransactionStore
 
AMQTx - Class in org.apache.activemq.store.amq
Operations
AMQTx(Location) - Constructor for class org.apache.activemq.store.amq.AMQTx
 
AMQTxMarshaller - Class in org.apache.activemq.store.kahadaptor
Marshall an AMQTx
AMQTxMarshaller(WireFormat) - Constructor for class org.apache.activemq.store.kahadaptor.AMQTxMarshaller
 
AMQTxOperation - Class in org.apache.activemq.store.amq
 
AMQTxOperation() - Constructor for class org.apache.activemq.store.amq.AMQTxOperation
 
AMQTxOperation(byte, ActiveMQDestination, Object, Location) - Constructor for class org.apache.activemq.store.amq.AMQTxOperation
 
AND - Static variable in interface org.apache.activemq.selector.SelectorParserConstants
 
andExpression() - Method in class org.apache.activemq.selector.SelectorParser
 
ANY_CHILD - Static variable in class org.apache.activemq.filter.DestinationFilter
 
ANY_CHILD - Static variable in class org.apache.activemq.filter.DestinationMap
 
ANY_CHILD - Static variable in class org.apache.activemq.filter.DestinationMapNode
 
ANY_DESCENDENT - Static variable in class org.apache.activemq.filter.DestinationFilter
 
ANY_DESCENDENT - Static variable in class org.apache.activemq.filter.DestinationMap
 
ANY_DESCENDENT - Static variable in class org.apache.activemq.filter.DestinationMapNode
 
AnyChildDestinationNode - Class in org.apache.activemq.filter
An implementation of DestinationNode which navigates all the children of the given node ignoring the name of the current path (so for navigating using * in a wildcard).
AnyChildDestinationNode(DestinationNode) - Constructor for class org.apache.activemq.filter.AnyChildDestinationNode
 
appendDescendantValues(Set) - Method in class org.apache.activemq.filter.AnyChildDestinationNode
 
appendDescendantValues(Set) - Method in class org.apache.activemq.filter.DestinationMapNode
 
appendDescendantValues(Set) - Method in interface org.apache.activemq.filter.DestinationNode
 
appender - Variable in class org.apache.activemq.kaha.impl.async.AsyncDataManager
 
appendFieldDescription(StringBuffer) - Method in class org.apache.activemq.management.BoundaryStatisticImpl
 
appendFieldDescription(StringBuffer) - Method in class org.apache.activemq.management.BoundedRangeStatisticImpl
 
appendFieldDescription(StringBuffer) - Method in class org.apache.activemq.management.CountStatisticImpl
 
appendFieldDescription(StringBuffer) - Method in class org.apache.activemq.management.PollCountStatisticImpl
 
appendFieldDescription(StringBuffer) - Method in class org.apache.activemq.management.RangeStatisticImpl
 
appendFieldDescription(StringBuffer) - Method in class org.apache.activemq.management.StatisticImpl
 
appendFieldDescription(StringBuffer) - Method in class org.apache.activemq.management.TimeStatisticImpl
 
appendMatchingValues(Set, String[], int) - Method in class org.apache.activemq.filter.AnyChildDestinationNode
 
appendMatchingValues(Set, String[], int) - Method in class org.apache.activemq.filter.DestinationMapNode
 
appendMatchingValues(Set, String[], int) - Method in interface org.apache.activemq.filter.DestinationNode
 
appendMatchingWildcards(Set, String[], int) - Method in class org.apache.activemq.filter.AnyChildDestinationNode
 
appendMatchingWildcards(Set, String[], int) - Method in class org.apache.activemq.filter.DestinationMapNode
Matches any entries in the map containing wildcards
appendMatchingWildcards(Set, String[], int) - Method in interface org.apache.activemq.filter.DestinationNode
 
appendMessages(List<MessageReference>) - Method in class org.apache.activemq.memory.buffer.MessageQueue
 
appendTabularMap(Map, CompositeData, String) - Static method in class org.apache.activemq.broker.jmx.CompositeDataHelper
 
appendToBrokerPath(BrokerId[], BrokerId[]) - Method in class org.apache.activemq.network.DemandForwardingBridgeSupport
 
appendToBrokerPath(BrokerId[], BrokerId) - Method in class org.apache.activemq.network.DemandForwardingBridgeSupport
 
appendToString(StringBuffer, Object) - Static method in class org.apache.activemq.util.IntrospectionSupport
 
archiveDataLogs - Variable in class org.apache.activemq.kaha.impl.async.AsyncDataManager
 
ArithmeticExpression - Class in org.apache.activemq.filter
An expression which performs an operation on two expression values
ArithmeticExpression(Expression, Expression) - Constructor for class org.apache.activemq.filter.ArithmeticExpression
 
arrival - Variable in class org.apache.activemq.command.Message
 
asBoolean(int) - Method in class org.apache.activemq.filter.ComparisonExpression
 
asID(String) - Method in class org.apache.activemq.broker.view.ConnectionDotFileInterceptor
Lets strip out any non supported characters
asManagedConnector(MBeanServer, ObjectName) - Method in class org.apache.activemq.broker.jmx.ManagedTransportConnector
 
asManagedConnector(MBeanServer, ObjectName) - Method in class org.apache.activemq.broker.TransportConnector
Factory method to create a JMX managed version of this transport connector
asMemoryMessageStore(Object) - Method in class org.apache.activemq.store.memory.MemoryPersistenceAdapter
 
asNumber(Object) - Method in class org.apache.activemq.filter.ArithmeticExpression
 
asOpenWireFormat(WireFormat) - Method in class org.apache.activemq.transport.udp.UdpTransportFactory
 
asQueryString(List<String>) - Method in class org.apache.activemq.spring.ActiveMQConnectionFactoryFactoryBean
Turns a list of query string key=value strings into a query URL string of the form "?a=x&b=y"
assertAckMatchesDispatched(MessageAck) - Method in class org.apache.activemq.broker.region.PrefetchSubscription
Checks an ack versus the contents of the dispatched list.
assignGroup(Subscription, MessageGroupMap, MessageReference, String) - Method in class org.apache.activemq.broker.region.QueueDispatchSelector
 
assignGroupToMe(MessageGroupMap, MessageReference, String) - Method in class org.apache.activemq.broker.region.QueueSubscription
Assigns the message group to this subscription and set the flag on the message that it is the first message to be dispatched.
async - Variable in class org.apache.activemq.transport.vm.VMTransport
 
AsyncDataManager - Class in org.apache.activemq.kaha.impl.async
Manages DataFiles
AsyncDataManager(AtomicLong) - Constructor for class org.apache.activemq.kaha.impl.async.AsyncDataManager
 
AsyncDataManager() - Constructor for class org.apache.activemq.kaha.impl.async.AsyncDataManager
 
asyncDispatch - Variable in class org.apache.activemq.ActiveMQSession
 
asyncQueueDepth - Variable in class org.apache.activemq.transport.vm.VMTransport
 
asyncRequest(Object, ResponseCallback) - Method in class org.apache.activemq.transport.failover.FailoverTransport
 
asyncRequest(Object, ResponseCallback) - Method in class org.apache.activemq.transport.fanout.FanoutTransport
 
asyncRequest(Object, ResponseCallback) - Method in class org.apache.activemq.transport.mock.MockTransport
 
asyncRequest(Object, ResponseCallback) - Method in class org.apache.activemq.transport.MutexTransport
 
asyncRequest(Object, ResponseCallback) - Method in class org.apache.activemq.transport.ResponseCorrelator
 
asyncRequest(Object, ResponseCallback) - Method in interface org.apache.activemq.transport.Transport
An asynchronous request response where the Receipt will be returned in the future.
asyncRequest(Object, ResponseCallback) - Method in class org.apache.activemq.transport.TransportFilter
 
asyncRequest(Object, ResponseCallback) - Method in class org.apache.activemq.transport.TransportLogger
 
asyncRequest(Object, ResponseCallback) - Method in class org.apache.activemq.transport.TransportSupport
 
asyncRequest(Object, ResponseCallback) - Method in class org.apache.activemq.transport.vm.VMTransport
 
asyncSendPacket(Command) - Method in class org.apache.activemq.ActiveMQConnection
send a Packet through the Connection - for internal use only
asyncSendPacket(Command) - Method in class org.apache.activemq.ActiveMQSession
Send the asynchronus command.
asyncWriteTask - Variable in class org.apache.activemq.store.amq.AMQMessageStore
 
AtomicIntegerMarshaller - Class in org.apache.activemq.store.kahadaptor
Marshall an AtomicInteger
AtomicIntegerMarshaller() - Constructor for class org.apache.activemq.store.kahadaptor.AtomicIntegerMarshaller
 
audit - Variable in class org.apache.activemq.broker.region.cursors.AbstractPendingMessageCursor
 
audit - Variable in class org.apache.activemq.broker.region.PrefetchSubscription
 
AUTHENTICATION - Static variable in class org.apache.activemq.security.LDAPAuthorizationMap
 
AuthenticationUser - Class in org.apache.activemq.security
A helper object used to configure simple authentiaction plugin
AuthenticationUser(String, String, String) - Constructor for class org.apache.activemq.security.AuthenticationUser
 
AuthorizationBroker - Class in org.apache.activemq.security
Verifies if a authenticated user can do an operation against the broker using an authorization map.
AuthorizationBroker(Broker, AuthorizationMap) - Constructor for class org.apache.activemq.security.AuthorizationBroker
 
AuthorizationEntry - Class in org.apache.activemq.security
Represents an entry in a DefaultAuthorizationMap for assigning different operations (read, write, admin) of user roles to a specific destination or a hierarchical wildcard area of destinations.
AuthorizationEntry() - Constructor for class org.apache.activemq.security.AuthorizationEntry
 
AuthorizationMap - Interface in org.apache.activemq.security
 
AuthorizationPlugin - Class in org.apache.activemq.security
An authorization plugin where each operation on a destination is checked against an authorizationMap
AuthorizationPlugin() - Constructor for class org.apache.activemq.security.AuthorizationPlugin
 
AuthorizationPlugin(AuthorizationMap) - Constructor for class org.apache.activemq.security.AuthorizationPlugin
 
AUTO - Static variable in interface org.apache.activemq.transport.stomp.Stomp.Headers.Subscribe.AckModeValues
 
AUTO_ACK - Static variable in class org.apache.activemq.transport.stomp.StompSubscription
 
autoCreateDestinations - Variable in class org.apache.activemq.broker.region.AbstractRegion
 
available() - Method in class org.apache.activemq.transport.nio.NIOInputStream
 
available() - Method in class org.apache.activemq.transport.tcp.TcpBufferedInputStream
 
available() - Method in class org.apache.activemq.util.ByteArrayInputStream
 
available() - Method in class org.apache.activemq.util.DataByteArrayInputStream
 
AxionJDBCAdapter - Class in org.apache.activemq.store.jdbc.adapter
Axion specific Adapter.
AxionJDBCAdapter() - Constructor for class org.apache.activemq.store.jdbc.adapter.AxionJDBCAdapter
 

B

backlog - Variable in class org.apache.activemq.transport.tcp.TcpTransportServer
 
backup(int) - Method in class org.apache.activemq.selector.SimpleCharStream
 
BadMagicException - Exception in org.apache.activemq.kaha.impl.index
Occurs when bad magic occurs in reading a file
BadMagicException() - Constructor for exception org.apache.activemq.kaha.impl.index.BadMagicException
Default Constructor
BadMagicException(String) - Constructor for exception org.apache.activemq.kaha.impl.index.BadMagicException
Construct an Exception with a reason
BaseCommand - Class in org.apache.activemq.command
 
BaseCommand() - Constructor for class org.apache.activemq.command.BaseCommand
 
BaseCommandMarshaller - Class in org.apache.activemq.openwire.v1
Marshalling code for Open Wire Format for BaseCommandMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
BaseCommandMarshaller() - Constructor for class org.apache.activemq.openwire.v1.BaseCommandMarshaller
 
BaseCommandMarshaller - Class in org.apache.activemq.openwire.v2
Marshalling code for Open Wire Format for BaseCommandMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
BaseCommandMarshaller() - Constructor for class org.apache.activemq.openwire.v2.BaseCommandMarshaller
 
BaseCommandMarshaller - Class in org.apache.activemq.openwire.v3
Marshalling code for Open Wire Format for BaseCommandMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
BaseCommandMarshaller() - Constructor for class org.apache.activemq.openwire.v3.BaseCommandMarshaller
 
baseConfiguration(BaseDestination) - Method in class org.apache.activemq.broker.region.policy.PolicyEntry
 
BaseContainerImpl - Class in org.apache.activemq.kaha.impl.container
Implementation of a ListContainer
BaseContainerImpl(ContainerId, IndexItem, IndexManager, DataManager, boolean) - Constructor for class org.apache.activemq.kaha.impl.container.BaseContainerImpl
 
BaseDataStreamMarshaller - Class in org.apache.activemq.openwire.v1
 
BaseDataStreamMarshaller() - Constructor for class org.apache.activemq.openwire.v1.BaseDataStreamMarshaller
 
BaseDataStreamMarshaller - Class in org.apache.activemq.openwire.v2
 
BaseDataStreamMarshaller() - Constructor for class org.apache.activemq.openwire.v2.BaseDataStreamMarshaller
 
BaseDataStreamMarshaller - Class in org.apache.activemq.openwire.v3
 
BaseDataStreamMarshaller() - Constructor for class org.apache.activemq.openwire.v3.BaseDataStreamMarshaller
 
BaseDestination - Class in org.apache.activemq.broker.region
 
BaseDestination(BrokerService, MessageStore, ActiveMQDestination, DestinationStatistics) - Constructor for class org.apache.activemq.broker.region.BaseDestination
 
BaseEndpoint - Class in org.apache.activemq.command
A default endpoint.
BaseEndpoint(String) - Constructor for class org.apache.activemq.command.BaseEndpoint
 
batchEntry - Variable in class org.apache.activemq.store.kahadaptor.KahaMessageStore
 
batchResetNeeded - Variable in class org.apache.activemq.broker.region.cursors.AbstractStoreCursor
 
batchStatments - Variable in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
 
beforeDelivery(ActiveMQSession, Message) - Method in interface org.apache.activemq.ActiveMQSession.DeliveryListener
 
beforeEnd() - Method in class org.apache.activemq.transaction.Synchronization
 
beforeMarshall(WireFormat) - Method in class org.apache.activemq.command.ActiveMQMapMessage
 
beforeMarshall(WireFormat) - Method in class org.apache.activemq.command.ActiveMQTextMessage
 
beforeMarshall(WireFormat) - Method in interface org.apache.activemq.command.MarshallAware
 
beforeMarshall(WireFormat) - Method in class org.apache.activemq.command.Message
 
beforeMarshall(WireFormat) - Method in class org.apache.activemq.command.WireFormatInfo
 
beforeUnmarshall(WireFormat) - Method in interface org.apache.activemq.command.MarshallAware
 
beforeUnmarshall(WireFormat) - Method in class org.apache.activemq.command.Message
 
beforeUnmarshall(WireFormat) - Method in class org.apache.activemq.command.WireFormatInfo
 
BEGIN - Static variable in class org.apache.activemq.command.TransactionInfo
 
begin() - Method in class org.apache.activemq.store.jdbc.TransactionContext
 
begin() - Method in class org.apache.activemq.TransactionContext
Start a local transaction.
BEGIN - Static variable in interface org.apache.activemq.transport.stomp.Stomp.Commands
 
BEGIN_TRANSACTION - Static variable in interface org.apache.activemq.transport.stomp.Stomp.Commands
 
beginColumn - Variable in class org.apache.activemq.selector.Token
beginLine and beginColumn describe the position of the first character of this token; endLine and endColumn describe the position of the last character of this token.
beginEvent() - Method in interface org.apache.activemq.LocalTransactionEventListener
 
beginLine - Variable in class org.apache.activemq.selector.Token
beginLine and beginColumn describe the position of the first character of this token; endLine and endColumn describe the position of the last character of this token.
BeginToken() - Method in class org.apache.activemq.selector.SimpleCharStream
 
beginTransaction(ConnectionContext, TransactionId) - Method in interface org.apache.activemq.broker.Broker
Starts a transaction.
beginTransaction(ConnectionContext, TransactionId) - Method in class org.apache.activemq.broker.BrokerBroadcaster
 
beginTransaction(ConnectionContext, TransactionId) - Method in class org.apache.activemq.broker.BrokerFilter
 
beginTransaction(ConnectionContext, TransactionId) - Method in class org.apache.activemq.broker.EmptyBroker
 
beginTransaction(ConnectionContext, TransactionId) - Method in class org.apache.activemq.broker.ErrorBroker
 
beginTransaction(ConnectionContext, TransactionId) - Method in class org.apache.activemq.broker.ft.MasterBroker
begin a transaction
beginTransaction(ConnectionContext, TransactionId) - Method in class org.apache.activemq.broker.MutableBrokerFilter
 
beginTransaction(ConnectionContext, TransactionId) - Method in class org.apache.activemq.broker.region.RegionBroker
 
beginTransaction(ConnectionContext, TransactionId) - Method in class org.apache.activemq.broker.TransactionBroker
 
beginTransaction(ConnectionContext, TransactionId) - Method in class org.apache.activemq.broker.util.UDPTraceBrokerPlugin
 
beginTransaction(ConnectionContext) - Method in class org.apache.activemq.store.amq.AMQPersistenceAdapter
 
beginTransaction(ConnectionContext) - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
 
beginTransaction(ConnectionContext) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
 
beginTransaction(ConnectionContext) - Method in class org.apache.activemq.store.kahadaptor.KahaPersistenceAdapter
 
beginTransaction(ConnectionContext) - Method in class org.apache.activemq.store.memory.MemoryPersistenceAdapter
 
beginTransaction(ConnectionContext) - Method in interface org.apache.activemq.store.PersistenceAdapter
This method starts a transaction on the persistent storage - which is nothing to do with JMS or XA transactions - its purely a mechanism to perform multiple writes to a persistent store in 1 transaction as a performance optimization.
BETWEEN - Static variable in interface org.apache.activemq.selector.SelectorParserConstants
 
BIG_STRING_TYPE - Static variable in class org.apache.activemq.util.MarshallingSupport
 
BINARY_MIME_TYPE - Static variable in class org.apache.activemq.command.ActiveMQBlobMessage
 
binaryDataType - Variable in class org.apache.activemq.store.jdbc.Statements
 
BinaryExpression - Class in org.apache.activemq.filter
An expression which performs an operation on two expression values.
BinaryExpression(Expression, Expression) - Constructor for class org.apache.activemq.filter.BinaryExpression
 
bind(String, BrokerService) - Method in class org.apache.activemq.broker.BrokerRegistry
 
bind(Name, Object) - Method in class org.apache.activemq.jndi.ReadOnlyContext
 
bind(String, Object) - Method in class org.apache.activemq.jndi.ReadOnlyContext
 
bind(DatagramSocket, SocketAddress) - Method in class org.apache.activemq.transport.multicast.MulticastTransport
 
bind() - Method in class org.apache.activemq.transport.tcp.SslTransportServer
Binds this socket to the previously specified URI.
bind() - Method in class org.apache.activemq.transport.tcp.TcpTransportServer
 
bind(URI) - Static method in class org.apache.activemq.transport.TransportFactory
 
bind(String, URI) - Static method in class org.apache.activemq.transport.TransportFactory
Deprecated.  
bind(BrokerService, URI) - Static method in class org.apache.activemq.transport.TransportFactory
 
bind(DatagramSocket, SocketAddress) - Method in class org.apache.activemq.transport.udp.UdpTransport
 
bindings - Variable in class org.apache.activemq.jndi.ReadOnlyContext
 
BitArray - Class in org.apache.activemq.util
Simple BitArray to enable setting multiple boolean values efficently Used instead of BitSet because BitSet does not allow for efficent serialization.
BitArray() - Constructor for class org.apache.activemq.util.BitArray
 
BitArrayBin - Class in org.apache.activemq.util
Holder for many bitArrays - used for message audit
BitArrayBin(int) - Constructor for class org.apache.activemq.util.BitArrayBin
Create a BitArrayBin to a certain window size (number of messages to keep)
BlobJDBCAdapter - Class in org.apache.activemq.store.jdbc.adapter
This JDBCAdapter inserts and extracts BLOB data using the getBlob()/setBlob() operations.
BlobJDBCAdapter() - Constructor for class org.apache.activemq.store.jdbc.adapter.BlobJDBCAdapter
 
BlobMessage - Interface in org.apache.activemq
Represents a message which has a typically out of band Binary Large Object (BLOB)
BlobTransferPolicy - Class in org.apache.activemq.blob
The policy for configuring how BLOBs (Binary Large OBjects) are transferred out of band between producers, brokers and consumers.
BlobTransferPolicy() - Constructor for class org.apache.activemq.blob.BlobTransferPolicy
 
BlobUploader - Class in org.apache.activemq.blob
A helper class to represent a required upload of a BLOB to some remote URL
BlobUploader(BlobTransferPolicy, InputStream) - Constructor for class org.apache.activemq.blob.BlobUploader
 
BlobUploader(BlobTransferPolicy, File) - Constructor for class org.apache.activemq.blob.BlobUploader
 
BlobUploadStrategy - Interface in org.apache.activemq.blob
Represents a strategy of uploading a file/stream to some remote
BLOCK_COMMENT - Static variable in interface org.apache.activemq.selector.SelectorParserConstants
 
BODY_LENGTH - Static variable in interface org.apache.activemq.broker.jmx.CompositeDataConstants
 
BODY_PREVIEW - Static variable in interface org.apache.activemq.broker.jmx.CompositeDataConstants
 
BOOLEAN_PROPERTIES - Static variable in interface org.apache.activemq.broker.jmx.CompositeDataConstants
 
BOOLEAN_TYPE - Static variable in interface org.apache.activemq.command.CommandTypes
 
BOOLEAN_TYPE - Static variable in class org.apache.activemq.util.MarshallingSupport
 
BooleanExpression - Interface in org.apache.activemq.filter
A BooleanExpression is an expression that always produces a Boolean result.
BooleanStream - Class in org.apache.activemq.openwire
 
BooleanStream() - Constructor for class org.apache.activemq.openwire.BooleanStream
 
borrowBuffer() - Method in interface org.apache.activemq.transport.udp.ByteBufferPool
Extract a buffer from the pool.
borrowBuffer() - Method in class org.apache.activemq.transport.udp.DefaultBufferPool
 
borrowBuffer() - Method in class org.apache.activemq.transport.udp.SimpleBufferPool
 
BoundaryStatisticImpl - Class in org.apache.activemq.management
A boundary statistic implementation
BoundaryStatisticImpl(String, String, String, long, long) - Constructor for class org.apache.activemq.management.BoundaryStatisticImpl
 
BoundedRangeStatisticImpl - Class in org.apache.activemq.management
A bounded range statistic implementation
BoundedRangeStatisticImpl(String, String, String, long, long) - Constructor for class org.apache.activemq.management.BoundedRangeStatisticImpl
 
bridgeFailed() - Method in interface org.apache.activemq.network.NetworkBridgeListener
called when the transport fails
broadcast - Variable in class org.apache.activemq.broker.util.UDPTraceBrokerPlugin
 
Broker - Interface in org.apache.activemq.broker
The Message Broker which routes messages, maintains subscriptions and connections, acknowledges messages and handles transactions.
broker - Variable in class org.apache.activemq.broker.jmx.DestinationView
 
broker - Variable in class org.apache.activemq.broker.jmx.DurableSubscriptionView
 
broker - Variable in class org.apache.activemq.broker.region.AbstractRegion
 
broker - Variable in class org.apache.activemq.broker.region.AbstractSubscription
 
broker - Variable in class org.apache.activemq.broker.region.BaseDestination
 
broker - Variable in class org.apache.activemq.broker.region.cursors.FilePendingMessageCursor
 
broker - Variable in class org.apache.activemq.broker.region.DestinationFactoryImpl
 
broker - Variable in class org.apache.activemq.broker.TransportConnection
 
BROKER_ID - Static variable in interface org.apache.activemq.command.CommandTypes
 
BROKER_INFO - Static variable in interface org.apache.activemq.command.CommandTypes
 
BROKER_MANAGEMENT - Static variable in interface org.apache.activemq.ThreadPriorities
 
BROKER_SECURITY_CONTEXT - Static variable in class org.apache.activemq.security.SecurityContext
 
BrokerBroadcaster - Class in org.apache.activemq.broker
Used to add listeners for Broker actions
BrokerBroadcaster(Broker) - Constructor for class org.apache.activemq.broker.BrokerBroadcaster
 
brokerConnectionStates - Variable in class org.apache.activemq.broker.TransportConnection
 
BrokerFactory - Class in org.apache.activemq.broker
A helper class to create a fully configured broker service using a URI.
BrokerFactoryBean - Class in org.apache.activemq.xbean
A Spring FactoryBean which creates an embedded broker inside a Spring XML using an external XBean Spring XML configuration file which provides a much neater and more concise XML format.
BrokerFactoryBean() - Constructor for class org.apache.activemq.xbean.BrokerFactoryBean
 
BrokerFactoryBean(Resource) - Constructor for class org.apache.activemq.xbean.BrokerFactoryBean
 
BrokerFactoryHandler - Interface in org.apache.activemq.broker
Represents the interface used to create a broker from a URI scheme.
BrokerFilter - Class in org.apache.activemq.broker
Allows you to intercept broker operation so that features such as security can be implemented as a pluggable filter.
BrokerFilter(Broker) - Constructor for class org.apache.activemq.broker.BrokerFilter
 
brokerId - Variable in class org.apache.activemq.broker.util.UDPTraceBrokerPlugin
 
BrokerId - Class in org.apache.activemq.command
 
BrokerId() - Constructor for class org.apache.activemq.command.BrokerId
 
BrokerId(String) - Constructor for class org.apache.activemq.command.BrokerId
 
BrokerIdMarshaller - Class in org.apache.activemq.openwire.v1
Marshalling code for Open Wire Format for BrokerIdMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
BrokerIdMarshaller() - Constructor for class org.apache.activemq.openwire.v1.BrokerIdMarshaller
 
BrokerIdMarshaller - Class in org.apache.activemq.openwire.v2
Marshalling code for Open Wire Format for BrokerIdMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
BrokerIdMarshaller() - Constructor for class org.apache.activemq.openwire.v2.BrokerIdMarshaller
 
BrokerIdMarshaller - Class in org.apache.activemq.openwire.v3
Marshalling code for Open Wire Format for BrokerIdMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
BrokerIdMarshaller() - Constructor for class org.apache.activemq.openwire.v3.BrokerIdMarshaller
 
brokerInfo - Variable in class org.apache.activemq.broker.TransportConnection
 
BrokerInfo - Class in org.apache.activemq.command
When a client connects to a broker, the broker send the client a BrokerInfo so that the client knows which broker node he's talking to and also any peers that the node has in his cluster.
BrokerInfo() - Constructor for class org.apache.activemq.command.BrokerInfo
 
BrokerInfoMarshaller - Class in org.apache.activemq.openwire.v1
Marshalling code for Open Wire Format for BrokerInfoMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
BrokerInfoMarshaller() - Constructor for class org.apache.activemq.openwire.v1.BrokerInfoMarshaller
 
BrokerInfoMarshaller - Class in org.apache.activemq.openwire.v2
Marshalling code for Open Wire Format for BrokerInfoMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
BrokerInfoMarshaller() - Constructor for class org.apache.activemq.openwire.v2.BrokerInfoMarshaller
 
BrokerInfoMarshaller - Class in org.apache.activemq.openwire.v3
Marshalling code for Open Wire Format for BrokerInfoMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
BrokerInfoMarshaller() - Constructor for class org.apache.activemq.openwire.v3.BrokerInfoMarshaller
 
brokerInfoMutex - Variable in class org.apache.activemq.network.CompositeDemandForwardingBridge
 
brokerInfoMutex - Variable in class org.apache.activemq.network.DemandForwardingBridge
 
brokerInTime - Variable in class org.apache.activemq.command.Message
 
brokerMasterConnector - Variable in class org.apache.activemq.command.ConnectionInfo
 
brokerName - Variable in class org.apache.activemq.command.DiscoveryEvent
 
brokerOutTime - Variable in class org.apache.activemq.command.Message
 
brokerPath - Variable in class org.apache.activemq.command.ConnectionInfo
 
brokerPath - Variable in class org.apache.activemq.command.ConsumerInfo
 
brokerPath - Variable in class org.apache.activemq.command.DestinationInfo
 
brokerPath - Variable in class org.apache.activemq.command.ProducerInfo
 
BrokerPlugin - Interface in org.apache.activemq.broker
Represents a plugin into a Broker
BrokerPluginSupport - Class in org.apache.activemq.broker
A useful base class for implementing broker plugins.
BrokerPluginSupport() - Constructor for class org.apache.activemq.broker.BrokerPluginSupport
 
BrokerRegistry - Class in org.apache.activemq.broker
 
BrokerRegistry() - Constructor for class org.apache.activemq.broker.BrokerRegistry
 
BROKERS - Static variable in class org.apache.activemq.transport.peer.PeerTransportFactory
 
BROKERS - Static variable in class org.apache.activemq.transport.vm.VMTransportFactory
 
brokerSequenceId - Variable in class org.apache.activemq.command.MessageId
 
BrokerService - Class in org.apache.activemq.broker
Manages the lifecycle of an ActiveMQ Broker.
BrokerService() - Constructor for class org.apache.activemq.broker.BrokerService
 
brokerService - Variable in class org.apache.activemq.broker.region.BaseDestination
 
brokerService - Variable in class org.apache.activemq.broker.region.RegionBroker
 
BrokerServiceAware - Interface in org.apache.activemq.broker
An interface used to represent a component that wants the BrokerService to be injected
brokerServiceStarted() - Method in interface org.apache.activemq.broker.Broker
called when the brokerService starts
brokerServiceStarted() - Method in class org.apache.activemq.broker.BrokerFilter
 
brokerServiceStarted() - Method in class org.apache.activemq.broker.EmptyBroker
 
brokerServiceStarted() - Method in class org.apache.activemq.broker.ErrorBroker
 
brokerServiceStarted() - Method in class org.apache.activemq.broker.MutableBrokerFilter
 
brokerServiceStarted() - Method in class org.apache.activemq.broker.region.RegionBroker
 
brokerServiceStarted() - Method in class org.apache.activemq.broker.TransactionBroker
 
BrokerStoppedException - Exception in org.apache.activemq.broker
This exception is thrown by the broker when you try to use it after it has been stopped.
BrokerStoppedException() - Constructor for exception org.apache.activemq.broker.BrokerStoppedException
 
BrokerStoppedException(String, Throwable) - Constructor for exception org.apache.activemq.broker.BrokerStoppedException
 
BrokerStoppedException(String) - Constructor for exception org.apache.activemq.broker.BrokerStoppedException
 
BrokerStoppedException(Throwable) - Constructor for exception org.apache.activemq.broker.BrokerStoppedException
 
BrokerSupport - Class in org.apache.activemq.util
Utility class for re-sending messages
brokerURL - Variable in class org.apache.activemq.ActiveMQConnectionFactory
 
BrokerView - Class in org.apache.activemq.broker.jmx
 
BrokerView(BrokerService, ManagedRegionBroker) - Constructor for class org.apache.activemq.broker.jmx.BrokerView
 
BrokerViewMBean - Interface in org.apache.activemq.broker.jmx
 
browse() - Method in class org.apache.activemq.broker.jmx.DestinationView
 
browse(String) - Method in class org.apache.activemq.broker.jmx.DestinationView
 
browse() - Method in interface org.apache.activemq.broker.jmx.DestinationViewMBean
 
browse(String) - Method in interface org.apache.activemq.broker.jmx.DestinationViewMBean
 
browse() - Method in class org.apache.activemq.broker.jmx.DurableSubscriptionView
Browse messages for this durable subscriber
browse() - Method in interface org.apache.activemq.broker.jmx.DurableSubscriptionViewMBean
Browse messages for this durable subscriber
browse() - Method in class org.apache.activemq.broker.jmx.InactiveDurableSubscriptionView
Browse messages for this durable subscriber
browse(SubscriptionView) - Method in class org.apache.activemq.broker.jmx.ManagedRegionBroker
 
browse() - Method in interface org.apache.activemq.broker.region.Destination
 
browse() - Method in class org.apache.activemq.broker.region.DestinationFilter
 
browse(ActiveMQDestination) - Method in class org.apache.activemq.broker.region.policy.FixedCountSubscriptionRecoveryPolicy
 
browse(ActiveMQDestination) - Method in class org.apache.activemq.broker.region.policy.FixedSizedSubscriptionRecoveryPolicy
 
browse(ActiveMQDestination) - Method in class org.apache.activemq.broker.region.policy.LastImageSubscriptionRecoveryPolicy
 
browse(ActiveMQDestination) - Method in class org.apache.activemq.broker.region.policy.NoSubscriptionRecoveryPolicy
 
browse(ActiveMQDestination) - Method in class org.apache.activemq.broker.region.policy.QueryBasedSubscriptionRecoveryPolicy
 
browse(ActiveMQDestination) - Method in interface org.apache.activemq.broker.region.policy.SubscriptionRecoveryPolicy
 
browse(ActiveMQDestination) - Method in class org.apache.activemq.broker.region.policy.TimedSubscriptionRecoveryPolicy
 
browse() - Method in class org.apache.activemq.broker.region.Queue
 
browse() - Method in class org.apache.activemq.broker.region.Topic
 
browse(ActiveMQDestination) - Method in class org.apache.activemq.memory.list.DestinationBasedMessageList
 
browse(ActiveMQDestination) - Method in interface org.apache.activemq.memory.list.MessageList
 
browse(ActiveMQDestination) - Method in class org.apache.activemq.memory.list.SimpleMessageList
 
browseAsTable() - Method in class org.apache.activemq.broker.jmx.DestinationView
 
browseAsTable(String) - Method in class org.apache.activemq.broker.jmx.DestinationView
 
browseAsTable() - Method in interface org.apache.activemq.broker.jmx.DestinationViewMBean
 
browseAsTable(String) - Method in interface org.apache.activemq.broker.jmx.DestinationViewMBean
 
browseAsTable() - Method in class org.apache.activemq.broker.jmx.DurableSubscriptionView
Browse messages for this durable subscriber
browseAsTable() - Method in interface org.apache.activemq.broker.jmx.DurableSubscriptionViewMBean
Browse messages for this durable subscriber
browseAsTable() - Method in class org.apache.activemq.broker.jmx.InactiveDurableSubscriptionView
Browse messages for this durable subscriber
browseAsTable(SubscriptionView) - Method in class org.apache.activemq.broker.jmx.ManagedRegionBroker
 
browseMessages() - Method in class org.apache.activemq.broker.jmx.DestinationView
Browses the current destination returning a list of messages
browseMessages(String) - Method in class org.apache.activemq.broker.jmx.DestinationView
Browses the current destination with the given selector returning a list of messages
browseMessages() - Method in interface org.apache.activemq.broker.jmx.DestinationViewMBean
Browses the current destination returning a list of messages
browseMessages(String) - Method in interface org.apache.activemq.broker.jmx.DestinationViewMBean
Browses the current destination with the given selector returning a list of messages
browser - Variable in class org.apache.activemq.command.ConsumerInfo
 
bubbleDown(MessageQueue, int) - Method in class org.apache.activemq.memory.buffer.SizeBasedMessageBuffer
 
bubbleUp(MessageQueue, int) - Method in class org.apache.activemq.memory.buffer.SizeBasedMessageBuffer
 
bufcolumn - Variable in class org.apache.activemq.selector.SimpleCharStream
 
buffer - Variable in class org.apache.activemq.selector.SimpleCharStream
 
buffOut - Variable in class org.apache.activemq.transport.tcp.TcpTransport
 
bufline - Variable in class org.apache.activemq.selector.SimpleCharStream
 
bufpos - Variable in class org.apache.activemq.selector.SimpleCharStream
 
buildEntrySet() - Method in class org.apache.activemq.kaha.impl.container.ContainerEntrySet
 
buildExistingSubscriptions() - Method in class org.apache.activemq.broker.jmx.ManagedRegionBroker
 
buildFromMap(Map<String, Object>) - Method in class org.apache.activemq.ActiveMQConnectionFactory
 
buildFromProperties(Properties) - Method in class org.apache.activemq.ActiveMQConnectionFactory
 
buildFromProperties(Properties) - Method in class org.apache.activemq.command.ActiveMQDestination
 
buildFromProperties(Properties) - Method in class org.apache.activemq.jndi.JNDIBaseStorable
Set the properties that will represent the instance in JNDI
BYTE_ARRAY_TYPE - Static variable in interface org.apache.activemq.command.CommandTypes
 
BYTE_ARRAY_TYPE - Static variable in class org.apache.activemq.util.MarshallingSupport
 
BYTE_PROPERTIES - Static variable in interface org.apache.activemq.broker.jmx.CompositeDataConstants
 
BYTE_TYPE - Static variable in interface org.apache.activemq.command.CommandTypes
 
BYTE_TYPE - Static variable in class org.apache.activemq.util.MarshallingSupport
 
ByteArrayInputStream - Class in org.apache.activemq.util
Very similar to the java.io.ByteArrayInputStream but this version is not thread safe.
ByteArrayInputStream(byte[]) - Constructor for class org.apache.activemq.util.ByteArrayInputStream
 
ByteArrayInputStream(ByteSequence) - Constructor for class org.apache.activemq.util.ByteArrayInputStream
 
ByteArrayInputStream(byte[], int, int) - Constructor for class org.apache.activemq.util.ByteArrayInputStream
 
ByteArrayOutputStream - Class in org.apache.activemq.util
Very similar to the java.io.ByteArrayOutputStream but this version is not thread safe and the resulting data is returned in a ByteSequence to avoid an extra byte[] allocation.
ByteArrayOutputStream() - Constructor for class org.apache.activemq.util.ByteArrayOutputStream
 
ByteArrayOutputStream(int) - Constructor for class org.apache.activemq.util.ByteArrayOutputStream
 
ByteBufferPool - Interface in org.apache.activemq.transport.udp
Represents a pool of ByteBuffer instances.
BYTES_MARSHALLER - Static variable in interface org.apache.activemq.kaha.Store
Byte Marshaller
ByteSequence - Class in org.apache.activemq.util
 
ByteSequence(byte[]) - Constructor for class org.apache.activemq.util.ByteSequence
 
ByteSequence(byte[], int, int) - Constructor for class org.apache.activemq.util.ByteSequence
 
ByteSequenceData - Class in org.apache.activemq.util
Used to write and read primitives to and from a ByteSequence.
BytesJDBCAdapter - Class in org.apache.activemq.store.jdbc.adapter
This JDBCAdapter inserts and extracts BLOB data using the setBytes()/getBytes() operations.
BytesJDBCAdapter() - Constructor for class org.apache.activemq.store.jdbc.adapter.BytesJDBCAdapter
 
BytesMarshaller - Class in org.apache.activemq.kaha
Implementation of a Marshaller for byte arrays
BytesMarshaller() - Constructor for class org.apache.activemq.kaha.BytesMarshaller
 
bytesOut - Variable in class org.apache.activemq.command.ActiveMQBytesMessage
 
bytesOut - Variable in class org.apache.activemq.command.ActiveMQStreamMessage
 

C

Cache - Interface in org.apache.activemq.memory
Defines the interface used to cache messages.
cacheEnabled - Variable in class org.apache.activemq.broker.region.cursors.AbstractStoreCursor
 
CacheEntry - Class in org.apache.activemq.memory
 
CacheEntry(Object, Object) - Constructor for class org.apache.activemq.memory.CacheEntry
 
CacheEntryList - Class in org.apache.activemq.memory
Maintains a simple linked list of CacheEntry objects.
CacheEntryList() - Constructor for class org.apache.activemq.memory.CacheEntryList
 
CacheEvictionUsageListener - Class in org.apache.activemq.memory
 
CacheEvictionUsageListener(Usage, int, int, TaskRunnerFactory) - Constructor for class org.apache.activemq.memory.CacheEvictionUsageListener
 
CacheEvictor - Interface in org.apache.activemq.memory
 
CacheFilter - Class in org.apache.activemq.memory
Filters another Cache implementation.
CacheFilter(Cache) - Constructor for class org.apache.activemq.memory.CacheFilter
 
caclPercentUsage() - Method in class org.apache.activemq.usage.Usage
 
Callback - Interface in org.apache.activemq.util
A simple callback object used by the TransactionTemplate and org.apache.activemq.util.ExceptionTemplate objects to provide automatic transactional or exception handling blocks.
cancel(Runnable) - Static method in class org.apache.activemq.thread.Scheduler
 
canDispatch(MessageReference) - Method in class org.apache.activemq.broker.region.DurableTopicSubscription
 
canDispatch(Subscription, MessageReference) - Method in interface org.apache.activemq.broker.region.policy.DispatchSelector
return true if a subscription can dispatch a message reference
canDispatch(Subscription, MessageReference) - Method in class org.apache.activemq.broker.region.policy.SimpleDispatchSelector
 
canDispatch(MessageReference) - Method in class org.apache.activemq.broker.region.PrefetchSubscription
Use when a matched message is about to be dispatched to the client.
canDispatch(MessageReference) - Method in class org.apache.activemq.broker.region.QueueBrowserSubscription
 
canDispatch(MessageReference) - Method in class org.apache.activemq.broker.region.QueueSubscription
 
canSelect(Subscription, MessageReference) - Method in class org.apache.activemq.broker.region.QueueDispatchSelector
 
changeScheme(URI, String) - Static method in class org.apache.activemq.util.URISupport
 
changeUserInfo(String, String) - Method in class org.apache.activemq.ActiveMQConnection
Changes the associated username/password that is associated with this connection.
CHAR_TYPE - Static variable in interface org.apache.activemq.command.CommandTypes
 
CHAR_TYPE - Static variable in class org.apache.activemq.util.MarshallingSupport
 
checkClientIDWasManuallySpecified() - Method in class org.apache.activemq.ActiveMQConnection
Ensures that the clientID was manually specified and not auto-generated.
checkClosed() - Method in class org.apache.activemq.ActiveMQConnection
simply throws an exception if the Connection is already closed
checkClosed() - Method in class org.apache.activemq.ActiveMQInputStream
 
checkClosed() - Method in class org.apache.activemq.ActiveMQMessageConsumer
 
checkClosed() - Method in class org.apache.activemq.ActiveMQMessageProducer
Check if the instance of this producer has been closed.
checkClosed() - Method in class org.apache.activemq.ActiveMQMessageProducerSupport
 
checkClosed() - Method in class org.apache.activemq.ActiveMQSession
Check if the session is closed.
checkClosed() - Method in class org.apache.activemq.kaha.impl.container.BaseContainerImpl
 
checkClosed() - Method in class org.apache.activemq.transport.nio.NIOOutputStream
Checks that the stream has not been closed
checkClosedOrFailed() - Method in class org.apache.activemq.ActiveMQConnection
simply throws an exception if the Connection is already closed or the Transport has failed
checkConnected() - Method in class org.apache.activemq.transport.stomp.ProtocolConverter
 
checkEqualOperand(Expression) - Static method in class org.apache.activemq.filter.ComparisonExpression
Validates that the expression can be used in == or <> expression.
checkLessThanOperand(Expression) - Static method in class org.apache.activemq.filter.ComparisonExpression
Only Numeric expressions can be used in >, >=, < or <= expressions.s
checkMessageListener() - Method in class org.apache.activemq.ActiveMQMessageConsumer
 
checkMessageListener() - Method in class org.apache.activemq.ActiveMQSession
 
checkParenthesis(String) - Static method in class org.apache.activemq.util.URISupport
 
checkpoint(boolean) - Method in class org.apache.activemq.store.amq.AMQPersistenceAdapter
When we checkpoint we move all the journalled data to long term storage.
checkpoint() - Method in class org.apache.activemq.store.amq.AMQTransactionStore
 
checkpoint(boolean) - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
 
checkpoint() - Method in class org.apache.activemq.store.journal.JournalMessageStore
 
checkpoint(Callback) - Method in class org.apache.activemq.store.journal.JournalMessageStore
 
checkpoint(boolean, boolean) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
When we checkpoint we move all the journalled data to long term storage.
checkpoint(boolean) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
 
checkpoint() - Method in class org.apache.activemq.store.journal.JournalTopicMessageStore
 
checkpoint() - Method in class org.apache.activemq.store.journal.JournalTransactionStore
 
checkpoint(boolean) - Method in class org.apache.activemq.store.kahadaptor.KahaPersistenceAdapter
 
checkpoint(boolean) - Method in class org.apache.activemq.store.memory.MemoryPersistenceAdapter
 
checkpoint(boolean) - Method in interface org.apache.activemq.store.PersistenceAdapter
checkpoint any
checkReadOnlyBody() - Method in class org.apache.activemq.command.ActiveMQMessage
 
checkStarted() - Method in class org.apache.activemq.transport.TransportSupport
 
checkValidObject(Object) - Method in class org.apache.activemq.command.ActiveMQMessage
 
checkWriteOnlyBody() - Method in class org.apache.activemq.command.ActiveMQBytesMessage
 
checkWriteOnlyBody() - Method in class org.apache.activemq.command.ActiveMQStreamMessage
 
chooseValue(ActiveMQDestination) - Method in class org.apache.activemq.filter.DestinationMap
Returns the value which matches the given destination or null if there is no matching value.
ClassLoadingAwareObjectInputStream - Class in org.apache.activemq.util
 
ClassLoadingAwareObjectInputStream(InputStream) - Constructor for class org.apache.activemq.util.ClassLoadingAwareObjectInputStream
 
cleanup() - Method in class org.apache.activemq.ActiveMQConnection
Cleans up this connection so that it's state is as if the connection was just created.
cleanup() - Method in class org.apache.activemq.store.amq.AMQPersistenceAdapter
Cleans up the data files
cleanup() - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
 
cleanup() - Method in class org.apache.activemq.TransactionContext
 
cleanupTask - Variable in class org.apache.activemq.kaha.impl.async.AsyncDataManager
 
clear() - Method in class org.apache.activemq.broker.MapTransportConnectionStateRegister
 
clear() - Method in class org.apache.activemq.broker.region.cursors.AbstractPendingMessageCursor
 
clear() - Method in class org.apache.activemq.broker.region.cursors.AbstractStoreCursor
 
clear() - Method in class org.apache.activemq.broker.region.cursors.FilePendingMessageCursor
clear all pending messages
clear() - Method in interface org.apache.activemq.broker.region.cursors.PendingMessageCursor
clear all pending messages
clear() - Method in class org.apache.activemq.broker.region.cursors.StoreDurableSubscriberCursor
 
clear() - Method in class org.apache.activemq.broker.region.cursors.StoreQueueCursor
 
clear() - Method in class org.apache.activemq.broker.region.cursors.VMPendingMessageCursor
clear all pending messages
clear() - Method in class org.apache.activemq.broker.SingleTransportConnectionStateRegister
 
clear() - Method in interface org.apache.activemq.broker.TransportConnectionStateRegister
 
clear() - Method in class org.apache.activemq.filter.MessageEvaluationContext
 
clear() - Method in class org.apache.activemq.kaha.impl.container.BaseContainerImpl
 
clear() - Method in class org.apache.activemq.kaha.impl.container.ContainerEntrySet
 
clear() - Method in class org.apache.activemq.kaha.impl.container.ContainerKeySet
 
clear() - Method in class org.apache.activemq.kaha.impl.container.ListContainerImpl
 
clear() - Method in class org.apache.activemq.kaha.impl.container.MapContainerImpl
 
clear() - Method in class org.apache.activemq.kaha.impl.index.DiskIndexLinkedList
Removes all of the elements from this list.
clear() - Method in class org.apache.activemq.kaha.impl.index.hash.HashIndex
 
clear() - Method in interface org.apache.activemq.kaha.impl.index.Index
clear the index
clear() - Method in interface org.apache.activemq.kaha.impl.index.IndexLinkedList
Removes all of the elements from this list.
clear() - Method in class org.apache.activemq.kaha.impl.index.tree.TreeIndex
 
clear() - Method in class org.apache.activemq.kaha.impl.index.VMIndex
 
clear() - Method in class org.apache.activemq.kaha.impl.index.VMIndexLinkedList
 
clear() - Method in class org.apache.activemq.kaha.impl.KahaStore
 
clear() - Method in interface org.apache.activemq.kaha.MapContainer
empty the container
clear() - Method in interface org.apache.activemq.kaha.Store
empty all the contents of the store
clear() - Method in interface org.apache.activemq.memory.buffer.MessageBuffer
 
clear() - Method in class org.apache.activemq.memory.buffer.MessageQueue
 
clear() - Method in class org.apache.activemq.memory.buffer.OrderBasedMessageBuffer
 
clear() - Method in class org.apache.activemq.memory.buffer.SizeBasedMessageBuffer
 
clear() - Method in class org.apache.activemq.memory.CacheEntryList
 
clear() - Method in class org.apache.activemq.memory.list.DestinationBasedMessageList
 
clear() - Method in interface org.apache.activemq.memory.list.MessageList
 
clear() - Method in class org.apache.activemq.memory.list.SimpleMessageList
 
clear() - Method in class org.apache.activemq.MessageDispatchChannel
 
clear() - Method in class org.apache.activemq.openwire.BooleanStream
 
clear() - Method in class org.apache.activemq.store.kahadaptor.TopicSubContainer
 
clear() - Method in class org.apache.activemq.util.LRUSet
 
clearBody() - Method in class org.apache.activemq.command.ActiveMQBytesMessage
Clears out the message body.
clearBody() - Method in class org.apache.activemq.command.ActiveMQMapMessage
Clears out the message body.
clearBody() - Method in class org.apache.activemq.command.ActiveMQMessage
 
clearBody() - Method in class org.apache.activemq.command.ActiveMQObjectMessage
Clears out the message body.
clearBody() - Method in class org.apache.activemq.command.ActiveMQStreamMessage
Clears out the message body.
clearBody() - Method in class org.apache.activemq.command.ActiveMQTextMessage
Clears out the message body.
clearBody() - Method in class org.apache.activemq.command.Message
 
clearBridges() - Method in class org.apache.activemq.network.jms.JmsConnector
 
clearDownSubscriptions() - Method in class org.apache.activemq.network.DemandForwardingBridgeSupport
 
clearMessageCache() - Method in class org.apache.activemq.filter.MessageEvaluationContext
A strategy hook to allow per-message caches to be cleared
clearMessageCache() - Method in class org.apache.activemq.filter.NonCachedMessageEvaluationContext
 
clearMessages() - Method in class org.apache.activemq.store.kahadaptor.KahaReferenceStoreAdapter
 
clearMessages() - Method in interface org.apache.activemq.store.ReferenceStoreAdapter
called by recover to clear out message references
clearMessagesInProgress() - Method in class org.apache.activemq.ActiveMQSessionExecutor
 
clearProperties() - Method in class org.apache.activemq.command.ActiveMQMessage
 
clearProperties() - Method in class org.apache.activemq.command.Message
 
clearProperties() - Method in class org.apache.activemq.command.WireFormatInfo
 
CLIENT - Static variable in interface org.apache.activemq.transport.stomp.Stomp.Headers.Subscribe.AckModeValues
 
CLIENT_ACK - Static variable in class org.apache.activemq.transport.stomp.StompSubscription
 
CLIENT_ID - Static variable in interface org.apache.activemq.transport.stomp.Stomp.Headers.Connect
 
clientID - Variable in class org.apache.activemq.ActiveMQConnectionFactory
 
clientId - Variable in class org.apache.activemq.broker.jmx.SubscriptionView
 
clientId - Variable in class org.apache.activemq.command.ConnectionInfo
 
clientId - Variable in class org.apache.activemq.command.RemoveSubscriptionInfo
 
clientId - Variable in class org.apache.activemq.command.SubscriptionInfo
 
clientId - Variable in class org.apache.activemq.util.SubscriptionKey
 
ClientInternalExceptionListener - Interface in org.apache.activemq
An exception listener similar to the standard javax.jms.ExceptionListener which can be used by client code to be notified of exceptions thrown by container components (e.g.
clientMaster - Variable in class org.apache.activemq.command.ConnectionInfo
 
CLOCK_DAEMON - Static variable in class org.apache.activemq.thread.Scheduler
 
clone() - Method in class org.apache.activemq.kaha.impl.index.VMIndexLinkedList
 
close() - Method in class org.apache.activemq.ActiveMQConnection
Closes the connection.
close() - Method in class org.apache.activemq.ActiveMQConnectionConsumer
Closes the connection consumer.
close() - Method in class org.apache.activemq.ActiveMQInputStream
 
close() - Method in class org.apache.activemq.ActiveMQMessageConsumer
Closes the message consumer.
close() - Method in class org.apache.activemq.ActiveMQMessageProducer
Closes the message producer.
close() - Method in class org.apache.activemq.ActiveMQOutputStream
 
close() - Method in class org.apache.activemq.ActiveMQQueueBrowser
 
close() - Method in class org.apache.activemq.ActiveMQQueueSession
 
close() - Method in class org.apache.activemq.ActiveMQSession
Closes the session.
close(ConsumerId) - Method in class org.apache.activemq.ActiveMQSession
 
close() - Method in class org.apache.activemq.ActiveMQTopicSession
 
close() - Method in interface org.apache.activemq.Closeable
Closes a JMS object.
close - Variable in class org.apache.activemq.command.ConnectionControl
 
close - Variable in class org.apache.activemq.command.ConsumerControl
 
close() - Method in class org.apache.activemq.jndi.ReadOnlyContext
 
close() - Method in class org.apache.activemq.kaha.impl.async.AsyncDataManager
 
close() - Method in class org.apache.activemq.kaha.impl.async.DataFileAccessorPool
 
close() - Method in class org.apache.activemq.kaha.impl.async.DataManagerFacade
 
close() - Method in class org.apache.activemq.kaha.impl.async.JournalFacade
 
close() - Method in class org.apache.activemq.kaha.impl.async.ReadOnlyAsyncDataManager
 
close() - Method in class org.apache.activemq.kaha.impl.container.BaseContainerImpl
 
close() - Method in class org.apache.activemq.kaha.impl.data.DataManagerImpl
 
close() - Method in class org.apache.activemq.kaha.impl.data.SyncDataFileWriter
 
close() - Method in interface org.apache.activemq.kaha.impl.DataManager
 
close() - Method in class org.apache.activemq.kaha.impl.index.IndexManager
 
close() - Method in class org.apache.activemq.kaha.impl.KahaStore
 
close() - Method in interface org.apache.activemq.kaha.Store
close the store
close() - Method in interface org.apache.activemq.memory.Cache
Lets a cache know it will not be used any further and that it can release acquired resources
close() - Method in class org.apache.activemq.memory.CacheFilter
 
close() - Method in class org.apache.activemq.memory.MapCache
 
close() - Method in class org.apache.activemq.memory.UsageManagerCacheFilter
 
close() - Method in class org.apache.activemq.MessageDispatchChannel
 
close() - Method in class org.apache.activemq.store.jdbc.TransactionContext
 
close() - Method in class org.apache.activemq.transport.nio.NIOInputStream
 
close() - Method in class org.apache.activemq.transport.nio.NIOOutputStream
close this stream
close() - Method in class org.apache.activemq.transport.nio.SelectorSelection
 
close() - Method in class org.apache.activemq.transport.tcp.ResponseHolder
close this holder
close() - Method in class org.apache.activemq.transport.tcp.TcpBufferedInputStream
 
close() - Method in class org.apache.activemq.transport.tcp.TcpBufferedOutputStream
close this stream
Closeable - Interface in org.apache.activemq
Provides a uniform interface that can be used to close all the JMS obejcts that provide a close() method.
closeAsync - Variable in class org.apache.activemq.transport.tcp.TcpTransport
 
closed - Variable in class org.apache.activemq.ActiveMQMessageProducer
 
closed - Variable in class org.apache.activemq.ActiveMQSession
 
closed - Variable in class org.apache.activemq.kaha.impl.container.BaseContainerImpl
 
closeRandomAccessFile(RandomAccessFile) - Method in class org.apache.activemq.kaha.impl.async.DataFile
 
closeRandomAccessFile(RandomAccessFile) - Method in class org.apache.activemq.kaha.impl.async.ReadOnlyDataFile
 
closeStreams() - Method in class org.apache.activemq.transport.tcp.TcpTransport
 
column - Variable in class org.apache.activemq.selector.SimpleCharStream
 
Command - Interface in org.apache.activemq.command
The Command Pattern so that we can send and receive commands on the different transports
COMMAND - Static variable in class org.apache.activemq.command.FlushCommand
 
COMMAND_MARSHALLER - Static variable in interface org.apache.activemq.kaha.Store
Command Marshaller
CommandAgent - Class in org.apache.activemq.broker.util
An agent which listens to commands on a JMS destination
CommandAgent() - Constructor for class org.apache.activemq.broker.util.CommandAgent
 
CommandChannel - Interface in org.apache.activemq.transport.udp
 
CommandChannelSupport - Class in org.apache.activemq.transport.udp
 
CommandChannelSupport(UdpTransport, OpenWireFormat, int, SocketAddress, DatagramHeaderMarshaller) - Constructor for class org.apache.activemq.transport.udp.CommandChannelSupport
 
CommandDatagramChannel - Class in org.apache.activemq.transport.udp
A strategy for reading datagrams and de-fragmenting them together.
CommandDatagramChannel(UdpTransport, OpenWireFormat, int, SocketAddress, DatagramHeaderMarshaller, DatagramChannel, ByteBufferPool) - Constructor for class org.apache.activemq.transport.udp.CommandDatagramChannel
 
CommandDatagramSocket - Class in org.apache.activemq.transport.udp
A strategy for reading datagrams and de-fragmenting them together.
CommandDatagramSocket(UdpTransport, OpenWireFormat, int, SocketAddress, DatagramHeaderMarshaller, DatagramSocket) - Constructor for class org.apache.activemq.transport.udp.CommandDatagramSocket
 
CommandHandler - Interface in org.apache.activemq.broker.util
Represents a processor of text based commands
commandId - Variable in class org.apache.activemq.command.BaseCommand
 
CommandIdComparator - Class in org.apache.activemq.openwire
A @{link Comparator} of commands using their Command.getCommandId()
CommandIdComparator() - Constructor for class org.apache.activemq.openwire.CommandIdComparator
 
CommandJoiner - Class in org.apache.activemq.transport
Joins together of partial commands which were split into individual chunks of data.
CommandJoiner(Transport, OpenWireFormat) - Constructor for class org.apache.activemq.transport.CommandJoiner
 
CommandMarshaller - Class in org.apache.activemq.kaha
Marshall a Message or a MessageReference
CommandMarshaller(WireFormat) - Constructor for class org.apache.activemq.kaha.CommandMarshaller
 
CommandMarshaller() - Constructor for class org.apache.activemq.kaha.CommandMarshaller
 
CommandMessageListener - Class in org.apache.activemq.broker.util
 
CommandMessageListener(Session) - Constructor for class org.apache.activemq.broker.util.CommandMessageListener
 
CommandTypes - Interface in org.apache.activemq.command
Holds the command id constants used by the command objects.
CommandVisitor - Interface in org.apache.activemq.state
 
CommandVisitorAdapter - Class in org.apache.activemq.state
 
CommandVisitorAdapter() - Constructor for class org.apache.activemq.state.CommandVisitorAdapter
 
commit() - Method in class org.apache.activemq.ActiveMQMessageConsumer
 
commit() - Method in class org.apache.activemq.ActiveMQQueueSession
 
commit() - Method in class org.apache.activemq.ActiveMQSession
Commits all messages done in this transaction and releases any locks currently held.
commit() - Method in class org.apache.activemq.ActiveMQTopicSession
 
commit() - Method in class org.apache.activemq.ActiveMQXASession
 
commit(TransactionId, boolean) - Method in class org.apache.activemq.store.amq.AMQTransactionStore
 
commit() - Method in class org.apache.activemq.store.jdbc.TransactionContext
 
commit(TransactionId, boolean) - Method in class org.apache.activemq.store.journal.JournalTransactionStore
 
commit(TransactionId, boolean) - Method in class org.apache.activemq.store.kahadaptor.KahaTransactionStore
 
commit(TransactionId, boolean) - Method in class org.apache.activemq.store.memory.MemoryTransactionStore
 
commit() - Method in class org.apache.activemq.store.memory.MemoryTransactionStore.Tx
 
commit(TransactionId, boolean) - Method in interface org.apache.activemq.store.TransactionStore
 
commit(boolean) - Method in class org.apache.activemq.transaction.LocalTransaction
 
commit(boolean) - Method in class org.apache.activemq.transaction.Transaction
 
commit(boolean) - Method in class org.apache.activemq.transaction.XATransaction
 
commit() - Method in class org.apache.activemq.TransactionContext
Commits all work done in this transaction and releases any locks currently held.
commit(Xid, boolean) - Method in class org.apache.activemq.TransactionContext
 
COMMIT - Static variable in interface org.apache.activemq.transport.stomp.Stomp.Commands
 
COMMIT_ONE_PHASE - Static variable in class org.apache.activemq.command.TransactionInfo
 
COMMIT_TRANSACTION - Static variable in interface org.apache.activemq.transport.stomp.Stomp.Commands
 
COMMIT_TWO_PHASE - Static variable in class org.apache.activemq.command.TransactionInfo
 
commitEvent() - Method in interface org.apache.activemq.LocalTransactionEventListener
 
commitTransaction(ConnectionContext, TransactionId, boolean) - Method in interface org.apache.activemq.broker.Broker
Commits a transaction.
commitTransaction(ConnectionContext, TransactionId, boolean) - Method in class org.apache.activemq.broker.BrokerBroadcaster
 
commitTransaction(ConnectionContext, TransactionId, boolean) - Method in class org.apache.activemq.broker.BrokerFilter
 
commitTransaction(ConnectionContext, TransactionId, boolean) - Method in class org.apache.activemq.broker.EmptyBroker
 
commitTransaction(ConnectionContext, TransactionId, boolean) - Method in class org.apache.activemq.broker.ErrorBroker
 
commitTransaction(ConnectionContext, TransactionId, boolean) - Method in class org.apache.activemq.broker.ft.MasterBroker
Commits a transaction.
commitTransaction(ConnectionContext, TransactionId, boolean) - Method in class org.apache.activemq.broker.MutableBrokerFilter
 
commitTransaction(ConnectionContext, TransactionId, boolean) - Method in class org.apache.activemq.broker.region.RegionBroker
 
commitTransaction(ConnectionContext, TransactionId, boolean) - Method in class org.apache.activemq.broker.TransactionBroker
 
commitTransaction(ConnectionContext, TransactionId, boolean) - Method in class org.apache.activemq.broker.util.UDPTraceBrokerPlugin
 
commitTransaction(ConnectionContext) - Method in class org.apache.activemq.store.amq.AMQPersistenceAdapter
 
commitTransaction(ConnectionContext) - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
 
commitTransaction(ConnectionContext) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
 
commitTransaction(ConnectionContext) - Method in class org.apache.activemq.store.kahadaptor.KahaPersistenceAdapter
 
commitTransaction(ConnectionContext) - Method in class org.apache.activemq.store.kahadaptor.KahaReferenceStoreAdapter
 
commitTransaction(ConnectionContext) - Method in class org.apache.activemq.store.memory.MemoryPersistenceAdapter
 
commitTransaction(ConnectionContext) - Method in interface org.apache.activemq.store.PersistenceAdapter
Commit a persistence transaction
compact() - Method in class org.apache.activemq.util.ByteSequence
 
compare(ActiveMQDestination, ActiveMQDestination) - Static method in class org.apache.activemq.command.ActiveMQDestination
 
compare(Comparable, Comparable) - Method in class org.apache.activemq.filter.ComparisonExpression
 
compare(Command, Command) - Method in class org.apache.activemq.openwire.CommandIdComparator
 
compare(String, String) - Static method in class org.apache.activemq.util.IdGenerator
Does a proper compare on the ids
compare(Object, Object) - Method in class org.apache.activemq.util.MessageComparatorSupport
 
compareComparators(Comparable, Comparable) - Method in class org.apache.activemq.util.MessageComparatorSupport
 
compareMessages(Message, Message) - Method in class org.apache.activemq.util.MessageComparatorSupport
 
compareMessages(Message, Message) - Method in class org.apache.activemq.util.MessageDestinationComparator
 
compareTo(Object) - Method in class org.apache.activemq.command.ActiveMQDestination
 
compareTo(ConnectionId) - Method in class org.apache.activemq.command.ConnectionId
 
compareTo(LocalTransactionId) - Method in class org.apache.activemq.command.LocalTransactionId
 
compareTo(MessageId) - Method in class org.apache.activemq.command.MessageId
 
compareTo(Object) - Method in class org.apache.activemq.command.XATransactionId
 
compareTo(Object) - Method in class org.apache.activemq.filter.DestinationMapEntry
 
compareTo(DataFile) - Method in class org.apache.activemq.kaha.impl.async.DataFile
 
compareTo(Object) - Method in class org.apache.activemq.kaha.impl.async.JournalFacade.RecordLocationFacade
 
compareTo(Location) - Method in class org.apache.activemq.kaha.impl.async.Location
 
ComparisonExpression - Class in org.apache.activemq.filter
A filter performing a comparison of two objects
ComparisonExpression(Expression, Expression) - Constructor for class org.apache.activemq.filter.ComparisonExpression
 
comparisonExpression() - Method in class org.apache.activemq.selector.SelectorParser
 
composeName(Name, Name) - Method in class org.apache.activemq.jndi.ReadOnlyContext
 
composeName(String, String) - Method in class org.apache.activemq.jndi.ReadOnlyContext
 
COMPOSITE_SEPERATOR - Static variable in class org.apache.activemq.command.ActiveMQDestination
 
compositeConfigure(Transport, WireFormat, Map) - Method in class org.apache.activemq.transport.stomp.StompSslTransportFactory
 
compositeConfigure(Transport, WireFormat, Map) - Method in class org.apache.activemq.transport.stomp.StompTransportFactory
 
compositeConfigure(Transport, WireFormat, Map) - Method in class org.apache.activemq.transport.tcp.SslTransportFactory
Overriding to allow for proper configuration through reflection.
compositeConfigure(Transport, WireFormat, Map) - Method in class org.apache.activemq.transport.tcp.TcpTransportFactory
 
compositeConfigure(Transport, WireFormat, Map) - Method in class org.apache.activemq.transport.TransportFactory
Similar to configure(...) but this avoid adding in the MutexTransport and ResponseCorrelator transport layers so that the resulting transport can more efficiently be used as part of a composite transport.
compositeConfigure(Transport, WireFormat, Map) - Method in class org.apache.activemq.transport.udp.UdpTransportFactory
 
compositeConnect(URI) - Static method in class org.apache.activemq.transport.TransportFactory
Creates a slimmed down transport that is more efficient so that it can be used by composite transports like reliable and HA.
compositeConnect(URI, Executor) - Static method in class org.apache.activemq.transport.TransportFactory
Creates a slimmed down transport that is more efficient so that it can be used by composite transports like reliable and HA.
CompositeDataConstants - Interface in org.apache.activemq.broker.jmx
 
CompositeDataHelper - Class in org.apache.activemq.broker.jmx
 
CompositeDataHelper() - Constructor for class org.apache.activemq.broker.jmx.CompositeDataHelper
 
CompositeDemandForwardingBridge - Class in org.apache.activemq.network
A demand forwarding bridge which works with multicast style transports where a single Transport could be communicating with multiple remote brokers
CompositeDemandForwardingBridge(NetworkBridgeConfiguration, Transport, Transport) - Constructor for class org.apache.activemq.network.CompositeDemandForwardingBridge
 
CompositeDestination - Class in org.apache.activemq.broker.region.virtual
 
CompositeDestination() - Constructor for class org.apache.activemq.broker.region.virtual.CompositeDestination
 
CompositeDestinationBroker - Class in org.apache.activemq.broker
This broker filter handles composite destinations.
CompositeDestinationBroker(Broker) - Constructor for class org.apache.activemq.broker.CompositeDestinationBroker
 
CompositeDestinationFilter - Class in org.apache.activemq.broker.region.virtual
Represents a composite Destination where send()s are replicated to each Destination instance.
CompositeDestinationFilter(Destination, Collection, boolean, boolean) - Constructor for class org.apache.activemq.broker.region.virtual.CompositeDestinationFilter
 
CompositeDestinationFilter - Class in org.apache.activemq.filter
A DestinationFilter used for composite destinations
CompositeDestinationFilter(ActiveMQDestination) - Constructor for class org.apache.activemq.filter.CompositeDestinationFilter
 
CompositeDestinationInterceptor - Class in org.apache.activemq.broker.region
Represents a Composite Pattern of a DestinationInterceptor
CompositeDestinationInterceptor(DestinationInterceptor[]) - Constructor for class org.apache.activemq.broker.region.CompositeDestinationInterceptor
 
compositeDestinations - Variable in class org.apache.activemq.command.ActiveMQDestination
 
CompositeQueue - Class in org.apache.activemq.broker.region.virtual
Represents a virtual queue which forwards to a number of other destinations.
CompositeQueue() - Constructor for class org.apache.activemq.broker.region.virtual.CompositeQueue
 
CompositeTopic - Class in org.apache.activemq.broker.region.virtual
Represents a virtual topic which forwards to a number of other destinations.
CompositeTopic() - Constructor for class org.apache.activemq.broker.region.virtual.CompositeTopic
 
CompositeTransport - Interface in org.apache.activemq.transport
 
compressed - Variable in class org.apache.activemq.command.Message
 
ConduitBridge - Class in org.apache.activemq.network
Consolidates subscriptions
ConduitBridge(NetworkBridgeConfiguration, Transport, Transport) - Constructor for class org.apache.activemq.network.ConduitBridge
Constructor
configuration - Variable in class org.apache.activemq.network.DemandForwardingBridgeSupport
 
configuration - Variable in class org.apache.activemq.security.JaasAuthenticationPlugin
 
ConfigurationException - Exception in org.apache.activemq
An exception thrown when a service is not correctly configured
ConfigurationException(String) - Constructor for exception org.apache.activemq.ConfigurationException
 
configure(Broker, Queue) - Method in class org.apache.activemq.broker.region.policy.PolicyEntry
 
configure(Topic) - Method in class org.apache.activemq.broker.region.policy.PolicyEntry
 
configure(Broker, SystemUsage, TopicSubscription) - Method in class org.apache.activemq.broker.region.policy.PolicyEntry
 
configure(Broker, SystemUsage, DurableTopicSubscription) - Method in class org.apache.activemq.broker.region.policy.PolicyEntry
 
configure(ActiveMQMessage) - Method in class org.apache.activemq.broker.region.policy.QueryBasedSubscriptionRecoveryPolicy
 
configure(Command) - Method in class org.apache.activemq.command.LastPartialCommand
Lets copy across any transient fields from this command to the complete command when it is unmarshalled on the other end
configure(ConsumerInfo) - Method in class org.apache.activemq.command.MessagePull
Configures a message pull from the consumer information
configure(Transport, WireFormat, Map) - Method in class org.apache.activemq.transport.TransportFactory
Fully configures and adds all need transport filters so that the transport can be used by the JMS client.
configure(Transport, WireFormat, Map) - Method in class org.apache.activemq.transport.udp.UdpTransportFactory
 
configure(Transport, WireFormat, Map, boolean) - Method in class org.apache.activemq.transport.udp.UdpTransportFactory
Configures the transport
configure(Transport) - Static method in class org.apache.activemq.transport.vm.VMTransportServer
Configure transport
configureBridge(DemandForwardingBridgeSupport) - Method in class org.apache.activemq.network.NetworkConnector
 
configureClientSideNegotiator(Transport, WireFormat, UdpTransport) - Method in class org.apache.activemq.transport.udp.UdpTransportFactory
 
configureConnection(ActiveMQConnection) - Method in class org.apache.activemq.ActiveMQConnectionFactory
 
configureDemandSubscription(ConsumerInfo, DemandSubscription) - Method in class org.apache.activemq.network.DemandForwardingBridgeSupport
 
configureMessage(ActiveMQMessage) - Method in class org.apache.activemq.ActiveMQSession
Checks that the session is not closed then configures the message
configureMessage(MessageDispatch) - Method in class org.apache.activemq.network.DemandForwardingBridgeSupport
 
configureQueue(Queue, ActiveMQDestination) - Method in class org.apache.activemq.broker.region.DestinationFactoryImpl
 
configureService(Object) - Method in class org.apache.activemq.broker.BrokerService
Perform any custom dependency injection
configureServices(Object[]) - Method in class org.apache.activemq.broker.BrokerService
Perform any custom dependency injection
configureTopic(Topic, ActiveMQDestination) - Method in class org.apache.activemq.broker.region.DestinationFactoryImpl
 
configureTopic(Topic, ActiveMQDestination) - Method in class org.apache.activemq.broker.region.TopicRegion
 
configureTransport(Transport) - Method in class org.apache.activemq.transport.udp.UdpTransportServer
 
CONNECT - Static variable in interface org.apache.activemq.transport.stomp.Stomp.Commands
 
connect() - Method in class org.apache.activemq.transport.tcp.TcpTransport
 
connect(URI) - Static method in class org.apache.activemq.transport.TransportFactory
Creates a normal transport.
connect(URI, Executor) - Static method in class org.apache.activemq.transport.TransportFactory
Creates a normal transport.
connect(DatagramChannel, SocketAddress) - Method in class org.apache.activemq.transport.udp.UdpTransport
 
connect() - Method in class org.apache.activemq.transport.vm.VMTransportServer
 
CONNECTED - Static variable in interface org.apache.activemq.transport.stomp.Stomp.Responses
 
connection - Variable in class org.apache.activemq.ActiveMQSession
 
Connection - Interface in org.apache.activemq.broker
 
connection - Variable in class org.apache.activemq.command.ActiveMQTempDestination
 
CONNECTION_ADVISORY_TOPIC - Static variable in class org.apache.activemq.advisory.AdvisorySupport
 
CONNECTION_CONTROL - Static variable in interface org.apache.activemq.command.CommandTypes
 
CONNECTION_ERROR - Static variable in interface org.apache.activemq.command.CommandTypes
 
CONNECTION_ID - Static variable in interface org.apache.activemq.command.CommandTypes
 
CONNECTION_INFO - Static variable in interface org.apache.activemq.command.CommandTypes
 
CONNECTION_PASSWORD - Static variable in class org.apache.activemq.security.LDAPAuthorizationMap
 
CONNECTION_PROTOCOL - Static variable in class org.apache.activemq.security.LDAPAuthorizationMap
 
CONNECTION_URL - Static variable in class org.apache.activemq.security.LDAPAuthorizationMap
 
CONNECTION_USERNAME - Static variable in class org.apache.activemq.security.LDAPAuthorizationMap
 
ConnectionClosedException - Exception in org.apache.activemq
An exception thrown when attempt is made to use a connection when the connection has been closed.
ConnectionClosedException() - Constructor for exception org.apache.activemq.ConnectionClosedException
 
ConnectionContext - Class in org.apache.activemq.broker
Used to hold context information needed to process requests sent to a broker.
ConnectionContext() - Constructor for class org.apache.activemq.broker.ConnectionContext
 
ConnectionContext(MessageEvaluationContext) - Constructor for class org.apache.activemq.broker.ConnectionContext
 
ConnectionContext(ConnectionInfo) - Constructor for class org.apache.activemq.broker.ConnectionContext
 
ConnectionControl - Class in org.apache.activemq.command
Used to start and stop transports as well as terminating clients.
ConnectionControl() - Constructor for class org.apache.activemq.command.ConnectionControl
 
ConnectionControlMarshaller - Class in org.apache.activemq.openwire.v1
Marshalling code for Open Wire Format for ConnectionControlMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
ConnectionControlMarshaller() - Constructor for class org.apache.activemq.openwire.v1.ConnectionControlMarshaller
 
ConnectionControlMarshaller - Class in org.apache.activemq.openwire.v2
Marshalling code for Open Wire Format for ConnectionControlMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
ConnectionControlMarshaller() - Constructor for class org.apache.activemq.openwire.v2.ConnectionControlMarshaller
 
ConnectionControlMarshaller - Class in org.apache.activemq.openwire.v3
Marshalling code for Open Wire Format for ConnectionControlMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
ConnectionControlMarshaller() - Constructor for class org.apache.activemq.openwire.v3.ConnectionControlMarshaller
 
ConnectionDotFileInterceptor - Class in org.apache.activemq.broker.view
 
ConnectionDotFileInterceptor(Broker, String, boolean) - Constructor for class org.apache.activemq.broker.view.ConnectionDotFileInterceptor
 
ConnectionDotFilePlugin - Class in org.apache.activemq.broker.view
A DOT file creator plugin which creates a DOT file showing the current connections
ConnectionDotFilePlugin() - Constructor for class org.apache.activemq.broker.view.ConnectionDotFilePlugin
 
ConnectionError - Class in org.apache.activemq.command
 
ConnectionError() - Constructor for class org.apache.activemq.command.ConnectionError
 
ConnectionErrorMarshaller - Class in org.apache.activemq.openwire.v1
Marshalling code for Open Wire Format for ConnectionErrorMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
ConnectionErrorMarshaller() - Constructor for class org.apache.activemq.openwire.v1.ConnectionErrorMarshaller
 
ConnectionErrorMarshaller - Class in org.apache.activemq.openwire.v2
Marshalling code for Open Wire Format for ConnectionErrorMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
ConnectionErrorMarshaller() - Constructor for class org.apache.activemq.openwire.v2.ConnectionErrorMarshaller
 
ConnectionErrorMarshaller - Class in org.apache.activemq.openwire.v3
Marshalling code for Open Wire Format for ConnectionErrorMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
ConnectionErrorMarshaller() - Constructor for class org.apache.activemq.openwire.v3.ConnectionErrorMarshaller
 
ConnectionFailedException - Exception in org.apache.activemq
An exception thrown when the a connection failure is detected (peer might close the connection, or a keep alive times out, etc.)
ConnectionFailedException(IOException) - Constructor for exception org.apache.activemq.ConnectionFailedException
 
ConnectionFailedException() - Constructor for exception org.apache.activemq.ConnectionFailedException
 
ConnectionFilter - Interface in org.apache.activemq.network
Abstraction that allows you to control which brokers a NetworkConnector connects bridges to.
connectionFilter - Variable in class org.apache.activemq.network.NetworkConnector
 
connectionId - Variable in class org.apache.activemq.command.ActiveMQTempDestination
 
ConnectionId - Class in org.apache.activemq.command
 
ConnectionId() - Constructor for class org.apache.activemq.command.ConnectionId
 
ConnectionId(String) - Constructor for class org.apache.activemq.command.ConnectionId
 
ConnectionId(ConnectionId) - Constructor for class org.apache.activemq.command.ConnectionId
 
ConnectionId(SessionId) - Constructor for class org.apache.activemq.command.ConnectionId
 
ConnectionId(ProducerId) - Constructor for class org.apache.activemq.command.ConnectionId
 
ConnectionId(ConsumerId) - Constructor for class org.apache.activemq.command.ConnectionId
 
connectionId - Variable in class org.apache.activemq.command.ConnectionInfo
 
connectionId - Variable in class org.apache.activemq.command.ConsumerId
 
connectionId - Variable in class org.apache.activemq.command.DestinationInfo
 
connectionId - Variable in class org.apache.activemq.command.LocalTransactionId
 
connectionId - Variable in class org.apache.activemq.command.ProducerId
 
connectionId - Variable in class org.apache.activemq.command.RemoveSubscriptionInfo
 
connectionId - Variable in class org.apache.activemq.command.SessionId
 
connectionId - Variable in class org.apache.activemq.command.TransactionInfo
 
ConnectionIdMarshaller - Class in org.apache.activemq.openwire.v1
Marshalling code for Open Wire Format for ConnectionIdMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
ConnectionIdMarshaller() - Constructor for class org.apache.activemq.openwire.v1.ConnectionIdMarshaller
 
ConnectionIdMarshaller - Class in org.apache.activemq.openwire.v2
Marshalling code for Open Wire Format for ConnectionIdMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
ConnectionIdMarshaller() - Constructor for class org.apache.activemq.openwire.v2.ConnectionIdMarshaller
 
ConnectionIdMarshaller - Class in org.apache.activemq.openwire.v3
Marshalling code for Open Wire Format for ConnectionIdMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
ConnectionIdMarshaller() - Constructor for class org.apache.activemq.openwire.v3.ConnectionIdMarshaller
 
ConnectionInfo - Class in org.apache.activemq.command
 
ConnectionInfo() - Constructor for class org.apache.activemq.command.ConnectionInfo
 
ConnectionInfo(ConnectionId) - Constructor for class org.apache.activemq.command.ConnectionInfo
 
ConnectionInfoMarshaller - Class in org.apache.activemq.openwire.v1
Marshalling code for Open Wire Format for ConnectionInfoMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
ConnectionInfoMarshaller() - Constructor for class org.apache.activemq.openwire.v1.ConnectionInfoMarshaller
 
ConnectionInfoMarshaller - Class in org.apache.activemq.openwire.v2
Marshalling code for Open Wire Format for ConnectionInfoMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
ConnectionInfoMarshaller() - Constructor for class org.apache.activemq.openwire.v2.ConnectionInfoMarshaller
 
ConnectionInfoMarshaller - Class in org.apache.activemq.openwire.v3
Marshalling code for Open Wire Format for ConnectionInfoMarshaller NOTE!: This file is auto generated - do not modify! if you need to make a change, please see the modify the groovy scripts in the under src/gram/script and then use maven openwire:generate to regenerate this file.
ConnectionInfoMarshaller() - Constructor for class org.apache.activemq.openwire.v3.ConnectionInfoMarshaller
 
connections - Variable in class org.apache.activemq.advisory.AdvisoryBroker
 
connections - Variable in class org.apache.activemq.broker.TransportConnector
 
ConnectionSplitBroker - Class in org.apache.activemq.broker.cluster
Monitors for client connections that may fail to another broker - but this broker isn't aware they've gone.
ConnectionSplitBroker(Broker) - Constructor for class org.apache.activemq.broker.cluster.ConnectionSplitBroker
 
ConnectionState - Class in org.apache.activemq.state
 
ConnectionState(ConnectionInfo) - Constructor for class org.apache.activemq.state.ConnectionState
 
connectionStates - Variable in class org.apache.activemq.broker.region.RegionBroker
 
connectionStates - Variable in class org.apache.activemq.state.ConnectionStateTracker
 
ConnectionStateTracker - Class in org.apache.activemq.state
Tracks the state of a connection so a newly established transport can be re-initialized to the state that was tracked.
ConnectionStateTracker()</