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(String) - Method in class org.apache.activemq.transport.stomp.StompConnection
 
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(StompFrame) - Method in class org.apache.activemq.transport.stomp.StompConnection
 
ack(StompFrame, String) - Method in class org.apache.activemq.transport.stomp.StompConnection
 
ack(String) - Method in class org.apache.activemq.transport.stomp.StompConnection
 
ack(String, String) - Method in class org.apache.activemq.transport.stomp.StompConnection
 
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_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
 
addExcludedDestination(ActiveMQDestination) - Method in class org.apache.activemq.network.NetworkConnector
 
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
 
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
 
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
 
appendHeaders(HashMap<String, Object>) - Method in class org.apache.activemq.transport.stomp.StompConnection
 
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
 
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(String) - Method in class org.apache.activemq.transport.stomp.StompConnection
 
BEGIN_TRANSACTION - Static variable in interface org.apache.activemq.transport.stomp.Stomp.Commands
 
beginEvent() - Method in interface org.apache.activemq.LocalTransactionEventListener
 
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.
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
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
 
buffOut - Variable in class org.apache.activemq.transport.tcp.TcpTransport
 
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) - 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
 
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.stomp.StompConnection
 
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
 
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(String) - Method in class org.apache.activemq.transport.stomp.StompConnection
 
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
 
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(String, String) - Method in class org.apache.activemq.transport.stomp.StompConnection
 
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() - Constructor for class org.apache.activemq.state.ConnectionStateTracker
 
ConnectionStatistics - Class in org.apache.activemq.broker.region
The J2EE Statistics for the Connection.
ConnectionStatistics() - Constructor for class org.apache.activemq.broker.region.ConnectionStatistics
 
connectionTimeout - Variable in class org.apache.activemq.transport.tcp.TcpTransport
 
connectionTimeout - Variable in class org.apache.activemq.transport.tcp.TcpTransportServer
 
ConnectionView - Class in org.apache.activemq.broker.jmx
 
ConnectionView(Connection) - Constructor for class org.apache.activemq.broker.jmx.ConnectionView
 
ConnectionViewMBean - Interface in org.apache.activemq.broker.jmx
 
Connector - Interface in org.apache.activemq.broker
A connector creates and manages client connections that talk to the Broker.
connector - Variable in class org.apache.activemq.broker.TransportConnection
 
CONNECTORS - Static variable in class org.apache.activemq.transport.peer.PeerTransportFactory
 
CONNECTORS - Static variable in class org.apache.activemq.transport.vm.VMTransportFactory
 
ConnectorStatistics - Class in org.apache.activemq.broker.region
The J2EE Statistics for the a Destination.
ConnectorStatistics() - Constructor for class org.apache.activemq.broker.region.ConnectorStatistics
 
ConnectorView - Class in org.apache.activemq.broker.jmx
 
ConnectorView(Connector) - Constructor for class org.apache.activemq.broker.jmx.ConnectorView
 
ConnectorViewMBean - Interface in org.apache.activemq.broker.jmx
 
connectTo(URI) - Method in interface org.apache.activemq.network.ConnectionFilter
 
consolidateDataFiles() - Method in class org.apache.activemq.kaha.impl.async.AsyncDataManager
 
consolidateDataFiles() - Method in class org.apache.activemq.kaha.impl.async.DataManagerFacade
 
consolidateDataFiles() - Method in class org.apache.activemq.kaha.impl.data.DataManagerImpl
 
consolidateDataFiles() - Method in interface org.apache.activemq.kaha.impl.DataManager
 
consolidateDataFilesNotIn(Set<Integer>, Set<Integer>) - Method in class org.apache.activemq.kaha.impl.async.AsyncDataManager
 
consolidateDataFilesNotIn(Set<Integer>, Integer) - Method in class org.apache.activemq.kaha.impl.async.AsyncDataManager
 
ConstantExpression - Class in org.apache.activemq.filter
Represents a constant expression
ConstantExpression(Object) - Constructor for class org.apache.activemq.filter.ConstantExpression
 
ConstantPendingMessageLimitStrategy - Class in org.apache.activemq.broker.region.policy
This PendingMessageLimitStrategy is configured to a constant value for all subscriptions.
ConstantPendingMessageLimitStrategy() - Constructor for class org.apache.activemq.broker.region.policy.ConstantPendingMessageLimitStrategy
 
consumer - Variable in class org.apache.activemq.command.MessageDispatch
 
consumer - Variable in class org.apache.activemq.network.jms.DestinationBridge
 
CONSUMER_ADVISORY_TOPIC_PREFIX - Static variable in class org.apache.activemq.advisory.AdvisorySupport
 
CONSUMER_CONTROL - Static variable in interface org.apache.activemq.command.CommandTypes
 
CONSUMER_ID - Static variable in interface org.apache.activemq.command.CommandTypes
 
CONSUMER_INFO - Static variable in interface org.apache.activemq.command.CommandTypes
 
ConsumerBrokerExchange - Class in org.apache.activemq.broker
Holds internal state in the broker for a essageConsumer
ConsumerBrokerExchange() - Constructor for class org.apache.activemq.broker.ConsumerBrokerExchange
 
consumerChangeMutexMap - Variable in class org.apache.activemq.broker.region.AbstractRegion
 
ConsumerControl - Class in org.apache.activemq.command
Used to start and stop transports as well as terminating clients.
ConsumerControl() - Constructor for class org.apache.activemq.command.ConsumerControl
 
ConsumerControlMarshaller - Class in org.apache.activemq.openwire.v1
Marshalling code for Open Wire Format for ConsumerControlMarshaller 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.
ConsumerControlMarshaller() - Constructor for class org.apache.activemq.openwire.v1.ConsumerControlMarshaller
 
ConsumerControlMarshaller - Class in org.apache.activemq.openwire.v2
Marshalling code for Open Wire Format for ConsumerControlMarshaller 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.
ConsumerControlMarshaller() - Constructor for class org.apache.activemq.openwire.v2.ConsumerControlMarshaller
 
ConsumerControlMarshaller - Class in org.apache.activemq.openwire.v3
Marshalling code for Open Wire Format for ConsumerControlMarshaller 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.
ConsumerControlMarshaller() - Constructor for class org.apache.activemq.openwire.v3.ConsumerControlMarshaller
 
ConsumerEvent - Class in org.apache.activemq.advisory
An event when the number of consumers on a given destination changes.
ConsumerEvent(ConsumerEventSource, Destination, ConsumerId, int) - Constructor for class org.apache.activemq.advisory.ConsumerEvent
 
ConsumerEventSource - Class in org.apache.activemq.advisory
An object which can be used to listen to the number of active consumers available on a given destination.
ConsumerEventSource(Connection, Destination) - Constructor for class org.apache.activemq.advisory.ConsumerEventSource
 
consumerId - Variable in class org.apache.activemq.command.ConsumerControl
 
ConsumerId - Class in org.apache.activemq.command
 
ConsumerId() - Constructor for class org.apache.activemq.command.ConsumerId
 
ConsumerId(SessionId, long) - Constructor for class org.apache.activemq.command.ConsumerId
 
ConsumerId(ConsumerId) - Constructor for class org.apache.activemq.command.ConsumerId
 
consumerId - Variable in class org.apache.activemq.command.ConsumerInfo
 
consumerId - Variable in class org.apache.activemq.command.MessageAck
 
consumerId - Variable in class org.apache.activemq.command.MessageDispatch
 
consumerId - Variable in class org.apache.activemq.command.MessageDispatchNotification
 
consumerId - Variable in class org.apache.activemq.command.MessagePull
 
consumerIdGenerator - Variable in class org.apache.activemq.ActiveMQSession
 
consumerIdGenerator - Variable in class org.apache.activemq.network.DemandForwardingBridgeSupport
 
ConsumerIdMarshaller - Class in org.apache.activemq.openwire.v1
Marshalling code for Open Wire Format for ConsumerIdMarshaller 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.
ConsumerIdMarshaller() - Constructor for class org.apache.activemq.openwire.v1.ConsumerIdMarshaller
 
ConsumerIdMarshaller - Class in org.apache.activemq.openwire.v2
Marshalling code for Open Wire Format for ConsumerIdMarshaller 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.
ConsumerIdMarshaller() - Constructor for class org.apache.activemq.openwire.v2.ConsumerIdMarshaller
 
ConsumerIdMarshaller - Class in org.apache.activemq.openwire.v3
Marshalling code for Open Wire Format for ConsumerIdMarshaller 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.
ConsumerIdMarshaller() - Constructor for class org.apache.activemq.openwire.v3.ConsumerIdMarshaller
 
ConsumerInfo - Class in org.apache.activemq.command
 
ConsumerInfo() - Constructor for class org.apache.activemq.command.ConsumerInfo
 
ConsumerInfo(ConsumerId) - Constructor for class org.apache.activemq.command.ConsumerInfo
 
ConsumerInfo(SessionInfo, long) - Constructor for class org.apache.activemq.command.ConsumerInfo
 
ConsumerInfoMarshaller - Class in org.apache.activemq.openwire.v1
Marshalling code for Open Wire Format for ConsumerInfoMarshaller 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.
ConsumerInfoMarshaller() - Constructor for class org.apache.activemq.openwire.v1.ConsumerInfoMarshaller
 
ConsumerInfoMarshaller - Class in org.apache.activemq.openwire.v2
Marshalling code for Open Wire Format for ConsumerInfoMarshaller 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.
ConsumerInfoMarshaller() - Constructor for class org.apache.activemq.openwire.v2.ConsumerInfoMarshaller
 
ConsumerInfoMarshaller - Class in org.apache.activemq.openwire.v3
Marshalling code for Open Wire Format for ConsumerInfoMarshaller 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.
ConsumerInfoMarshaller() - Constructor for class org.apache.activemq.openwire.v3.ConsumerInfoMarshaller
 
consumerKey - Variable in class org.apache.activemq.command.MessageAck
 
ConsumerListener - Interface in org.apache.activemq.advisory
Listen to the changes in the number of active consumers available for a given destination.
ConsumerMessageRef - Class in org.apache.activemq.store.kahadaptor
Holds information for location of message
ConsumerMessageRef() - Constructor for class org.apache.activemq.store.kahadaptor.ConsumerMessageRef
 
ConsumerMessageRefMarshaller - Class in org.apache.activemq.store.kahadaptor
Marshall a TopicSubAck
ConsumerMessageRefMarshaller() - Constructor for class org.apache.activemq.store.kahadaptor.ConsumerMessageRefMarshaller
 
consumers - Variable in class org.apache.activemq.ActiveMQSession
 
consumers - Variable in class org.apache.activemq.advisory.AdvisoryBroker
 
consumers - Variable in class org.apache.activemq.broker.region.ConnectorStatistics
 
consumers - Variable in class org.apache.activemq.broker.region.DestinationStatistics
 
consumers - Variable in class org.apache.activemq.broker.region.Queue
 
consumers - Variable in class org.apache.activemq.broker.region.Topic
 
ConsumerStartedEvent - Class in org.apache.activemq.advisory
An event when a new consumer has started.
ConsumerStartedEvent(ConsumerEventSource, ActiveMQDestination, ConsumerInfo, int) - Constructor for class org.apache.activemq.advisory.ConsumerStartedEvent
 
ConsumerState - Class in org.apache.activemq.state
 
ConsumerState(ConsumerInfo) - Constructor for class org.apache.activemq.state.ConsumerState
 
ConsumerStoppedEvent - Class in org.apache.activemq.advisory
An event generated when a consumer stops.
ConsumerStoppedEvent(ConsumerEventSource, ActiveMQDestination, ConsumerId, int) - Constructor for class org.apache.activemq.advisory.ConsumerStoppedEvent
 
consumerTransform(Session, MessageConsumer, Message) - Method in interface org.apache.activemq.MessageTransformer
Transforms the given message inside the consumer before being dispatched to the client code
container - Variable in class org.apache.activemq.kaha.impl.container.ContainerValueCollectionIterator
 
ContainerEntrySet - Class in org.apache.activemq.kaha.impl.container
Set of Map.Entry objects for a container
ContainerEntrySetIterator - Class in org.apache.activemq.kaha.impl.container
An Iterator for a container entry Set
ContainerId - Class in org.apache.activemq.kaha
Used by RootContainers
ContainerId() - Constructor for class org.apache.activemq.kaha.ContainerId
 
ContainerId(Object, String) - Constructor for class org.apache.activemq.kaha.ContainerId
 
containerId - Variable in class org.apache.activemq.kaha.impl.container.BaseContainerImpl
 
ContainerKeySet - Class in org.apache.activemq.kaha.impl.container
A Set of keys for the container
ContainerKeySetIterator - Class in org.apache.activemq.kaha.impl.container
Iterator for the set of keys for a container
ContainerListIterator - Class in org.apache.activemq.kaha.impl.container
 
ContainerListIterator(ListContainerImpl, IndexLinkedList, IndexItem) - Constructor for class org.apache.activemq.kaha.impl.container.ContainerListIterator
 
containerNameDataType - Variable in class org.apache.activemq.store.jdbc.Statements
 
containerShutdown() - Method in class org.apache.activemq.broker.BrokerService
Causes a clean shutdown of the container when the VM is being shut down
ContainerValueCollectionIterator - Class in org.apache.activemq.kaha.impl.container
Values collection iterator for the MapContainer
contains(String) - Method in class org.apache.activemq.broker.region.group.EmptyMessageGroupSet
 
contains(String) - Method in interface org.apache.activemq.broker.region.group.MessageGroupSet
 
contains(String) - Method in class org.apache.activemq.broker.region.group.SimpleMessageGroupSet
 
contains(BrokerId[], BrokerId) - Static method in class org.apache.activemq.command.NetworkBridgeFilter
 
contains(Object) - Method in class org.apache.activemq.kaha.impl.container.ContainerEntrySet
 
contains(Object) - Method in class org.apache.activemq.kaha.impl.container.ContainerKeySet
 
contains(Object) - Method in class org.apache.activemq.kaha.impl.container.ListContainerImpl
 
contains(BrokerId[], BrokerId) - Static method in class org.apache.activemq.network.DemandForwardingBridgeSupport
 
contains(Object) - Method in class org.apache.activemq.util.LRUSet
 
containsAll(Collection) - Method in class org.apache.activemq.kaha.impl.container.ContainerEntrySet
 
containsAll(Collection) - Method in class org.apache.activemq.kaha.impl.container.ContainerKeySet
 
containsAll(Collection) - Method in class org.apache.activemq.kaha.impl.container.ListContainerImpl
 
containsKey(Object) - Method in class org.apache.activemq.kaha.impl.container.MapContainerImpl
 
containsKey(Object) - Method in class org.apache.activemq.kaha.impl.index.hash.HashIndex
 
containsKey(Object) - Method in interface org.apache.activemq.kaha.impl.index.Index
 
containsKey(Object) - Method in class org.apache.activemq.kaha.impl.index.tree.TreeIndex
 
containsKey(Object) - Method in class org.apache.activemq.kaha.impl.index.VMIndex
 
containsKey(K) - Method in interface org.apache.activemq.kaha.MapContainer
 
containsValue(Object) - Method in class org.apache.activemq.kaha.impl.container.MapContainerImpl
 
containsValue(K) - Method in interface org.apache.activemq.kaha.MapContainer
 
content - Variable in class org.apache.activemq.command.Message
 
CONTENT_LENGTH - Static variable in interface org.apache.activemq.transport.stomp.Stomp.Headers
 
CONTENT_MAP - Static variable in interface org.apache.activemq.broker.jmx.CompositeDataConstants
 
context - Variable in class org.apache.activemq.broker.region.AbstractSubscription
 
CONTROL_COMMAND - Static variable in interface org.apache.activemq.command.CommandTypes
 
CONTROL_RECORD_MAX_LENGTH - Static variable in class org.apache.activemq.kaha.impl.async.AsyncDataManager
 
ControlCommand - Class in org.apache.activemq.command
Used to start and stop transports as well as terminating clients.
ControlCommand() - Constructor for class org.apache.activemq.command.ControlCommand
 
ControlCommandMarshaller - Class in org.apache.activemq.openwire.v1
Marshalling code for Open Wire Format for ControlCommandMarshaller 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.
ControlCommandMarshaller() - Constructor for class org.apache.activemq.openwire.v1.ControlCommandMarshaller
 
ControlCommandMarshaller - Class in org.apache.activemq.openwire.v2
Marshalling code for Open Wire Format for ControlCommandMarshaller 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.
ControlCommandMarshaller() - Constructor for class org.apache.activemq.openwire.v2.ControlCommandMarshaller
 
ControlCommandMarshaller - Class in org.apache.activemq.openwire.v3
Marshalling code for Open Wire Format for ControlCommandMarshaller 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.
ControlCommandMarshaller() - Constructor for class org.apache.activemq.openwire.v3.ControlCommandMarshaller
 
controlFile - Variable in class org.apache.activemq.kaha.impl.async.AsyncDataManager
 
ControlFile - Class in org.apache.activemq.kaha.impl.async
Use to reliably store fixed sized state data.
ControlFile(File, int) - Constructor for class org.apache.activemq.kaha.impl.async.ControlFile
 
convert(Message) - Static method in class org.apache.activemq.broker.jmx.OpenTypeSupport
 
convert(Message) - Method in interface org.apache.activemq.network.jms.JmsMesageConvertor
Convert a foreign JMS Message to a native ActiveMQ Message
convert(Message, Destination) - Method in interface org.apache.activemq.network.jms.JmsMesageConvertor
 
convert(Message) - Method in class org.apache.activemq.network.jms.SimpleJmsMessageConvertor
Convert a foreign JMS Message to a native ActiveMQ Message - Inbound or visa-versa outbound
convert(Message, Destination) - Method in class org.apache.activemq.network.jms.SimpleJmsMessageConvertor
 
convert(Object, Class) - Static method in class org.apache.activemq.util.TypeConversionSupport
 
convertDestination(ProtocolConverter, Destination) - Method in interface org.apache.activemq.transport.stomp.FrameTranslator
 
convertDestination(ProtocolConverter, String) - Method in interface org.apache.activemq.transport.stomp.FrameTranslator
 
convertDestination(ProtocolConverter, Destination) - Method in class org.apache.activemq.transport.stomp.LegacyFrameTranslator
 
convertDestination(ProtocolConverter, String) - Method in class org.apache.activemq.transport.stomp.LegacyFrameTranslator
 
convertFrame(ProtocolConverter, StompFrame) - Method in interface org.apache.activemq.transport.stomp.FrameTranslator
 
convertFrame(ProtocolConverter, StompFrame) - Method in class org.apache.activemq.transport.stomp.JmsFrameTranslator
 
convertFrame(ProtocolConverter, StompFrame) - Method in class org.apache.activemq.transport.stomp.LegacyFrameTranslator
 
convertMessage(ProtocolConverter, ActiveMQMessage) - Method in interface org.apache.activemq.transport.stomp.FrameTranslator
 
convertMessage(ProtocolConverter, ActiveMQMessage) - Method in class org.apache.activemq.transport.stomp.JmsFrameTranslator
 
convertMessage(ProtocolConverter, ActiveMQMessage) - Method in class org.apache.activemq.transport.stomp.LegacyFrameTranslator
 
convertMessage(StompFrame) - Method in class org.apache.activemq.transport.stomp.ProtocolConverter
 
convertMessage(ActiveMQMessage, boolean) - Method in class org.apache.activemq.transport.stomp.ProtocolConverter
 
copy() - Method in class org.apache.activemq.ActiveMQConnectionFactory
Returns a copy of the given connection factory
copy() - Method in class org.apache.activemq.blob.BlobTransferPolicy
Returns a copy of this policy object
copy() - Method in class org.apache.activemq.broker.region.policy.FixedCountSubscriptionRecoveryPolicy
 
copy() - Method in class org.apache.activemq.broker.region.policy.FixedSizedSubscriptionRecoveryPolicy
 
copy() - Method in class org.apache.activemq.broker.region.policy.LastImageSubscriptionRecoveryPolicy
 
copy() - Method in class org.apache.activemq.broker.region.policy.NoSubscriptionRecoveryPolicy
 
copy() - Method in class org.apache.activemq.broker.region.policy.QueryBasedSubscriptionRecoveryPolicy
 
copy() - Method in interface org.apache.activemq.broker.region.policy.SubscriptionRecoveryPolicy
Used to copy the policy object.
copy() - Method in class org.apache.activemq.broker.region.policy.TimedSubscriptionRecoveryPolicy
 
copy() - Method in class org.apache.activemq.command.ActiveMQBlobMessage
 
copy() - Method in class org.apache.activemq.command.ActiveMQBytesMessage
 
copy() - Method in class org.apache.activemq.command.ActiveMQMapMessage
 
copy() - Method in class org.apache.activemq.command.ActiveMQMessage
 
copy(ActiveMQMessage) - Method in class org.apache.activemq.command.ActiveMQMessage
 
copy() - Method in class org.apache.activemq.command.ActiveMQObjectMessage
 
copy() - Method in class org.apache.activemq.command.ActiveMQStreamMessage
 
copy() - Method in class org.apache.activemq.command.ActiveMQTextMessage
 
copy(BaseCommand) - Method in class org.apache.activemq.command.BaseCommand
 
copy(ConnectionInfo) - Method in class org.apache.activemq.command.ConnectionInfo
 
copy() - Method in class org.apache.activemq.command.ConsumerInfo
 
copy(ConsumerInfo) - Method in class org.apache.activemq.command.ConsumerInfo
 
copy() - Method in class org.apache.activemq.command.Message
 
copy(Message) - Method in class org.apache.activemq.command.Message
 
copy(MessageAck) - Method in class org.apache.activemq.command.MessageAck
 
copy() - Method in class org.apache.activemq.command.MessageId
 
copy(ProducerAck) - Method in class org.apache.activemq.command.ProducerAck
 
copy() - Method in class org.apache.activemq.command.ProducerInfo
 
copy(ProducerInfo) - Method in class org.apache.activemq.command.ProducerInfo
 
copy() - Method in class org.apache.activemq.kaha.impl.data.DataItem
 
copy() - Method in class org.apache.activemq.openwire.OpenWireFormat
 
copy() - Method in class org.apache.activemq.RedeliveryPolicy
 
copyFile(File, File) - Static method in class org.apache.activemq.util.IOHelper
 
copyInputStream(InputStream, OutputStream) - Static method in class org.apache.activemq.util.IOHelper
 
copyMatchingMessages(ConnectionContext, MessageReferenceFilter, ActiveMQDestination, int) - Method in class org.apache.activemq.broker.region.Queue
Copies the messages matching the given filter up to the maximum number of matched messages
copyMatchingMessagesTo(String, String) - Method in class org.apache.activemq.broker.jmx.QueueView
 
copyMatchingMessagesTo(String, String, int) - Method in class org.apache.activemq.broker.jmx.QueueView
 
copyMatchingMessagesTo(String, String) - Method in interface org.apache.activemq.broker.jmx.QueueViewMBean
Copies the messages matching the given selector
copyMatchingMessagesTo(String, String, int) - Method in interface org.apache.activemq.broker.jmx.QueueViewMBean
Copies the messages matching the given selector up to the maximum number of matched messages
copyMatchingMessagesTo(ConnectionContext, String, ActiveMQDestination) - Method in class org.apache.activemq.broker.region.Queue
Copies the messages matching the given selector
copyMatchingMessagesTo(ConnectionContext, String, ActiveMQDestination, int) - Method in class org.apache.activemq.broker.region.Queue
Copies the messages matching the given selector up to the maximum number of matched messages
copyMessageTo(String, String) - Method in class org.apache.activemq.broker.jmx.QueueView
 
copyMessageTo(String, String) - Method in interface org.apache.activemq.broker.jmx.QueueViewMBean
Copies a given message to another destination.
copyMessageTo(ConnectionContext, String, ActiveMQDestination) - Method in class org.apache.activemq.broker.region.Queue
Copies the message matching the given messageId
copyProperties(Message, Message) - Static method in class org.apache.activemq.ActiveMQMessageTransformation
Copies the standard JMS and user defined properties from the givem message to the specified message
copyProperties(Message, Message) - Method in class org.apache.activemq.MessageTransformerSupport
Copies the standard JMS and user defined properties from the givem message to the specified message
copyStandardHeadersFromFrameToMessage(ProtocolConverter, StompFrame, ActiveMQMessage, FrameTranslator) - Static method in class org.apache.activemq.transport.stomp.FrameTranslator.Helper
 
copyStandardHeadersFromMessageToFrame(ProtocolConverter, ActiveMQMessage, StompFrame, FrameTranslator) - Static method in class org.apache.activemq.transport.stomp.FrameTranslator.Helper
 
CORRELATION_ID - Static variable in interface org.apache.activemq.transport.stomp.Stomp.Headers.Message
 
CORRELATION_ID - Static variable in interface org.apache.activemq.transport.stomp.Stomp.Headers.Send
 
correlationId - Variable in class org.apache.activemq.command.Message
 
count - Variable in class org.apache.activemq.ActiveMQOutputStream
 
count - Variable in class org.apache.activemq.transport.nio.NIOInputStream
 
count - Variable in class org.apache.activemq.transport.tcp.TcpBufferedInputStream
 
countBeforeFull() - Method in class org.apache.activemq.broker.region.AbstractSubscription
 
countBeforeFull() - Method in class org.apache.activemq.broker.region.PrefetchSubscription
 
countBeforeFull() - Method in interface org.apache.activemq.broker.region.Subscription
 
CountStatisticImpl - Class in org.apache.activemq.management
A count statistic implementation
CountStatisticImpl(CountStatisticImpl, String, String) - Constructor for class org.apache.activemq.management.CountStatisticImpl
 
CountStatisticImpl(String, String) - Constructor for class org.apache.activemq.management.CountStatisticImpl
 
CountStatisticImpl(String, String, String) - Constructor for class org.apache.activemq.management.CountStatisticImpl
 
create(String, Throwable) - Static method in class org.apache.activemq.util.IOExceptionSupport
 
create(String, Exception) - Static method in class org.apache.activemq.util.IOExceptionSupport
 
create(Throwable) - Static method in class org.apache.activemq.util.IOExceptionSupport
 
create(Exception) - Static method in class org.apache.activemq.util.IOExceptionSupport
 
create(String, Throwable) - Static method in class org.apache.activemq.util.JMSExceptionSupport
 
create(String, Exception) - Static method in class org.apache.activemq.util.JMSExceptionSupport
 
create(Throwable) - Static method in class org.apache.activemq.util.JMSExceptionSupport
 
create(Exception) - Static method in class org.apache.activemq.util.JMSExceptionSupport
 
createActiveMQConnection() - Method in class org.apache.activemq.ActiveMQConnectionFactory
 
createActiveMQConnection(String, String) - Method in class org.apache.activemq.ActiveMQConnectionFactory
 
createActiveMQConnection(Transport, JMSStatsImpl) - Method in class org.apache.activemq.ActiveMQConnectionFactory
 
createActiveMQConnection(Transport, JMSStatsImpl) - Method in class org.apache.activemq.ActiveMQXAConnectionFactory
 
createActiveMQQueue(QueueSession, String) - Method in class org.apache.activemq.network.jms.JmsQueueConnector
 
createActiveMQTopic(TopicSession, String) - Method in class org.apache.activemq.network.jms.JmsTopicConnector
 
createAdapter() - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
 
createAddress(URI) - Method in class org.apache.activemq.transport.multicast.MulticastTransport
 
createAddress(URI) - Method in class org.apache.activemq.transport.udp.UdpTransport
Creates an address from the given URI
createAdminConnectionContext() - Method in class org.apache.activemq.broker.BrokerService
Factory method to create the new administration connection context object.
createAdminConnectionContext(Broker) - Static method in class org.apache.activemq.broker.jmx.BrokerView
Factory method to create the new administration connection context object.
createAND(BooleanExpression, BooleanExpression) - Static method in class org.apache.activemq.filter.LogicExpression
 
createApplicationContext(String) - Method in class org.apache.activemq.xbean.XBeanBrokerFactory
 
createAsyncDataManager() - Method in class org.apache.activemq.store.amq.AMQPersistenceAdapter
 
createBetween(Expression, Expression, Expression) - Static method in class org.apache.activemq.filter.ComparisonExpression
 
createBlobMessage(URL) - Method in class org.apache.activemq.ActiveMQSession
Creates an initialized BlobMessage object.
createBlobMessage(URL, boolean) - Method in class org.apache.activemq.ActiveMQSession
Creates an initialized BlobMessage object.
createBlobMessage(File) - Method in class org.apache.activemq.ActiveMQSession
Creates an initialized BlobMessage object.
createBlobMessage(InputStream) - Method in class org.apache.activemq.ActiveMQSession
Creates an initialized BlobMessage object.
createBlobTransferPolicy() - Method in class org.apache.activemq.ActiveMQConnection
 
createBooleanCast(Expression) - Static method in class org.apache.activemq.filter.UnaryExpression
 
createBridge(Transport, Transport, DiscoveryEvent) - Method in class org.apache.activemq.network.DiscoveryNetworkConnector
 
createBridge(Transport, Transport) - Method in class org.apache.activemq.network.MulticastNetworkConnector
 
createBridge(NetworkBridgeConfiguration, Transport, Transport) - Static method in class org.apache.activemq.network.NetworkBridgeFactory
Create a network bridge
createBridge(NetworkBridgeConfiguration, Transport, Transport, NetworkBridgeListener) - Static method in class org.apache.activemq.network.NetworkBridgeFactory
create a network bridge
createBroker(URI) - Static method in class org.apache.activemq.broker.BrokerFactory
Creates a broker from a URI configuration
createBroker(URI, boolean) - Static method in class org.apache.activemq.broker.BrokerFactory
Creates a broker from a URI configuration
createBroker(String) - Static method in class org.apache.activemq.broker.BrokerFactory
Creates a broker from a URI configuration
createBroker(String, boolean) - Static method in class org.apache.activemq.broker.BrokerFactory
Creates a broker from a URI configuration
createBroker(URI) - Method in interface org.apache.activemq.broker.BrokerFactoryHandler
 
createBroker() - Method in class org.apache.activemq.broker.BrokerService
Factory method to create a new broker
createBroker(URI) - Method in class org.apache.activemq.broker.DefaultBrokerFactory
 
createBroker(URI) - Method in class org.apache.activemq.broker.PropertiesBrokerFactory
 
createBroker(URI) - Method in class org.apache.activemq.xbean.XBeanBrokerFactory
 
createBrokerFactoryHandler(String) - Static method in class org.apache.activemq.broker.BrokerFactory
 
createBrokerObjectName() - Method in class org.apache.activemq.broker.BrokerService
 
createBrokerService(URI, Map) - Method in class org.apache.activemq.broker.PropertiesBrokerFactory
 
createBrowser(Queue) - Method in class org.apache.activemq.ActiveMQQueueSession
 
createBrowser(Queue, String) - Method in class org.apache.activemq.ActiveMQQueueSession
 
createBrowser(Queue) - Method in class org.apache.activemq.ActiveMQSession
Creates a QueueBrowser object to peek at the messages on the specified queue.
createBrowser(Queue, String) - Method in class org.apache.activemq.ActiveMQSession
Creates a QueueBrowser object to peek at the messages on the specified queue using a message selector.
createBrowser(Queue) - Method in class org.apache.activemq.ActiveMQTopicSession
 
createBrowser(Queue, String) - Method in class org.apache.activemq.ActiveMQTopicSession
 
createBuffer() - Method in class org.apache.activemq.transport.udp.SimpleBufferPool
 
createByAddressObjectName(String, String) - Method in class org.apache.activemq.broker.jmx.ManagedTransportConnection
 
createByClientIdObjectName(String) - Method in class org.apache.activemq.broker.jmx.ManagedTransportConnection
 
createByteArrayOutputStream() - Method in class org.apache.activemq.transport.udp.CommandDatagramSocket
 
createBytesMessage() - Method in class org.apache.activemq.ActiveMQQueueSession
 
createBytesMessage() - Method in class org.apache.activemq.ActiveMQSession
Creates a BytesMessage object.
createBytesMessage() - Method in class org.apache.activemq.ActiveMQTopicSession
 
createChildNode() - Method in class org.apache.activemq.filter.DestinationMapNode
Factory method to create a child node
createCommandChannel() - Method in class org.apache.activemq.transport.multicast.MulticastTransport
 
createCommandChannel() - Method in class org.apache.activemq.transport.udp.UdpTransport
 
createCommandDatagramChannel() - Method in class org.apache.activemq.transport.udp.UdpTransport
 
createCommandDestination() - Method in class org.apache.activemq.broker.util.CommandAgent
 
createCompositeDestination(Destination, List<Destination>) - Method in class org.apache.activemq.broker.region.virtual.VirtualDestinationInterceptor
 
createConnection() - Method in class org.apache.activemq.ActiveMQConnectionFactory
 
createConnection(String, String) - Method in class org.apache.activemq.ActiveMQConnectionFactory
 
createConnection(Transport) - Method in class org.apache.activemq.broker.jmx.ManagedTransportConnector
 
createConnection(Transport) - Method in class org.apache.activemq.broker.TransportConnector
 
createConnection() - Method in class org.apache.activemq.broker.util.CommandAgent
 
createConnectionConsumer(Topic, String, ServerSessionPool, int) - Method in class org.apache.activemq.ActiveMQConnection
Creates a connection consumer for this connection (optional operation).
createConnectionConsumer(Queue, String, ServerSessionPool, int) - Method in class org.apache.activemq.ActiveMQConnection
Creates a connection consumer for this connection (optional operation).
createConnectionConsumer(Destination, String, ServerSessionPool, int) - Method in class org.apache.activemq.ActiveMQConnection
Creates a connection consumer for this connection (optional operation).
createConnectionConsumer(Destination, String, ServerSessionPool, int, boolean) - Method in class org.apache.activemq.ActiveMQConnection
 
createConnectionContext() - Method in class org.apache.activemq.broker.region.Queue
 
createConnectionFactory(String, Hashtable) - Method in class org.apache.activemq.jndi.ActiveMQInitialContextFactory
 
createConnectionFactory(Hashtable) - Method in class org.apache.activemq.jndi.ActiveMQInitialContextFactory
Factory method to create a new connection factory from the given environment
createConsumer(Destination) - Method in class org.apache.activemq.ActiveMQQueueSession
 
createConsumer(Destination, String) - Method in class org.apache.activemq.ActiveMQQueueSession
 
createConsumer(Destination, String, boolean) - Method in class org.apache.activemq.ActiveMQQueueSession
 
createConsumer(Destination) - Method in class org.apache.activemq.ActiveMQSession
Creates a MessageConsumer for the specified destination.
createConsumer(Destination, String) - Method in class org.apache.activemq.ActiveMQSession
Creates a MessageConsumer for the specified destination, using a message selector.
createConsumer(Destination, MessageListener) - Method in class org.apache.activemq.ActiveMQSession
Creates a MessageConsumer for the specified destination.
createConsumer(Destination, String, MessageListener) - Method in class org.apache.activemq.ActiveMQSession
Creates a MessageConsumer for the specified destination, using a message selector.
createConsumer(Destination, String, boolean) - Method in class org.apache.activemq.ActiveMQSession
Creates MessageConsumer for the specified destination, using a message selector.
createConsumer(Destination, String, boolean, MessageListener) - Method in class org.apache.activemq.ActiveMQSession
Creates MessageConsumer for the specified destination, using a message selector.
createConsumer(Destination) - Method in class org.apache.activemq.ActiveMQTopicSession
 
createConsumer(Destination, String) - Method in class org.apache.activemq.ActiveMQTopicSession
 
createConsumer(Destination, String, boolean) - Method in class org.apache.activemq.ActiveMQTopicSession
 
createConsumer(ActiveMQSession, String) - Method in interface org.apache.activemq.CustomDestination
 
createConsumer(ActiveMQSession, String, boolean) - Method in interface org.apache.activemq.CustomDestination
 
createConsumer() - Method in class org.apache.activemq.network.jms.DestinationBridge
 
createContext(Hashtable, Map<String, Object>) - Method in class org.apache.activemq.jndi.ActiveMQInitialContextFactory
 
createCustomComponentMBeanName(String, String) - Method in class org.apache.activemq.broker.jmx.ManagementContext
Formulate and return the MBean ObjectName of a custom control MBean
createDatabaseLocker() - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
 
createDatagramHeaderMarshaller() - Method in class org.apache.activemq.transport.multicast.MulticastTransport
 
createDatagramHeaderMarshaller() - Method in class org.apache.activemq.transport.udp.UdpTransport
 
createDatagramPacket() - Method in class org.apache.activemq.transport.udp.CommandDatagramSocket
 
createDataSource() - Method in class org.apache.activemq.store.jdbc.DataSourceSupport
 
createDefaultDestinationInterceptor() - Method in class org.apache.activemq.broker.BrokerService
Create the default destination interceptor
createDefaultExecutor() - Method in class org.apache.activemq.thread.TaskRunnerFactory
 
createDemandSubscription(ConsumerInfo) - Method in class org.apache.activemq.network.ConduitBridge
 
createDemandSubscription(ConsumerInfo) - Method in class org.apache.activemq.network.DemandForwardingBridgeSupport
 
createDemandSubscription(ActiveMQDestination) - Method in class org.apache.activemq.network.DemandForwardingBridgeSupport
 
createDemandSubscription(ConsumerInfo) - Method in class org.apache.activemq.network.DurableConduitBridge
 
createDestination(ConnectionContext, ActiveMQDestination) - Method in class org.apache.activemq.broker.jmx.ManagedQueueRegion
 
createDestination(ConnectionContext, ActiveMQDestination) - Method in class org.apache.activemq.broker.jmx.ManagedTempQueueRegion
 
createDestination(ConnectionContext, ActiveMQDestination) - Method in class org.apache.activemq.broker.jmx.ManagedTempTopicRegion
 
createDestination(ConnectionContext, ActiveMQDestination) - Method in class org.apache.activemq.broker.jmx.ManagedTopicRegion
 
createDestination(ConnectionContext, ActiveMQDestination) - Method in class org.apache.activemq.broker.region.AbstractRegion
 
createDestination(ConnectionContext, ActiveMQDestination) - Method in class org.apache.activemq.broker.region.AbstractTempRegion
 
createDestination(ConnectionContext, ActiveMQDestination, DestinationStatistics) - Method in class org.apache.activemq.broker.region.DestinationFactory
Create destination implementation.
createDestination(ConnectionContext, ActiveMQDestination, DestinationStatistics) - Method in class org.apache.activemq.broker.region.DestinationFactoryImpl
 
createDestination(ActiveMQDestination, String, boolean) - Method in class org.apache.activemq.broker.region.policy.IndividualDeadLetterStrategy
 
createDestination(String, byte) - Static method in class org.apache.activemq.command.ActiveMQDestination
 
createDestination(String) - Method in class org.apache.activemq.command.ActiveMQDestination
 
createDiscoveryAgent() - Method in class org.apache.activemq.broker.TransportConnector
 
createDiscoveryAgent(URI) - Static method in class org.apache.activemq.transport.discovery.DiscoveryAgentFactory
 
createDivide(Expression, Expression) - Static method in class org.apache.activemq.filter.ArithmeticExpression
 
createDurableConnectionConsumer(Topic, String, String, ServerSessionPool, int) - Method in class org.apache.activemq.ActiveMQConnection
Create a durable connection consumer for this connection (optional operation).
createDurableConnectionConsumer(Topic, String, String, ServerSessionPool, int, boolean) - Method in class org.apache.activemq.ActiveMQConnection
Create a durable connection consumer for this connection (optional operation).
createDurableInputStream(Topic, String) - Method in class org.apache.activemq.ActiveMQConnection
 
createDurableInputStream(Topic, String, String) - Method in class org.apache.activemq.ActiveMQConnection
 
createDurableInputStream(Topic, String, String, boolean) - Method in class org.apache.activemq.ActiveMQConnection
 
createDurableInputStream(Topic, String) - Method in interface org.apache.activemq.StreamConnection
 
createDurableInputStream(Topic, String, String) - Method in interface org.apache.activemq.StreamConnection
 
createDurableInputStream(Topic, String, String, boolean) - Method in interface org.apache.activemq.StreamConnection
 
createDurableSubscriber(Topic, String) - Method in class org.apache.activemq.ActiveMQQueueSession
 
createDurableSubscriber(Topic, String, String, boolean) - Method in class org.apache.activemq.ActiveMQQueueSession
 
createDurableSubscriber(Topic, String) - Method in class org.apache.activemq.ActiveMQSession
Creates a durable subscriber to the specified topic.
createDurableSubscriber(Topic, String, String, boolean) - Method in class org.apache.activemq.ActiveMQSession
Creates a durable subscriber to the specified topic, using a message selector and specifying whether messages published by its own connection should be delivered to it.
createDurableSubscriber(Topic, String) - Method in class org.apache.activemq.ActiveMQTopicSession
 
createDurableSubscriber(Topic, String, String, boolean) - Method in class org.apache.activemq.ActiveMQTopicSession
 
createDurableSubscriber(String, String, String, String) - Method in class org.apache.activemq.broker.jmx.BrokerView
 
createDurableSubscriber(String, String, String, String) - Method in interface org.apache.activemq.broker.jmx.BrokerViewMBean
Creates a new durable topic subscriber
createDurableSubscriber(ActiveMQSession, String, String, boolean) - Method in interface org.apache.activemq.CustomDestination
 
createEndpoint(ByteBuffer, SocketAddress) - Method in class org.apache.activemq.transport.multicast.MulticastDatagramHeaderMarshaller
 
createEndpoint(ByteBuffer, SocketAddress) - Method in class org.apache.activemq.transport.udp.DatagramHeaderMarshaller
Reads any header if applicable and then creates an endpoint object
createEndpoint(DatagramPacket, DataInputStream) - Method in class org.apache.activemq.transport.udp.DatagramHeaderMarshaller
 
createEndpoint(SocketAddress) - Method in class org.apache.activemq.transport.udp.DatagramHeaderMarshaller
 
createEntry(String) - Method in class org.apache.activemq.jndi.LazyCreateContext
 
createEqual(Expression, Expression) - Static method in class org.apache.activemq.filter.ComparisonExpression
 
createFIFOCacheEvictor() - Method in class org.apache.activemq.memory.CacheEntryList
 
createFloat(String) - Static method in class org.apache.activemq.filter.ConstantExpression
 
createForeignQueue(QueueSession, String) - Method in class org.apache.activemq.network.jms.JmsQueueConnector
 
createForeignTopic(TopicSession, String) - Method in class org.apache.activemq.network.jms.JmsTopicConnector
 
createFromDecimal(String) - Static method in class org.apache.activemq.filter.ConstantExpression
 
createFromHex(String) - Static method in class org.apache.activemq.filter.ConstantExpression
 
createFromOctal(String) - Static method in class org.apache.activemq.filter.ConstantExpression
 
createGreaterThan(Expression, Expression) - Static method in class org.apache.activemq.filter.ComparisonExpression
 
createGreaterThanEqual(Expression, Expression) - Static method in class org.apache.activemq.filter.ComparisonExpression
 
createInExpression(PropertyExpression, List<Object>, boolean) - Static method in class org.apache.activemq.filter.UnaryExpression
 
createInFilter(Expression, List) - Static method in class org.apache.activemq.filter.ComparisonExpression
 
createInputStream(Destination) - Method in class org.apache.activemq.ActiveMQConnection
 
createInputStream(Destination, String) - Method in class org.apache.activemq.ActiveMQConnection
 
createInputStream(Destination, String, boolean) - Method in class org.apache.activemq.ActiveMQConnection
 
createInputStream(Destination) - Method in interface org.apache.activemq.StreamConnection
 
createInputStream(Destination, String) - Method in interface org.apache.activemq.StreamConnection
 
createInputStream(Destination, String, boolean) - Method in interface org.apache.activemq.StreamConnection
 
createIsNotNull(Expression) - Static method in class org.apache.activemq.filter.ComparisonExpression
 
createIsNull(Expression) - Static method in class org.apache.activemq.filter.ComparisonExpression
 
createJmDNS() - Method in class org.apache.activemq.transport.discovery.rendezvous.RendezvousDiscoveryAgent
 
createJournal() - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapterFactory
 
createLessThan(Expression, Expression) - Static method in class org.apache.activemq.filter.ComparisonExpression
 
createLessThanEqual(Expression, Expression) - Static method in class org.apache.activemq.filter.ComparisonExpression
 
createLIFOCacheEvictor() - Method in class org.apache.activemq.memory.CacheEntryList
 
createLike(Expression, String, String) - Static method in class org.apache.activemq.filter.ComparisonExpression
 
createLocalAddress() - Method in class org.apache.activemq.transport.discovery.rendezvous.RendezvousDiscoveryAgent
 
createLocalAddress() - Method in class org.apache.activemq.transport.udp.UdpTransport
 
createLocalTransport() - Method in class org.apache.activemq.network.NetworkConnector
 
createMap(int) - Method in class org.apache.activemq.transport.reliable.DefaultReplayBuffer
 
createMapMessage() - Method in class org.apache.activemq.ActiveMQQueueSession
 
createMapMessage() - Method in class org.apache.activemq.ActiveMQSession
Creates a MapMessage object.
createMapMessage() - Method in class org.apache.activemq.ActiveMQTopicSession
 
createMapMessage(HierarchicalStreamReader) - Method in class org.apache.activemq.transport.stomp.JmsFrameTranslator
 
createMarshallerMap(OpenWireFormat) - Static method in class org.apache.activemq.openwire.v1.MarshallerFactory
 
createMarshallerMap(OpenWireFormat) - Static method in class org.apache.activemq.openwire.v2.MarshallerFactory
 
createMarshallerMap(OpenWireFormat) - Static method in class org.apache.activemq.openwire.v3.MarshallerFactory
 
createMBeanServer() - Method in class org.apache.activemq.broker.jmx.ManagementContext
 
createMessage() - Method in class org.apache.activemq.ActiveMQQueueSession
 
createMessage() - Method in class org.apache.activemq.ActiveMQSession
Creates a Message object.
createMessage() - Method in class org.apache.activemq.ActiveMQTopicSession
 
createMessageDispatch(MessageReference, Message) - Method in class org.apache.activemq.broker.region.DurableTopicSubscription
 
createMessageDispatch(MessageReference, Message) - Method in class org.apache.activemq.broker.region.PrefetchSubscription
 
createMessageEOFException(Exception) - Static method in class org.apache.activemq.util.JMSExceptionSupport
 
createMessageFormatException(Exception) - Static method in class org.apache.activemq.util.JMSExceptionSupport
 
createMessageGroupMap() - Method in class org.apache.activemq.broker.region.group.MessageGroupHashBucketFactory
 
createMessageGroupMap() - Method in interface org.apache.activemq.broker.region.group.MessageGroupMapFactory
 
createMessageGroupMap() - Method in class org.apache.activemq.broker.region.group.SimpleMessageGroupMapFactory
 
createMessageGroupSet(int, MessageGroupSet) - Method in class org.apache.activemq.broker.region.group.MessageGroupHashBucket
 
createMessageGroupSet(int) - Method in class org.apache.activemq.broker.region.group.MessageGroupHashBucket
 
createMessageIdFilter(String) - Method in class org.apache.activemq.broker.region.Queue
 
createMessageList() - Method in class org.apache.activemq.broker.region.policy.FixedSizedSubscriptionRecoveryPolicy
 
createMessageMarshaller() - Method in class org.apache.activemq.store.kahadaptor.KahaPersistenceAdapter
 
createMessageQueue() - Method in interface org.apache.activemq.memory.buffer.MessageBuffer
Creates a new message queue instance
createMessageQueue() - Method in class org.apache.activemq.memory.buffer.OrderBasedMessageBuffer
Creates a new message queue instance
createMessageQueue() - Method in class org.apache.activemq.memory.buffer.SizeBasedMessageBuffer
Creates a new message queue instance
createMinus(Expression, Expression) - Static method in class org.apache.activemq.filter.ArithmeticExpression
 
createMod(Expression, Expression) - Static method in class org.apache.activemq.filter.ArithmeticExpression
 
createMultiply(Expression, Expression) - Static method in class org.apache.activemq.filter.ArithmeticExpression
 
createNegate(Expression) - Static method in class org.apache.activemq.filter.UnaryExpression
 
createNetworkBridgeFilter(ConsumerInfo) - Method in class org.apache.activemq.network.CompositeDemandForwardingBridge
 
createNetworkBridgeFilter(ConsumerInfo) - Method in class org.apache.activemq.network.DemandForwardingBridge
 
createNetworkBridgeFilter(ConsumerInfo) - Method in class org.apache.activemq.network.DemandForwardingBridgeSupport
 
createNetworkBridgeObjectName(NetworkBridge) - Method in class org.apache.activemq.network.NetworkConnector
 
createNetworkConnectorObjectName(NetworkConnector) - Method in class org.apache.activemq.broker.BrokerService
 
createNewIndex() - Method in class org.apache.activemq.kaha.impl.index.IndexManager
 
createNonPersistentOutputStream(Destination) - Method in class org.apache.activemq.ActiveMQConnection
Creates a non persistent output stream; messages will not be written to disk
createNOT(BooleanExpression) - Static method in class org.apache.activemq.filter.UnaryExpression
 
createNotBetween(Expression, Expression, Expression) - Static method in class org.apache.activemq.filter.ComparisonExpression
 
createNotEqual(Expression, Expression) - Static method in class org.apache.activemq.filter.ComparisonExpression
 
createNotInFilter(Expression, List) - Static method in class org.apache.activemq.filter.ComparisonExpression
 
createNotLike(Expression, String, String) - Static method in class org.apache.activemq.filter.ComparisonExpression
 
createObject() - Method in interface org.apache.activemq.openwire.DataStreamMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.ActiveMQBytesMessageMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.ActiveMQMapMessageMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.ActiveMQMessageMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.ActiveMQObjectMessageMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.ActiveMQQueueMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.ActiveMQStreamMessageMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.ActiveMQTempQueueMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.ActiveMQTempTopicMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.ActiveMQTextMessageMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.ActiveMQTopicMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.BaseDataStreamMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.BrokerIdMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.BrokerInfoMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.ConnectionControlMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.ConnectionErrorMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.ConnectionIdMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.ConnectionInfoMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.ConsumerControlMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.ConsumerIdMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.ConsumerInfoMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.ControlCommandMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.DataArrayResponseMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.DataResponseMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.DestinationInfoMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.DiscoveryEventMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.ExceptionResponseMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.FlushCommandMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.IntegerResponseMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.JournalQueueAckMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.JournalTopicAckMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.JournalTraceMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.JournalTransactionMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.KeepAliveInfoMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.LastPartialCommandMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.LocalTransactionIdMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.MessageAckMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.MessageDispatchMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.MessageDispatchNotificationMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.MessageIdMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.NetworkBridgeFilterMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.PartialCommandMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.ProducerIdMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.ProducerInfoMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.RemoveInfoMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.RemoveSubscriptionInfoMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.ReplayCommandMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.ResponseMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.SessionIdMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.SessionInfoMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.ShutdownInfoMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.SubscriptionInfoMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.TransactionInfoMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.WireFormatInfoMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v1.XATransactionIdMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.ActiveMQBytesMessageMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.ActiveMQMapMessageMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.ActiveMQMessageMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.ActiveMQObjectMessageMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.ActiveMQQueueMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.ActiveMQStreamMessageMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.ActiveMQTempQueueMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.ActiveMQTempTopicMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.ActiveMQTextMessageMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.ActiveMQTopicMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.BaseDataStreamMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.BrokerIdMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.BrokerInfoMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.ConnectionControlMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.ConnectionErrorMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.ConnectionIdMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.ConnectionInfoMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.ConsumerControlMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.ConsumerIdMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.ConsumerInfoMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.ControlCommandMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.DataArrayResponseMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.DataResponseMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.DestinationInfoMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.DiscoveryEventMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.ExceptionResponseMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.FlushCommandMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.IntegerResponseMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.JournalQueueAckMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.JournalTopicAckMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.JournalTraceMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.JournalTransactionMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.KeepAliveInfoMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.LastPartialCommandMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.LocalTransactionIdMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.MessageAckMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.MessageDispatchMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.MessageDispatchNotificationMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.MessageIdMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.MessagePullMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.NetworkBridgeFilterMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.PartialCommandMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.ProducerIdMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.ProducerInfoMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.RemoveInfoMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.RemoveSubscriptionInfoMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.ReplayCommandMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.ResponseMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.SessionIdMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.SessionInfoMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.ShutdownInfoMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.SubscriptionInfoMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.TransactionInfoMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.WireFormatInfoMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v2.XATransactionIdMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.ActiveMQBlobMessageMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.ActiveMQBytesMessageMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.ActiveMQMapMessageMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.ActiveMQMessageMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.ActiveMQObjectMessageMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.ActiveMQQueueMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.ActiveMQStreamMessageMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.ActiveMQTempQueueMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.ActiveMQTempTopicMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.ActiveMQTextMessageMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.ActiveMQTopicMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.BaseDataStreamMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.BrokerIdMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.BrokerInfoMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.ConnectionControlMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.ConnectionErrorMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.ConnectionIdMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.ConnectionInfoMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.ConsumerControlMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.ConsumerIdMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.ConsumerInfoMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.ControlCommandMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.DataArrayResponseMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.DataResponseMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.DestinationInfoMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.DiscoveryEventMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.ExceptionResponseMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.FlushCommandMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.IntegerResponseMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.JournalQueueAckMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.JournalTopicAckMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.JournalTraceMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.JournalTransactionMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.KeepAliveInfoMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.LastPartialCommandMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.LocalTransactionIdMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.MessageAckMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.MessageDispatchMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.MessageDispatchNotificationMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.MessageIdMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.MessagePullMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.NetworkBridgeFilterMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.PartialCommandMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.ProducerAckMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.ProducerIdMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.ProducerInfoMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.RemoveInfoMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.RemoveSubscriptionInfoMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.ReplayCommandMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.ResponseMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.SessionIdMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.SessionInfoMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.ShutdownInfoMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.SubscriptionInfoMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.TransactionInfoMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.WireFormatInfoMarshaller
 
createObject() - Method in class org.apache.activemq.openwire.v3.XATransactionIdMarshaller
 
createObjectMessage() - Method in class org.apache.activemq.ActiveMQQueueSession
 
createObjectMessage(Serializable) - Method in class org.apache.activemq.ActiveMQQueueSession
 
createObjectMessage() - Method in class org.apache.activemq.ActiveMQSession
Creates an ObjectMessage object.
createObjectMessage(Serializable) - Method in class org.apache.activemq.ActiveMQSession
Creates an initialized ObjectMessage object.
createObjectMessage() - Method in class org.apache.activemq.ActiveMQTopicSession
 
createObjectMessage(Serializable) - Method in class org.apache.activemq.ActiveMQTopicSession
 
createObjectMessage(HierarchicalStreamReader) - Method in class org.apache.activemq.transport.stomp.JmsFrameTranslator
 
createObjectName(ActiveMQDestination) - Method in class org.apache.activemq.broker.jmx.ManagedRegionBroker
 
createOR(BooleanExpression, BooleanExpression) - Static method in class org.apache.activemq.filter.LogicExpression
 
createOutputStream(Destination) - Method in class org.apache.activemq.ActiveMQConnection
Creates a persistent output stream; individual messages will be written to disk/database by the broker
createOutputStream(Destination, Map<String, Object>, int, int, long) - Method in class org.apache.activemq.ActiveMQConnection
Creates an output stream allowing full control over the delivery mode, the priority and time to live of the messages and the properties added to messages on the stream.
createOutputStream(Destination) - Method in interface org.apache.activemq.StreamConnection
 
createOutputStream(Destination, Map<String, Object>, int, int, long) - Method in interface org.apache.activemq.StreamConnection
 
createPersistenceAdapter() - Method in class org.apache.activemq.broker.BrokerService
 
createPersistenceAdapter() - Method in class org.apache.activemq.store.amq.AMQPersistenceAdapterFactory
 
createPersistenceAdapter() - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapterFactory
 
createPersistenceAdapter() - Method in interface org.apache.activemq.store.PersistenceAdapterFactory
Creates a persistence Adapter that can use a given directory to store it's data.
createPersistenceFactory() - Method in class org.apache.activemq.broker.BrokerService
 
createPlus(Expression, Expression) - Static method in class org.apache.activemq.filter.ArithmeticExpression
 
createProducer(Destination) - Method in class org.apache.activemq.ActiveMQQueueSession
 
createProducer(Destination) - Method in class org.apache.activemq.ActiveMQSession
Creates a MessageProducer to send messages to the specified destination.
createProducer(Destination) - Method in class org.apache.activemq.ActiveMQTopicSession
 
createProducer(ActiveMQSession) - Method in interface org.apache.activemq.CustomDestination
 
createProducer() - Method in class org.apache.activemq.network.jms.DestinationBridge
 
createProducerId() - Method in class org.apache.activemq.broker.region.policy.QueryBasedSubscriptionRecoveryPolicy
 
createPublisher(Topic) - Method in class org.apache.activemq.ActiveMQSession
Creates a publisher for the specified topic.
createPublisher(Topic) - Method in class org.apache.activemq.ActiveMQTopicSession
 
createPublisher(ActiveMQSession) - Method in interface org.apache.activemq.CustomDestination
 
createQueryString(Map) - Static method in class org.apache.activemq.util.URISupport
 
createQueue(String) - Method in class org.apache.activemq.ActiveMQQueueSession
 
createQueue(String) - Method in class org.apache.activemq.ActiveMQSession
Creates a queue identity given a Queue name.
createQueue(String) - Method in class org.apache.activemq.ActiveMQTopicSession
 
createQueue(String) - Method in class org.apache.activemq.jndi.ActiveMQInitialContextFactory
Factory method to create new Queue instances
createQueueConnection() - Method in class org.apache.activemq.ActiveMQConnectionFactory
 
createQueueConnection(String, String) - Method in class org.apache.activemq.ActiveMQConnectionFactory
 
createQueueMessageStore(ActiveMQQueue) - Method in class org.apache.activemq.store.amq.AMQPersistenceAdapter
 
createQueueMessageStore(ActiveMQQueue) - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
 
createQueueMessageStore(ActiveMQQueue) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
 
createQueueMessageStore(ActiveMQQueue) - Method in class org.apache.activemq.store.kahadaptor.KahaPersistenceAdapter
 
createQueueMessageStore(ActiveMQQueue) - Method in class org.apache.activemq.store.kahadaptor.KahaReferenceStoreAdapter
 
createQueueMessageStore(ActiveMQQueue) - Method in class org.apache.activemq.store.memory.MemoryPersistenceAdapter
 
createQueueMessageStore(ActiveMQQueue) - Method in interface org.apache.activemq.store.PersistenceAdapter
Factory method to create a new queue message store with the given destination name
createQueueReferenceStore(ActiveMQQueue) - Method in class org.apache.activemq.store.kahadaptor.KahaReferenceStoreAdapter
 
createQueueReferenceStore(ActiveMQQueue) - Method in interface org.apache.activemq.store.ReferenceStoreAdapter
Factory method to create a new queue message store with the given destination name
createQueueRegion(SystemUsage, TaskRunnerFactory, DestinationFactory) - Method in class org.apache.activemq.broker.jmx.ManagedRegionBroker
 
createQueueRegion(SystemUsage, TaskRunnerFactory, DestinationFactory) - Method in class org.apache.activemq.broker.region.RegionBroker
 
createQueues(Map<String, Object>, Hashtable) - Method in class org.apache.activemq.jndi.ActiveMQInitialContextFactory
 
createQueueSession(boolean, int) - Method in class org.apache.activemq.ActiveMQConnection
Creates a QueueSession object.
createReader() - Method in class org.apache.activemq.kaha.impl.data.DataManagerImpl
 
createReceiver(Queue) - Method in class org.apache.activemq.ActiveMQQueueSession
 
createReceiver(Queue, String) - Method in class org.apache.activemq.ActiveMQQueueSession
 
createReceiver(Queue) - Method in class org.apache.activemq.ActiveMQSession
Creates a QueueReceiver object to receive messages from the specified queue.
createReceiver(Queue, String) - Method in class org.apache.activemq.ActiveMQSession
Creates a QueueReceiver object to receive messages from the specified queue using a message selector.
createReceiver(ActiveMQSession, String) - Method in interface org.apache.activemq.CustomDestination
 
createRecoveryFailedException(Exception) - Method in class org.apache.activemq.store.amq.AMQPersistenceAdapter
 
createRecoveryFailedException(Exception) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
 
createReference(String, JNDIStorableInterface) - Static method in class org.apache.activemq.jndi.JNDIReferenceFactory
Create a Reference instance from a JNDIStorable object
createReferenceStoreAdapter() - Method in class org.apache.activemq.store.amq.AMQPersistenceAdapter
 
createRegionBroker() - Method in class org.apache.activemq.broker.BrokerService
Factory method to create the core region broker onto which interceptors are added
createRegionBroker(DestinationInterceptor) - Method in class org.apache.activemq.broker.BrokerService
 
createRemainingURI(URI, Map) - Static method in class org.apache.activemq.util.URISupport
Creates a URI from the original URI and the remaining paramaters
createRemoveCommand() - Method in class org.apache.activemq.command.ConnectionInfo
 
createRemoveCommand() - Method in class org.apache.activemq.command.ConsumerInfo
 
createRemoveCommand() - Method in class org.apache.activemq.command.ProducerInfo
 
createRemoveCommand() - Method in class org.apache.activemq.command.SessionInfo
 
createReplayBuffer() - Method in class org.apache.activemq.transport.reliable.ReliableTransport
 
createReplayer() - Method in class org.apache.activemq.transport.udp.UdpTransport
Creates a replayer for working with the reliable transport
createReplayStrategy(Replayer) - Method in class org.apache.activemq.transport.udp.UdpTransportFactory
 
createReplayStrategy() - Method in class org.apache.activemq.transport.udp.UdpTransportFactory
 
createReplyToBridge(Destination, Connection, Connection) - Method in class org.apache.activemq.network.jms.JmsConnector
 
createReplyToBridge(Destination, Connection, Connection) - Method in class org.apache.activemq.network.jms.JmsQueueConnector
 
createReplyToBridge(Destination, Connection, Connection) - Method in class org.apache.activemq.network.jms.JmsTopicConnector
 
createResponseHandler(StompFrame) - Method in class org.apache.activemq.transport.stomp.ProtocolConverter
 
createSelectorFilter(String) - Method in class org.apache.activemq.broker.region.Queue
 
createSender(Queue) - Method in class org.apache.activemq.ActiveMQQueueSession
 
createSender(Queue) - Method in class org.apache.activemq.ActiveMQSession
Creates a QueueSender object to send messages to the specified queue.
createSender(ActiveMQSession) - Method in interface org.apache.activemq.CustomDestination
 
createServer() - Method in class org.apache.activemq.proxy.ProxyConnector
 
createServerSocketFactory() - Method in class org.apache.activemq.transport.nio.NIOTransportFactory
 
createServerSocketFactory() - Method in class org.apache.activemq.transport.tcp.SslTransportFactory
Creates a new SSL ServerSocketFactory.
createServerSocketFactory() - Method in class org.apache.activemq.transport.tcp.TcpTransportFactory
 
createServiceInfo(String, Map) - Method in class org.apache.activemq.transport.discovery.rendezvous.RendezvousDiscoveryAgent
 
createSession(boolean, int) - Method in class org.apache.activemq.ActiveMQConnection
Creates a Session object.
createSession(boolean, int) - Method in class org.apache.activemq.ActiveMQXAConnection
 
createSocket() - Method in class org.apache.activemq.broker.util.MulticastTraceBrokerPlugin
 
createSocket() - Method in class org.apache.activemq.broker.util.UDPTraceBrokerPlugin
 
createSocketAddress(URI) - Method in class org.apache.activemq.broker.util.UDPTraceBrokerPlugin
 
createSocketFactory() - Method in class org.apache.activemq.transport.nio.NIOTransportFactory
 
createSocketFactory() - Method in class org.apache.activemq.transport.tcp.SslTransportFactory
Creates a new SSL SocketFactory.
createSocketFactory() - Method in class org.apache.activemq.transport.tcp.TcpTransportFactory
 
createSslTransportServer(URI, KeyManager[], TrustManager[], SecureRandom) - Method in class org.apache.activemq.broker.SslBrokerService
Creates a TransportServer that uses the given key and trust managers.
createStore() - Method in class org.apache.activemq.store.kahadaptor.KahaPersistenceAdapter
 
createStreamMessage() - Method in class org.apache.activemq.ActiveMQQueueSession
 
createStreamMessage() - Method in class org.apache.activemq.ActiveMQSession
Creates a StreamMessage object.
createStreamMessage() - Method in class org.apache.activemq.ActiveMQTopicSession
 
createSubcontext(Name) - Method in class org.apache.activemq.jndi.ReadOnlyContext
 
createSubcontext(String) - Method in class org.apache.activemq.jndi.ReadOnlyContext
 
createSubscriber(Topic) - Method in class org.apache.activemq.ActiveMQSession
Creates a nondurable subscriber to the specified topic.
createSubscriber(Topic, String, boolean) - Method in class org.apache.activemq.ActiveMQSession
Creates a nondurable subscriber to the specified topic, using a message selector or specifying whether messages published by its own connection should be delivered to it.
createSubscriber(Topic) - Method in class org.apache.activemq.ActiveMQTopicSession
 
createSubscriber(Topic, String, boolean) - Method in class org.apache.activemq.ActiveMQTopicSession
 
createSubscriber(ActiveMQSession, String, boolean) - Method in interface org.apache.activemq.CustomDestination
 
createSubscription(ConnectionContext, ConsumerInfo) - Method in class org.apache.activemq.broker.jmx.ManagedQueueRegion
 
createSubscription(ConnectionContext, ConsumerInfo) - Method in class org.apache.activemq.broker.jmx.ManagedTempQueueRegion
 
createSubscription(ConnectionContext, ConsumerInfo) - Method in class org.apache.activemq.broker.jmx.ManagedTempTopicRegion
 
createSubscription(ConnectionContext, ConsumerInfo) - Method in class org.apache.activemq.broker.jmx.ManagedTopicRegion
 
createSubscription(ConnectionContext, ConsumerInfo) - Method in class org.apache.activemq.broker.region.AbstractRegion
 
createSubscription(ConnectionContext, ConsumerInfo) - Method in class org.apache.activemq.broker.region.QueueRegion
 
createSubscription(ConnectionContext, ConsumerInfo) - Method in class org.apache.activemq.broker.region.TempQueueRegion
 
createSubscription(ConnectionContext, ConsumerInfo) - Method in class org.apache.activemq.broker.region.TempTopicRegion
 
createSubscription(ConnectionContext, ConsumerInfo) - Method in class org.apache.activemq.broker.region.TopicRegion
 
createTaskRunner(Task, String) - Method in class org.apache.activemq.thread.TaskRunnerFactory
 
createTaskRunnerFactory() - Method in class org.apache.activemq.store.amq.AMQPersistenceAdapter
 
createTcpHostAndPortUrl(String) - Method in class org.apache.activemq.spring.ActiveMQConnectionFactoryFactoryBean
Allows us to add any TCP specific URI configurations
createTcpTransport(WireFormat, SocketFactory, URI, URI) - Method in class org.apache.activemq.transport.nio.NIOTransportFactory
 
createTcpTransport(WireFormat, SocketFactory, URI, URI) - Method in class org.apache.activemq.transport.tcp.TcpTransportFactory
Allows subclasses of TcpTransportFactory to provide a create custom TcpTransport intances.
createTcpTransportServer(URI, ServerSocketFactory) - Method in class org.apache.activemq.transport.nio.NIOTransportFactory
 
createTcpTransportServer(URI, ServerSocketFactory) - Method in class org.apache.activemq.transport.tcp.TcpTransportFactory
Allows subclasses of TcpTransportFactory to create custom instances of TcpTransportServer.
createTempDestination(boolean) - Method in class org.apache.activemq.ActiveMQConnection
Create the DestinationInfo object for the temporary destination.
createTemporaryQueue() - Method in class org.apache.activemq.ActiveMQQueueSession
 
createTemporaryQueue() - Method in class org.apache.activemq.ActiveMQSession
Creates a TemporaryQueue object.
createTemporaryQueue() - Method in class org.apache.activemq.ActiveMQTopicSession
 
createTemporaryTopic() - Method in class org.apache.activemq.ActiveMQQueueSession
 
createTemporaryTopic() - Method in class org.apache.activemq.ActiveMQSession
Creates a TemporaryTopic object.
createTemporaryTopic() - Method in class org.apache.activemq.ActiveMQTopicSession
 
createTempQueue(String) - Method in class org.apache.activemq.transport.stomp.ProtocolConverter
 
createTempQueueRegion(SystemUsage, TaskRunnerFactory, DestinationFactory) - Method in class org.apache.activemq.broker.jmx.ManagedRegionBroker
 
createTempQueueRegion(SystemUsage, TaskRunnerFactory, DestinationFactory) - Method in class org.apache.activemq.broker.region.RegionBroker
 
createTempTopic(String) - Method in class org.apache.activemq.transport.stomp.ProtocolConverter
 
createTempTopicRegion(SystemUsage, TaskRunnerFactory, DestinationFactory) - Method in class org.apache.activemq.broker.jmx.ManagedRegionBroker
 
createTempTopicRegion(SystemUsage, TaskRunnerFactory, DestinationFactory) - Method in class org.apache.activemq.broker.region.RegionBroker
 
createTextMessage() - Method in class org.apache.activemq.ActiveMQQueueSession
 
createTextMessage(String) - Method in class org.apache.activemq.ActiveMQQueueSession
 
createTextMessage() - Method in class org.apache.activemq.ActiveMQSession
Creates a TextMessage object.
createTextMessage(String) - Method in class org.apache.activemq.ActiveMQSession
Creates an initialized TextMessage object.
createTextMessage() - Method in class org.apache.activemq.ActiveMQTopicSession
 
createTextMessage(String) - Method in class org.apache.activemq.ActiveMQTopicSession
 
createTopic(String) - Method in class org.apache.activemq.ActiveMQQueueSession
 
createTopic(String) - Method in class org.apache.activemq.ActiveMQSession
Creates a topic identity given a Topic name.
createTopic(String) - Method in class org.apache.activemq.ActiveMQTopicSession
 
createTopic(String) - Method in class org.apache.activemq.jndi.ActiveMQInitialContextFactory
Factory method to create new Topic instances
createTopicConnection() - Method in class org.apache.activemq.ActiveMQConnectionFactory
 
createTopicConnection(String, String) - Method in class org.apache.activemq.ActiveMQConnectionFactory
 
createTopicMessageStore(ActiveMQTopic) - Method in class org.apache.activemq.store.amq.AMQPersistenceAdapter
 
createTopicMessageStore(ActiveMQTopic) - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
 
createTopicMessageStore(ActiveMQTopic) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
 
createTopicMessageStore(ActiveMQTopic) - Method in class org.apache.activemq.store.kahadaptor.KahaPersistenceAdapter
 
createTopicMessageStore(ActiveMQTopic) - Method in class org.apache.activemq.store.kahadaptor.KahaReferenceStoreAdapter
 
createTopicMessageStore(ActiveMQTopic) - Method in class org.apache.activemq.store.memory.MemoryPersistenceAdapter
 
createTopicMessageStore(ActiveMQTopic) - Method in interface org.apache.activemq.store.PersistenceAdapter
Factory method to create a new topic message store with the given destination name
createTopicReferenceStore(ActiveMQTopic) - Method in class org.apache.activemq.store.kahadaptor.KahaReferenceStoreAdapter
 
createTopicReferenceStore(ActiveMQTopic) - Method in interface org.apache.activemq.store.ReferenceStoreAdapter
Factory method to create a new topic message store with the given destination name
createTopicRegion(SystemUsage, TaskRunnerFactory, DestinationFactory) - Method in class org.apache.activemq.broker.jmx.ManagedRegionBroker
 
createTopicRegion(SystemUsage, TaskRunnerFactory, DestinationFactory) - Method in class org.apache.activemq.broker.region.RegionBroker
 
createTopics(Map<String, Object>, Hashtable) - Method in class org.apache.activemq.jndi.ActiveMQInitialContextFactory
 
createTopicSession(boolean, int) - Method in class org.apache.activemq.ActiveMQConnection
Creates a TopicSession object.
createTransactionStore() - Method in class org.apache.activemq.store.amq.AMQPersistenceAdapter
 
createTransactionStore() - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
 
createTransactionStore() - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
 
createTransactionStore() - Method in class org.apache.activemq.store.kahadaptor.KahaPersistenceAdapter
 
createTransactionStore() - Method in class org.apache.activemq.store.memory.MemoryPersistenceAdapter
 
createTransactionStore() - Method in interface org.apache.activemq.store.PersistenceAdapter
Factory method to create a new persistent prepared transaction store for XA recovery
createTransport() - Method in class org.apache.activemq.ActiveMQConnectionFactory
Creates a Transport based on this object's connection settings.
createTransport() - Method in class org.apache.activemq.ActiveMQSslConnectionFactory
Overriding to make special considerations for SSL connections.
createTransport(URISupport.CompositeData) - Method in class org.apache.activemq.transport.discovery.DiscoveryTransportFactory
 
createTransport(URISupport.CompositeData) - Method in class org.apache.activemq.transport.failover.FailoverTransportFactory
 
createTransport(Map) - Method in class org.apache.activemq.transport.failover.FailoverTransportFactory
 
createTransport(URI) - Method in class org.apache.activemq.transport.fanout.FanoutTransportFactory
 
createTransport(Map) - Method in class org.apache.activemq.transport.fanout.FanoutTransportFactory
 
createTransport(URISupport.CompositeData) - Method in class org.apache.activemq.transport.mock.MockTransportFactory
 
createTransport(URI, WireFormat) - Method in class org.apache.activemq.transport.multicast.MulticastTransportFactory
 
createTransport(URI, WireFormat) - Method in class org.apache.activemq.transport.tcp.SslTransportFactory
Overriding to use SslTransports.
createTransport(Socket, WireFormat) - Method in class org.apache.activemq.transport.tcp.SslTransportServer
Used to create Transports for this server.
createTransport(URI, WireFormat) - Method in class org.apache.activemq.transport.tcp.TcpTransportFactory
 
createTransport(Socket, WireFormat) - Method in class org.apache.activemq.transport.tcp.TcpTransportServer
Allow derived classes to override the Transport implementation that this transport server creates.
createTransport(URI, WireFormat) - Method in class org.apache.activemq.transport.TransportFactory
Factory method to create a new transport
createTransport(URI, WireFormat) - Method in class org.apache.activemq.transport.udp.UdpTransportFactory
 
createTransport(Command, DatagramEndpoint) - Method in class org.apache.activemq.transport.udp.UdpTransportServer
 
createTransportConnector(URI) - Method in class org.apache.activemq.broker.BrokerService
 
createTransportLogger(Transport) - Method in class org.apache.activemq.transport.TransportLoggerFactory
Creates a TransportLogger object, that will be inserted in the Transport Stack.
createTransportLogger(Transport, Log) - Method in class org.apache.activemq.transport.TransportLoggerFactory
Creates a TransportLogger object, that will be inserted in the Transport Stack.
createTransportLogger(Transport, String, boolean, boolean, int) - Method in class org.apache.activemq.transport.TransportLoggerFactory
Creates a TransportLogger object, that will be inserted in the Transport Stack.
createTransportLogger(Transport, int, Log, String, boolean, boolean, int) - Method in class org.apache.activemq.transport.TransportLoggerFactory
Creates a TransportLogger object, that will be inserted in the Transport Stack.
createTransportLoggerObjectNameRoot(ManagementContext) - Static method in class org.apache.activemq.transport.TransportLoggerView
Creates the part of the ObjectName that will be used by all MBeans.
createTransportServer() - Method in class org.apache.activemq.broker.TransportConnector
 
createUnknownDestinationTypeException(ActiveMQDestination) - Method in class org.apache.activemq.broker.region.RegionBroker
 
createUploadStrategy() - Method in class org.apache.activemq.blob.BlobTransferPolicy
 
createUploadURL(ActiveMQBlobMessage) - Method in class org.apache.activemq.blob.DefaultBlobUploadStrategy
 
createURIWithQuery(URI, String) - Static method in class org.apache.activemq.util.URISupport
Creates a URI with the given query
createWireFormat() - Method in class org.apache.activemq.broker.util.UDPTraceBrokerPlugin
 
createWireFormat() - Method in class org.apache.activemq.openwire.OpenWireFormatFactory
 
createWireFormat() - Method in class org.apache.activemq.transport.stomp.StompWireFormatFactory
 
createWireFormat(Map<String, String>) - Method in class org.apache.activemq.transport.TransportFactory
 
createWireFormat() - Method in interface org.apache.activemq.wireformat.WireFormatFactory
 
createWireFormatFactory() - Method in class org.apache.activemq.broker.util.UDPTraceBrokerPlugin
 
createWireFormatFactory(Map<String, String>) - Method in class org.apache.activemq.transport.TransportFactory
 
createWriteException(DataStructure, Exception) - Method in class org.apache.activemq.store.amq.AMQPersistenceAdapter
 
createWriteException(String, Exception) - Method in class org.apache.activemq.store.amq.AMQPersistenceAdapter
 
createWriteException(DataStructure, Exception) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
 
createWriteException(String, Exception) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
 
createXAConnection() - Method in class org.apache.activemq.ActiveMQXAConnectionFactory
 
createXAConnection(String, String) - Method in class org.apache.activemq.ActiveMQXAConnectionFactory
 
createXAQueueConnection() - Method in class org.apache.activemq.ActiveMQXAConnectionFactory
 
createXAQueueConnection(String, String) - Method in class org.apache.activemq.ActiveMQXAConnectionFactory
 
createXAQueueSession() - Method in class org.apache.activemq.ActiveMQXAConnection
 
createXASession() - Method in class org.apache.activemq.ActiveMQXAConnection
 
createXATopicConnection() - Method in class org.apache.activemq.ActiveMQXAConnectionFactory
 
createXATopicConnection(String, String) - Method in class org.apache.activemq.ActiveMQXAConnectionFactory
 
createXATopicSession() - Method in class org.apache.activemq.ActiveMQXAConnection
 
createXPath(String) - Static method in class org.apache.activemq.filter.UnaryExpression
 
createXQuery(String) - Static method in class org.apache.activemq.filter.UnaryExpression
 
createXStream() - Method in class org.apache.activemq.transport.stomp.JmsFrameTranslator
 
currentItem - Variable in class org.apache.activemq.kaha.impl.container.ContainerKeySetIterator
 
currentItem - Variable in class org.apache.activemq.kaha.impl.container.ContainerValueCollectionIterator
 
currentPrefetchSize - Variable in class org.apache.activemq.command.ConsumerInfo
 
currentTransportCount - Variable in class org.apache.activemq.transport.tcp.TcpTransportServer
 
currentWriteFile - Variable in class org.apache.activemq.kaha.impl.async.AsyncDataManager
 
cursorSize() - Method in class org.apache.activemq.broker.jmx.DurableSubscriptionView
 
cursorSize() - Method in interface org.apache.activemq.broker.jmx.DurableSubscriptionViewMBean
 
cursorSize() - Method in class org.apache.activemq.broker.jmx.QueueView
 
cursorSize() - Method in interface org.apache.activemq.broker.jmx.QueueViewMBean
 
CustomDestination - Interface in org.apache.activemq
Represents a hook to allow the support of custom destinations such as to support Apache Camel to create and manage endpoints
CustomLogWriter - Class in org.apache.activemq.transport.logwriters
Custom implementation of LogWriter interface.
CustomLogWriter() - Constructor for class org.apache.activemq.transport.logwriters.CustomLogWriter
 

D

data - Variable in class org.apache.activemq.store.journal.JournalTransactionStore.TxOperation
 
data - Variable in class org.apache.activemq.util.ByteSequence
 
DATA_ARRAY_RESPONSE - Static variable in interface org.apache.activemq.command.CommandTypes
 
DATA_ITEM_TYPE - Static variable in class org.apache.activemq.kaha.impl.async.AsyncDataManager
 
DATA_ITEM_TYPE - Static variable in class org.apache.activemq.kaha.impl.data.DataManagerImpl
 
DATA_RESPONSE - Static variable in interface org.apache.activemq.command.CommandTypes
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.ActiveMQBlobMessage
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.ActiveMQBytesMessage
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.ActiveMQMapMessage
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.ActiveMQMessage
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.ActiveMQObjectMessage
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.ActiveMQQueue
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.ActiveMQStreamMessage
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.ActiveMQTempQueue
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.ActiveMQTempTopic
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.ActiveMQTextMessage
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.ActiveMQTopic
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.BrokerId
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.BrokerInfo
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.ConnectionControl
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.ConnectionError
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.ConnectionId
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.ConnectionInfo
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.ConsumerControl
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.ConsumerId
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.ConsumerInfo
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.ControlCommand
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.DataArrayResponse
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.DataResponse
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.DestinationInfo
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.DiscoveryEvent
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.ExceptionResponse
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.FlushCommand
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.IntegerResponse
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.JournalQueueAck
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.JournalTopicAck
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.JournalTrace
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.JournalTransaction
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.KeepAliveInfo
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.LastPartialCommand
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.LocalTransactionId
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.MessageAck
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.MessageDispatch
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.MessageDispatchNotification
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.MessageId
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.MessagePull
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.NetworkBridgeFilter
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.PartialCommand
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.ProducerAck
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.ProducerId
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.ProducerInfo
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.RemoveInfo
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.RemoveSubscriptionInfo
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.ReplayCommand
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.Response
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.SessionId
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.SessionInfo
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.ShutdownInfo
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.SubscriptionInfo
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.TransactionInfo
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.WireFormatInfo
 
DATA_STRUCTURE_TYPE - Static variable in class org.apache.activemq.command.XATransactionId
 
DataArrayResponse - Class in org.apache.activemq.command
 
DataArrayResponse() - Constructor for class org.apache.activemq.command.DataArrayResponse
 
DataArrayResponse(DataStructure[]) - Constructor for class org.apache.activemq.command.DataArrayResponse
 
DataArrayResponseMarshaller - Class in org.apache.activemq.openwire.v1
Marshalling code for Open Wire Format for DataArrayResponseMarshaller 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.
DataArrayResponseMarshaller() - Constructor for class org.apache.activemq.openwire.v1.DataArrayResponseMarshaller
 
DataArrayResponseMarshaller - Class in org.apache.activemq.openwire.v2
Marshalling code for Open Wire Format for DataArrayResponseMarshaller 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.
DataArrayResponseMarshaller() - Constructor for class org.apache.activemq.openwire.v2.DataArrayResponseMarshaller
 
DataArrayResponseMarshaller - Class in org.apache.activemq.openwire.v3
Marshalling code for Open Wire Format for DataArrayResponseMarshaller 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.
DataArrayResponseMarshaller() - Constructor for class org.apache.activemq.openwire.v3.DataArrayResponseMarshaller
 
DatabaseLocker - Interface in org.apache.activemq.store.jdbc
Represents some kind of lock service to ensure that a broker is the only master
databaseLockKeepAlive() - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
 
DataByteArrayInputStream - Class in org.apache.activemq.util
Optimized ByteArrayInputStream that can be used more than once
DataByteArrayInputStream(byte[]) - Constructor for class org.apache.activemq.util.DataByteArrayInputStream
Creates a StoreByteArrayInputStream.
DataByteArrayInputStream(ByteSequence) - Constructor for class org.apache.activemq.util.DataByteArrayInputStream
Creates a StoreByteArrayInputStream.
DataByteArrayInputStream() - Constructor for class org.apache.activemq.util.DataByteArrayInputStream
Creates WireByteArrayInputStream with a minmalist byte array
DataByteArrayOutputStream - Class in org.apache.activemq.util
Optimized ByteArrayOutputStream
DataByteArrayOutputStream(int) - Constructor for class org.apache.activemq.util.DataByteArrayOutputStream
Creates a new byte array output stream, with a buffer capacity of the specified size, in bytes.
DataByteArrayOutputStream() - Constructor for class org.apache.activemq.util.DataByteArrayOutputStream
Creates a new byte array output stream.
DataFile - Class in org.apache.activemq.kaha.impl.async
DataFile
DataFileAccessorPool - Class in org.apache.activemq.kaha.impl.async
Used to pool DataFileAccessors.
DataFileAccessorPool(AsyncDataManager) - Constructor for class org.apache.activemq.kaha.impl.async.DataFileAccessorPool
 
dataFileId - Variable in class org.apache.activemq.kaha.impl.async.DataFile
 
DatagramEndpoint - Class in org.apache.activemq.transport.udp
 
DatagramEndpoint(String, SocketAddress) - Constructor for class org.apache.activemq.transport.udp.DatagramEndpoint
 
DatagramHeaderMarshaller - Class in org.apache.activemq.transport.udp
 
DatagramHeaderMarshaller() - Constructor for class org.apache.activemq.transport.udp.DatagramHeaderMarshaller
 
datagramSize - Variable in class org.apache.activemq.transport.udp.CommandChannelSupport
 
dataIn - Variable in class org.apache.activemq.command.ActiveMQBytesMessage
 
dataIn - Variable in class org.apache.activemq.command.ActiveMQStreamMessage
 
dataIn - Variable in class org.apache.activemq.transport.tcp.TcpTransport
 
DataItem - Class in org.apache.activemq.kaha.impl.data
A a wrapper for a data in the store
DataItem() - Constructor for class org.apache.activemq.kaha.impl.data.DataItem
 
dataManager - Variable in class org.apache.activemq.kaha.impl.container.BaseContainerImpl
 
DataManager - Interface in org.apache.activemq.kaha.impl
 
DataManagerFacade - Class in org.apache.activemq.kaha.impl.async
Provides a Kaha DataManager Facade to the DataManager.
DataManagerFacade(AsyncDataManager, String) - Constructor for class org.apache.activemq.kaha.impl.async.DataManagerFacade
 
DataManagerImpl - Class in org.apache.activemq.kaha.impl.data
Manages DataFiles
DataManagerImpl(File, String, AtomicLong) - Constructor for class org.apache.activemq.kaha.impl.data.DataManagerImpl
 
dataOut - Variable in class org.apache.activemq.command.ActiveMQBytesMessage
 
dataOut - Variable in class org.apache.activemq.command.ActiveMQStreamMessage
 
dataOut - Variable in class org.apache.activemq.transport.tcp.TcpTransport
 
DataResponse - Class in org.apache.activemq.command
 
DataResponse() - Constructor for class org.apache.activemq.command.DataResponse
 
DataResponse(DataStructure) - Constructor for class org.apache.activemq.command.DataResponse
 
DataResponseMarshaller - Class in org.apache.activemq.openwire.v1
Marshalling code for Open Wire Format for DataResponseMarshaller 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.
DataResponseMarshaller() - Constructor for class org.apache.activemq.openwire.v1.DataResponseMarshaller
 
DataResponseMarshaller - Class in org.apache.activemq.openwire.v2
Marshalling code for Open Wire Format for DataResponseMarshaller 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.
DataResponseMarshaller() - Constructor for class org.apache.activemq.openwire.v2.DataResponseMarshaller
 
DataResponseMarshaller - Class in org.apache.activemq.openwire.v3
Marshalling code for Open Wire Format for DataResponseMarshaller 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.
DataResponseMarshaller() - Constructor for class org.apache.activemq.openwire.v3.DataResponseMarshaller
 
DataSourceSupport - Class in org.apache.activemq.store.jdbc
A helper class which provides a factory method to create a default {@link DataSource) if one is not provided.
DataSourceSupport() - Constructor for class org.apache.activemq.store.jdbc.DataSourceSupport
 
DataSourceSupport(DataSource) - Constructor for class org.apache.activemq.store.jdbc.DataSourceSupport
 
DataStreamMarshaller - Interface in org.apache.activemq.openwire
 
DataStructure - Interface in org.apache.activemq.command
 
dataStructure - Variable in class org.apache.activemq.command.Message
 
DataStructureSupportMarshaller - Class in org.apache.activemq.openwire.v1
Marshalling code for Open Wire Format for DataStructureSupportMarshaller 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.
DataStructureSupportMarshaller() - Constructor for class org.apache.activemq.openwire.v1.DataStructureSupportMarshaller
 
DB2JDBCAdapter - Class in org.apache.activemq.store.jdbc.adapter
 
DB2JDBCAdapter() - Constructor for class org.apache.activemq.store.jdbc.adapter.DB2JDBCAdapter
 
deactivate(boolean) - Method in class org.apache.activemq.broker.region.DurableTopicSubscription
 
deactivate(ConnectionContext, DurableTopicSubscription) - Method in class org.apache.activemq.broker.region.Topic
 
deadLetterStrategy - Variable in class org.apache.activemq.broker.region.BaseDestination
 
DeadLetterStrategy - Interface in org.apache.activemq.broker.region.policy
A strategy for choosing which destination is used for dead letter queue messages.
debug - Variable in class org.apache.activemq.ActiveMQSession
 
decodeString(byte[]) - Static method in class org.apache.activemq.command.ActiveMQMessage
 
decreaseUsage(long) - Method in class org.apache.activemq.usage.MemoryUsage
Decreases the usage by the value amount.
decrement() - Method in class org.apache.activemq.kaha.impl.async.DataFile
 
decrement() - Method in class org.apache.activemq.management.CountStatisticImpl
 
decrement() - Method in class org.apache.activemq.thread.Valve
Decrements the use counter of the valve.
decrementCount() - Method in class org.apache.activemq.store.kahadaptor.TopicSubAck
 
decrementIndent() - Method in class org.apache.activemq.util.IndentPrinter
 
decrementQueueRef() - Method in class org.apache.activemq.broker.region.QueueBrowserSubscription
 
decrementReference() - Method in class org.apache.activemq.broker.TransportConnectionState
 
decrementReferenceCount() - Method in class org.apache.activemq.broker.region.IndirectMessageReference
 
decrementReferenceCount() - Method in interface org.apache.activemq.broker.region.MessageReference
 
decrementReferenceCount() - Method in class org.apache.activemq.command.Message
 
DEFAULT_ARCHIVE_DIRECTORY - Static variable in class org.apache.activemq.kaha.impl.async.AsyncDataManager
 
DEFAULT_BIN_SIZE - Static variable in class org.apache.activemq.kaha.impl.index.hash.HashIndex
 
DEFAULT_BROKER_BIND_URL - Static variable in class org.apache.activemq.ActiveMQConnectionFactory
 
DEFAULT_BROKER_NAME - Static variable in class org.apache.activemq.broker.BrokerService
 
DEFAULT_BROKER_URL - Static variable in class org.apache.activemq.ActiveMQConnection
 
DEFAULT_BROKER_URL - Static variable in class org.apache.activemq.ActiveMQConnectionFactory
 
DEFAULT_CLEANUP_INTERVAL - Static variable in class org.apache.activemq.kaha.impl.async.AsyncDataManager
 
DEFAULT_CONNECTION_EXECUTOR - Static variable in class org.apache.activemq.ActiveMQConnectionFactory
 
DEFAULT_CONTAINER_NAME - Static variable in interface org.apache.activemq.kaha.Store
Defauly container name
DEFAULT_DEAD_LETTER_QUEUE_NAME - Static variable in class org.apache.activemq.broker.region.policy.SharedDeadLetterStrategy
 
DEFAULT_DEAD_LETTER_STRATEGY - Static variable in interface org.apache.activemq.broker.region.Destination
 
DEFAULT_DIRECTORY - Static variable in class org.apache.activemq.kaha.impl.async.AsyncDataManager
 
DEFAULT_DISCOVERY_URI_STRING - Static variable in class org.apache.activemq.transport.discovery.multicast.MulticastDiscoveryAgent
 
DEFAULT_DOMAIN - Static variable in class org.apache.activemq.broker.jmx.ManagementContext
Default activemq domain
DEFAULT_FILE_PREFIX - Static variable in class org.apache.activemq.kaha.impl.async.AsyncDataManager
 
DEFAULT_HOST_IP - Static variable in class org.apache.activemq.transport.discovery.multicast.MulticastDiscoveryAgent
 
DEFAULT_HOST_STR - Static variable in class org.apache.activemq.transport.discovery.multicast.MulticastDiscoveryAgent
 
DEFAULT_INITIAL_CAPACITY - Static variable in class org.apache.activemq.memory.LRUMap
 
DEFAULT_KEY_SIZE - Static variable in class org.apache.activemq.kaha.impl.index.hash.HashIndex
 
DEFAULT_LOAD_FACTOR - Static variable in class org.apache.activemq.kaha.impl.index.hash.HashIndex
 
DEFAULT_LOAD_FACTOR - Static variable in class org.apache.activemq.memory.LRUMap
 
DEFAULT_LOCK_ACQUIRE_SLEEP_INTERVAL - Static variable in class org.apache.activemq.store.jdbc.DefaultDatabaseLocker
 
DEFAULT_MAX_FILE_LENGTH - Static variable in class org.apache.activemq.kaha.impl.async.AsyncDataManager
 
DEFAULT_MINIMUM_MESSAGE_SIZE - Static variable in class org.apache.activemq.command.Message
The default minimum amount of memory a message is assumed to use
DEFAULT_PAGE_SIZE - Static variable in class org.apache.activemq.kaha.impl.index.hash.HashIndex
 
DEFAULT_PASSWORD - Static variable in class org.apache.activemq.ActiveMQConnection
 
DEFAULT_PASSWORD - Static variable in class org.apache.activemq.ActiveMQConnectionFactory
 
DEFAULT_PORT - Static variable in class org.apache.activemq.broker.BrokerService
 
DEFAULT_PORT - Static variable in class org.apache.activemq.transport.discovery.multicast.MulticastDiscoveryAgent
 
DEFAULT_PRODUCER_WINDOW_SIZE - Static variable in class org.apache.activemq.ActiveMQConnectionFactory
 
DEFAULT_USER - Static variable in class org.apache.activemq.ActiveMQConnection
 
DEFAULT_USER - Static variable in class org.apache.activemq.ActiveMQConnectionFactory
 
DEFAULT_VERSION - Static variable in class org.apache.activemq.openwire.OpenWireFormat
 
DefaultAuthorizationMap - Class in org.apache.activemq.security
Represents a destination based configuration of policies so that individual destinations or wildcard hierarchies of destinations can be configured using different policies.
DefaultAuthorizationMap() - Constructor for class org.apache.activemq.security.DefaultAuthorizationMap
 
DefaultAuthorizationMap(List) - Constructor for class org.apache.activemq.security.DefaultAuthorizationMap
 
DefaultBlobUploadStrategy - Class in org.apache.activemq.blob
A default implementation of BlobUploadStrategy which uses the URL class to upload files or streams to a remote URL
DefaultBlobUploadStrategy(BlobTransferPolicy) - Constructor for class org.apache.activemq.blob.DefaultBlobUploadStrategy
 
DefaultBrokerFactory - Class in org.apache.activemq.broker
Simple BrokerFactorySPI which using the brokerURI to extract the configuration parameters for the broker service.
DefaultBrokerFactory() - Constructor for class org.apache.activemq.broker.DefaultBrokerFactory
 
DefaultBufferPool - Class in org.apache.activemq.transport.udp
A default implementation of BufferPool which keeps a pool of direct byte buffers.
DefaultBufferPool() - Constructor for class org.apache.activemq.transport.udp.DefaultBufferPool
 
DefaultBufferPool(boolean) - Constructor for class org.apache.activemq.transport.udp.DefaultBufferPool
 
DefaultDatabaseLocker - Class in org.apache.activemq.store.jdbc
Represents an exclusive lock on a database to avoid multiple brokers running against the same logical database.
DefaultDatabaseLocker(JDBCPersistenceAdapter) - Constructor for class org.apache.activemq.store.jdbc.DefaultDatabaseLocker
 
DefaultDatabaseLocker(DataSource, Statements) - Constructor for class org.apache.activemq.store.jdbc.DefaultDatabaseLocker
 
defaultDeliveryMode - Variable in class org.apache.activemq.ActiveMQMessageProducerSupport
 
DefaultDestinationMapEntry - Class in org.apache.activemq.filter
A default entry in a DestinationMap which holds a single value.
DefaultDestinationMapEntry() - Constructor for class org.apache.activemq.filter.DefaultDestinationMapEntry
 
DefaultJDBCAdapter - Class in org.apache.activemq.store.jdbc.adapter
Implements all the default JDBC operations that are used by the JDBCPersistenceAdapter.
DefaultJDBCAdapter() - Constructor for class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
 
DefaultLogWriter - Class in org.apache.activemq.transport.logwriters
Implementation of LogWriter interface to keep ActiveMQ's old logging format.
DefaultLogWriter() - Constructor for class org.apache.activemq.transport.logwriters.DefaultLogWriter
 
defaultLogWriterName - Static variable in class org.apache.activemq.transport.TransportLoggerFactory
LogWriter that will be used if none is specified.
defaultPriority - Variable in class org.apache.activemq.ActiveMQMessageProducerSupport
 
DefaultReplayBuffer - Class in org.apache.activemq.transport.reliable
 
DefaultReplayBuffer(int) - Constructor for class org.apache.activemq.transport.reliable.DefaultReplayBuffer
 
DefaultReplayStrategy - Class in org.apache.activemq.transport.reliable
Throws an exception if packets are dropped causing the transport to be closed.
DefaultReplayStrategy() - Constructor for class org.apache.activemq.transport.reliable.DefaultReplayStrategy
 
DefaultReplayStrategy(int) - Constructor for class org.apache.activemq.transport.reliable.DefaultReplayStrategy
 
DefaultThreadPools - Class in org.apache.activemq.thread
 
defaultTimeToLive - Variable in class org.apache.activemq.ActiveMQMessageProducerSupport
 
DefaultTransportListener - Class in org.apache.activemq.transport
An asynchronous listener of commands
DefaultTransportListener() - Constructor for class org.apache.activemq.transport.DefaultTransportListener
 
DefaultUsageCapacity - Class in org.apache.activemq.usage
Identify if a limit has been reached
DefaultUsageCapacity() - Constructor for class org.apache.activemq.usage.DefaultUsageCapacity
 
delete() - Method in class org.apache.activemq.command.ActiveMQTempDestination
 
delete() - Method in class org.apache.activemq.kaha.impl.async.AsyncDataManager
 
delete() - Method in class org.apache.activemq.kaha.impl.async.DataFile
 
delete() - Method in class org.apache.activemq.kaha.impl.async.DataManagerFacade
 
delete() - Method in class org.apache.activemq.kaha.impl.async.ReadOnlyAsyncDataManager
 
delete() - Method in class org.apache.activemq.kaha.impl.async.ReadOnlyDataFile
 
delete(IndexItem, IndexItem, IndexItem) - Method in class org.apache.activemq.kaha.impl.container.BaseContainerImpl
 
delete() - Method in class org.apache.activemq.kaha.impl.data.DataManagerImpl
 
delete() - Method in interface org.apache.activemq.kaha.impl.DataManager
 
delete() - Method in class org.apache.activemq.kaha.impl.index.hash.HashIndex
 
delete() - Method in class org.apache.activemq.kaha.impl.index.IndexManager
 
delete() - Method in class org.apache.activemq.kaha.impl.index.tree.TreeIndex
 
delete() - Method in class org.apache.activemq.kaha.impl.KahaStore
 
delete() - Method in interface org.apache.activemq.kaha.Store
delete the store
delete(String) - Static method in class org.apache.activemq.kaha.StoreFactory
Delete a database
delete(File) - Static method in class org.apache.activemq.kaha.StoreFactory
Delete a database
delete() - Method in class org.apache.activemq.store.kahadaptor.KahaMessageStore
 
delete() - Method in class org.apache.activemq.store.kahadaptor.KahaReferenceStore
 
delete() - Method in class org.apache.activemq.store.kahadaptor.KahaTopicMessageStore
 
delete() - Method in class org.apache.activemq.store.kahadaptor.KahaTransactionStore
 
delete() - Method in class org.apache.activemq.store.memory.MemoryMessageStore
 
delete() - Method in class org.apache.activemq.store.memory.MemoryTopicMessageStore
 
delete() - Method in class org.apache.activemq.store.memory.MemoryTransactionStore
 
deleteAllMessages() - Method in class org.apache.activemq.broker.BrokerService
Delete all messages from the persistent store
deleteAllMessages() - Method in class org.apache.activemq.store.amq.AMQPersistenceAdapter
 
deleteAllMessages() - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
 
deleteAllMessages() - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
 
deleteAllMessages() - Method in class org.apache.activemq.store.kahadaptor.KahaPersistenceAdapter
 
deleteAllMessages() - Method in class org.apache.activemq.store.kahadaptor.KahaReferenceStoreAdapter
 
deleteAllMessages() - Method in class org.apache.activemq.store.memory.MemoryPersistenceAdapter
 
deleteAllMessages() - Method in interface org.apache.activemq.store.PersistenceAdapter
Delete's all the messages in the persistent store.
deleteChildren(File) - Static method in class org.apache.activemq.util.IOHelper
 
deleteFile(ActiveMQBlobMessage) - Method in class org.apache.activemq.blob.DefaultBlobUploadStrategy
 
deleteFile(File) - Static method in class org.apache.activemq.util.IOHelper
 
deleteListContainer(Object) - Method in class org.apache.activemq.kaha.impl.KahaStore
 
deleteListContainer(Object, String) - Method in class org.apache.activemq.kaha.impl.KahaStore
 
deleteListContainer(ContainerId) - Method in class org.apache.activemq.kaha.impl.KahaStore
 
deleteListContainer(Object) - Method in interface org.apache.activemq.kaha.Store
delete a ListContainer from the default container
deleteListContainer(Object, String) - Method in interface org.apache.activemq.kaha.Store
delete a ListContainer from the named container
deleteListContainer(ContainerId) - Method in interface org.apache.activemq.kaha.Store
delete a list container
deleteMapContainer(Object) - Method in class org.apache.activemq.kaha.impl.KahaStore
 
deleteMapContainer(Object, String) - Method in class org.apache.activemq.kaha.impl.KahaStore
 
deleteMapContainer(ContainerId) - Method in class org.apache.activemq.kaha.impl.KahaStore
 
deleteMapContainer(Object) - Method in interface org.apache.activemq.kaha.Store
delete a container from the default container
deleteMapContainer(Object, String) - Method in interface org.apache.activemq.kaha.Store
delete a MapContainer from the name container
deleteMapContainer(ContainerId) - Method in interface org.apache.activemq.kaha.Store
Delete Map container
deleteSubscription(ConnectionContext, SubscriptionKey) - Method in class org.apache.activemq.broker.region.Topic
 
deleteSubscription(String, String) - Method in class org.apache.activemq.store.amq.AMQTopicMessageStore
 
deleteSubscription(String, String) - Method in class org.apache.activemq.store.jdbc.JDBCTopicMessageStore
 
deleteSubscription(String, String) - Method in class org.apache.activemq.store.journal.JournalTopicMessageStore
 
deleteSubscription(String, String) - Method in class org.apache.activemq.store.kahadaptor.KahaTopicMessageStore
 
deleteSubscription(String, String) - Method in class org.apache.activemq.store.kahadaptor.KahaTopicReferenceStore
 
deleteSubscription(String, String) - Method in class org.apache.activemq.store.memory.MemoryTopicMessageStore
 
deleteSubscription(String, String) - Method in class org.apache.activemq.store.ProxyTopicMessageStore
 
deleteSubscription(String, String) - Method in interface org.apache.activemq.store.TopicMessageStore
 
deleteSubscription(String, String) - Method in interface org.apache.activemq.store.TopicReferenceStore
 
deleteTempDestination(ActiveMQTempDestination) - Method in class org.apache.activemq.ActiveMQConnection
 
DELIVERED_ACK_TYPE - Static variable in class org.apache.activemq.command.MessageAck
Used to let the broker know that the message has been delivered to the client.
deliveryIdGenerator - Variable in class org.apache.activemq.ActiveMQSession
 
deliverySequenceId - Variable in class org.apache.activemq.command.MessageDispatch
 
deliverySequenceId - Variable in class org.apache.activemq.command.MessageDispatchNotification
 
demandConsumerDispatched - Variable in class org.apache.activemq.network.DemandForwardingBridgeSupport
 
demandConsumerInfo - Variable in class org.apache.activemq.network.DemandForwardingBridgeSupport
 
DemandForwardingBridge - Class in org.apache.activemq.network
Forwards messages from the local broker to the remote broker based on demand.
DemandForwardingBridge(NetworkBridgeConfiguration, Transport, Transport) - Constructor for class org.apache.activemq.network.DemandForwardingBridge
 
DemandForwardingBridgeSupport - Class in org.apache.activemq.network
A useful base class for implementing demand forwarding bridges.
DemandForwardingBridgeSupport(NetworkBridgeConfiguration, Transport, Transport) - Constructor for class org.apache.activemq.network.DemandForwardingBridgeSupport
 
DemandSubscription - Class in org.apache.activemq.network
Represents a network bridge interface
dequeue(long) - Method in class org.apache.activemq.MessageDispatchChannel
Used to get an enqueued message.
dequeueCounter - Variable in class org.apache.activemq.broker.region.PrefetchSubscription
 
dequeueNoWait() - Method in class org.apache.activemq.MessageDispatchChannel
 
dequeues - Variable in class org.apache.activemq.broker.region.ConnectorStatistics
 
dequeues - Variable in class org.apache.activemq.broker.region.DestinationStatistics
 
deRegisterWrite(WriteTimeoutFilter, boolean, IOException) - Static method in class org.apache.activemq.transport.WriteTimeoutFilter
 
destination - Variable in class org.apache.activemq.broker.jmx.DestinationView
 
destination - Variable in class org.apache.activemq.broker.region.BaseDestination
 
Destination - Interface in org.apache.activemq.broker.region
 
destination - Variable in class org.apache.activemq.broker.util.UDPTraceBrokerPlugin
 
destination - Variable in class org.apache.activemq.command.ConsumerInfo
 
destination - Variable in class org.apache.activemq.command.DestinationInfo
 
destination - Variable in class org.apache.activemq.command.Message
 
destination - Variable in class org.apache.activemq.command.MessageAck
 
destination - Variable in class org.apache.activemq.command.MessageDispatch
 
destination - Variable in class org.apache.activemq.command.MessageDispatchNotification
 
destination - Variable in class org.apache.activemq.command.MessagePull
 
destination - Variable in class org.apache.activemq.command.ProducerInfo
 
destination - Variable in class org.apache.activemq.command.SubscriptionInfo
 
destination - Variable in class org.apache.activemq.filter.MessageEvaluationContext
 
destination - Variable in class org.apache.activemq.store.amq.AMQMessageStore
 
destination - Variable in class org.apache.activemq.store.jdbc.JDBCMessageStore
 
destination - Variable in class org.apache.activemq.store.journal.JournalMessageStore
 
destination - Variable in class org.apache.activemq.store.kahadaptor.KahaMessageStore
 
destination - Variable in class org.apache.activemq.store.kahadaptor.KahaReferenceStore
 
destination - Variable in class org.apache.activemq.store.memory.MemoryMessageStore
 
DESTINATION - Static variable in interface org.apache.activemq.transport.stomp.Stomp.Headers.Message
 
DESTINATION - Static variable in interface org.apache.activemq.transport.stomp.Stomp.Headers.Send
 
DESTINATION - Static variable in interface org.apache.activemq.transport.stomp.Stomp.Headers.Subscribe
 
DESTINATION - Static variable in interface org.apache.activemq.transport.stomp.Stomp.Headers.Unsubscribe
 
DESTINATION_INFO - Static variable in interface org.apache.activemq.command.CommandTypes
 
DestinationAlreadyExistsException - Exception in org.apache.activemq.broker
An exception thrown if a destination is attempted to be created when it already exists.
DestinationAlreadyExistsException(ActiveMQDestination) - Constructor for exception org.apache.activemq.broker.DestinationAlreadyExistsException
 
DestinationBasedMessageList - Class in org.apache.activemq.memory.list
An implementation of MessageList which maintains a separate message list for each destination to reduce contention on the list and to speed up recovery times by only recovering the interested topics.
DestinationBasedMessageList(int) - Constructor for class org.apache.activemq.memory.list.DestinationBasedMessageList
 
DestinationBasedMessageList(MessageBuffer) - Constructor for class org.apache.activemq.memory.list.DestinationBasedMessageList
 
DestinationBridge - Class in org.apache.activemq.network.jms
A Destination bridge is used to bridge between to different JMS systems
DestinationBridge() - Constructor for class org.apache.activemq.network.jms.DestinationBridge
 
DestinationDotFileInterceptor - Class in org.apache.activemq.broker.view
 
DestinationDotFileInterceptor(Broker, String) - Constructor for class org.apache.activemq.broker.view.DestinationDotFileInterceptor
 
DestinationDotFilePlugin - Class in org.apache.activemq.broker.view
A DOT file creator plugin which creates a DOT file showing the current topic & queue hierarchies.
DestinationDotFilePlugin() - Constructor for class org.apache.activemq.broker.view.DestinationDotFilePlugin
 
DestinationEvent - Class in org.apache.activemq.advisory
An event caused when a destination is created or deleted
DestinationEvent(DestinationSource, DestinationInfo) - Constructor for class org.apache.activemq.advisory.DestinationEvent
 
destinationFactory - Variable in class org.apache.activemq.broker.BrokerService
 
destinationFactory - Variable in class org.apache.activemq.broker.region.AbstractRegion
 
DestinationFactory - Class in org.apache.activemq.broker.region
Used to create Destinations.
DestinationFactory() - Constructor for class org.apache.activemq.broker.region.DestinationFactory
 
destinationFactory - Variable in class org.apache.activemq.broker.region.RegionBroker
 
DestinationFactoryImpl - Class in org.apache.activemq.broker.region
Creates standard ActiveMQ implementations of Destination.
DestinationFactoryImpl(BrokerService, TaskRunnerFactory, PersistenceAdapter) - Constructor for class org.apache.activemq.broker.region.DestinationFactoryImpl
 
destinationFilter - Variable in class org.apache.activemq.broker.region.AbstractSubscription
 
DestinationFilter - Class in org.apache.activemq.broker.region
 
DestinationFilter(Destination) - Constructor for class org.apache.activemq.broker.region.DestinationFilter
 
DestinationFilter - Class in org.apache.activemq.filter
Represents a filter which only operates on Destinations
DestinationFilter() - Constructor for class org.apache.activemq.filter.DestinationFilter
 
DestinationInfo - Class in org.apache.activemq.command
Used to create and destroy destinations on the broker.
DestinationInfo() - Constructor for class org.apache.activemq.command.DestinationInfo
 
DestinationInfo(ConnectionId, byte, ActiveMQDestination) - Constructor for class org.apache.activemq.command.DestinationInfo
 
DestinationInfoMarshaller - Class in org.apache.activemq.openwire.v1
Marshalling code for Open Wire Format for DestinationInfoMarshaller 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.
DestinationInfoMarshaller() - Constructor for class org.apache.activemq.openwire.v1.DestinationInfoMarshaller
 
DestinationInfoMarshaller - Class in org.apache.activemq.openwire.v2
Marshalling code for Open Wire Format for DestinationInfoMarshaller 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.
DestinationInfoMarshaller() - Constructor for class org.apache.activemq.openwire.v2.DestinationInfoMarshaller
 
DestinationInfoMarshaller - Class in org.apache.activemq.openwire.v3
Marshalling code for Open Wire Format for DestinationInfoMarshaller 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.
DestinationInfoMarshaller() - Constructor for class org.apache.activemq.openwire.v3.DestinationInfoMarshaller
 
DestinationInterceptor - Interface in org.apache.activemq.broker.region
Represents an interceptor on destination instances.
DestinationListener - Interface in org.apache.activemq.advisory
Listen to the changes in destinations being created or destroyed
destinationMap - Variable in class org.apache.activemq.broker.region.AbstractRegion
 
DestinationMap - Class in org.apache.activemq.filter
A Map-like data structure allowing values to be indexed by ActiveMQDestination and retrieved by destination - supporting both * and > style of wildcard as well as composite destinations.
DestinationMap() - Constructor for class org.apache.activemq.filter.DestinationMap
 
DestinationMapEntry - Class in org.apache.activemq.filter
A base class for entry objects used to construct a destination based policy map.
DestinationMapEntry() - Constructor for class org.apache.activemq.filter.DestinationMapEntry
 
DestinationMapNode - Class in org.apache.activemq.filter
An implementation class used to implement DestinationMap
DestinationMapNode(DestinationMapNode) - Constructor for class org.apache.activemq.filter.DestinationMapNode
 
DestinationNode - Interface in org.apache.activemq.filter
Represents a node in the DestinationMap tree
DestinationPath - Class in org.apache.activemq.filter
Helper class for decomposing a Destination into a number of paths
destinationPaths - Variable in class org.apache.activemq.command.ActiveMQDestination
 
destinations - Variable in class org.apache.activemq.advisory.AdvisoryBroker
 
destinations - Variable in class org.apache.activemq.broker.region.AbstractRegion
 
destinations - Variable in class org.apache.activemq.broker.region.AbstractSubscription
 
destinationsAdded() - Method in class org.apache.activemq.broker.region.QueueBrowserSubscription
 
destinationsMutex - Variable in class org.apache.activemq.broker.region.AbstractRegion
 
DestinationSource - Class in org.apache.activemq.advisory
A helper class which keeps track of the Destinations available in a broker and allows you to listen to them being created or deleted.
DestinationSource(Connection) - Constructor for class org.apache.activemq.advisory.DestinationSource
 
destinationStatistics - Variable in class org.apache.activemq.broker.region.AbstractRegion
 
destinationStatistics - Variable in class org.apache.activemq.broker.region.BaseDestination
 
DestinationStatistics - Class in org.apache.activemq.broker.region
The J2EE Statistics for the a Destination.
DestinationStatistics() - Constructor for class org.apache.activemq.broker.region.DestinationStatistics
 
destinationStatistics - Variable in class org.apache.activemq.broker.region.RegionBroker
 
DestinationView - Class in org.apache.activemq.broker.jmx
 
DestinationView(ManagedRegionBroker, Destination) - Constructor for class org.apache.activemq.broker.jmx.DestinationView
 
DestinationViewMBean - Interface in org.apache.activemq.broker.jmx
 
destroy() - Method in class org.apache.activemq.broker.jmx.DurableSubscriptionView
Destroys the durable subscription so that messages will no longer be stored for this subscription
destroy() - Method in interface org.apache.activemq.broker.jmx.DurableSubscriptionViewMBean
Destroys the durable subscription so that messages will no longer be stored for this subscription
destroy() - Method in class org.apache.activemq.broker.jmx.InactiveDurableSubscriptionView
Destroys the durable subscription so that messages will no longer be stored for this subscription
destroy() - Method in class org.apache.activemq.broker.region.cursors.AbstractPendingMessageCursor
destroy the cursor
destroy() - Method in class org.apache.activemq.broker.region.cursors.FilePendingMessageCursor
 
destroy() - Method in interface org.apache.activemq.broker.region.cursors.PendingMessageCursor
destroy the cursor
destroy() - Method in class org.apache.activemq.broker.region.DurableTopicSubscription
Release any references that we are holding.
destroy() - Method in class org.apache.activemq.broker.region.QueueSubscription
 
destroy() - Method in interface org.apache.activemq.broker.region.Subscription
Called when the subscription is destroyed.
destroy() - Method in class org.apache.activemq.broker.region.TopicSubscription
 
destroy() - Method in class org.apache.activemq.broker.util.CommandAgent
 
destroy() - Method in class org.apache.activemq.xbean.BrokerFactoryBean
 
destroy() - Method in class org.apache.activemq.xbean.PooledBrokerFactoryBean
 
destroy() - Method in class org.apache.activemq.xbean.XBeanBrokerService
 
destroyDestination(ActiveMQDestination) - Method in class org.apache.activemq.ActiveMQConnection
 
destroyDurableSubscriber(String, String) - Method in class org.apache.activemq.broker.jmx.BrokerView
 
destroyDurableSubscriber(String, String) - Method in interface org.apache.activemq.broker.jmx.BrokerViewMBean
Destroys a durable subscriber
destroySubcontext(Name) - Method in class org.apache.activemq.jndi.ReadOnlyContext
 
destroySubcontext(String) - Method in class org.apache.activemq.jndi.ReadOnlyContext
 
destroySubscription(Subscription) - Method in class org.apache.activemq.broker.jmx.ManagedQueueRegion
 
destroySubscription(Subscription) - Method in class org.apache.activemq.broker.jmx.ManagedTempQueueRegion
 
destroySubscription(Subscription) - Method in class org.apache.activemq.broker.jmx.ManagedTempTopicRegion
 
destroySubscription(Subscription) - Method in class org.apache.activemq.broker.jmx.ManagedTopicRegion
 
destroySubscription(Subscription) - Method in class org.apache.activemq.broker.region.AbstractRegion
 
DeterministicTaskRunner - Class in org.apache.activemq.thread
 
DeterministicTaskRunner(Executor, Task) - Constructor for class org.apache.activemq.thread.DeterministicTaskRunner
Constructor
directory - Variable in class org.apache.activemq.kaha.impl.async.AsyncDataManager
 
directory - Variable in class org.apache.activemq.kaha.impl.container.MapContainerImpl
 
directoryArchive - Variable in class org.apache.activemq.kaha.impl.async.AsyncDataManager
 
disable() - Method in class org.apache.activemq.transport.nio.SelectorSelection
 
disableAllTransportLoggers() - Method in class org.apache.activemq.transport.TransportLoggerControl
 
disableAllTransportLoggers() - Method in interface org.apache.activemq.transport.TransportLoggerControlMBean
Disable logging for all Transport Loggers at once.
disableAllTransportLoggers() - Static method in class org.apache.activemq.transport.TransportLoggerView
Disable logging for all Transport Loggers at once.
disableLogging() - Method in class org.apache.activemq.transport.TransportLoggerView
 
disableLogging() - Method in interface org.apache.activemq.transport.TransportLoggerViewMBean
Disables logging for the managed TransportLogger.
disableMessageID - Variable in class org.apache.activemq.ActiveMQMessageProducerSupport
 
disableMessageTimestamp - Variable in class org.apache.activemq.ActiveMQMessageProducerSupport
 
disableStatistics() - Method in class org.apache.activemq.broker.jmx.BrokerView
 
disableStatistics() - Method in interface org.apache.activemq.broker.jmx.BrokerViewMBean
 
disableStatistics() - Method in class org.apache.activemq.broker.jmx.ConnectorView
disable statistics gathering
disableStatistics() - Method in interface org.apache.activemq.broker.jmx.ConnectorViewMBean
disable statistics gathering
discard(MessageReference) - Method in class org.apache.activemq.broker.region.cursors.FilePendingMessageCursor
 
discarded() - Method in class org.apache.activemq.broker.region.TopicSubscription
 
DiscardingDLQBroker - Class in org.apache.activemq.plugin
 
DiscardingDLQBroker(Broker) - Constructor for class org.apache.activemq.plugin.DiscardingDLQBroker
 
DiscardingDLQBrokerPlugin - Class in org.apache.activemq.plugin
 
DiscardingDLQBrokerPlugin() - Constructor for class org.apache.activemq.plugin.DiscardingDLQBrokerPlugin
 
DISCONNECT - Static variable in interface org.apache.activemq.transport.stomp.Stomp.Commands
 
disconnect() - Method in class org.apache.activemq.transport.stomp.StompConnection
 
discoverLoginConfig - Variable in class org.apache.activemq.security.JaasAuthenticationPlugin
 
DISCOVERY_EVENT - Static variable in interface org.apache.activemq.command.CommandTypes
 
DiscoveryAgent - Interface in org.apache.activemq.transport.discovery
An agent used to discover other instances of a service.
DiscoveryAgentFactory - Class in org.apache.activemq.transport.discovery
 
DiscoveryAgentFactory() - Constructor for class org.apache.activemq.transport.discovery.DiscoveryAgentFactory
 
DiscoveryEvent - Class in org.apache.activemq.command
Represents a discovery event containing the details of the service
DiscoveryEvent() - Constructor for class org.apache.activemq.command.DiscoveryEvent
 
DiscoveryEvent(String) - Constructor for class org.apache.activemq.command.DiscoveryEvent
 
DiscoveryEventMarshaller - Class in org.apache.activemq.openwire.v1
Marshalling code for Open Wire Format for DiscoveryEventMarshaller 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.
DiscoveryEventMarshaller() - Constructor for class org.apache.activemq.openwire.v1.DiscoveryEventMarshaller
 
DiscoveryEventMarshaller - Class in org.apache.activemq.openwire.v2
Marshalling code for Open Wire Format for DiscoveryEventMarshaller 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.
DiscoveryEventMarshaller() - Constructor for class org.apache.activemq.openwire.v2.DiscoveryEventMarshaller
 
DiscoveryEventMarshaller - Class in org.apache.activemq.openwire.v3
Marshalling code for Open Wire Format for DiscoveryEventMarshaller 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.
DiscoveryEventMarshaller() - Constructor for class org.apache.activemq.openwire.v3.DiscoveryEventMarshaller
 
DiscoveryListener - Interface in org.apache.activemq.transport.discovery
A listener of services being added or removed from a network
DiscoveryNetworkConnector - Class in org.apache.activemq.network
A network connector which uses a discovery agent to detect the remote brokers available and setup a connection to each available remote broker
DiscoveryNetworkConnector() - Constructor for class org.apache.activemq.network.DiscoveryNetworkConnector
 
DiscoveryNetworkConnector(URI) - Constructor for class org.apache.activemq.network.DiscoveryNetworkConnector
 
DiscoveryTransport - Class in org.apache.activemq.transport.discovery
A ReliableTransportChannel which uses a DiscoveryAgent to discover remote broker instances and dynamically connect to them.
DiscoveryTransport(CompositeTransport) - Constructor for class org.apache.activemq.transport.discovery.DiscoveryTransport
 
DiscoveryTransportFactory - Class in org.apache.activemq.transport.discovery
 
DiscoveryTransportFactory() - Constructor for class org.apache.activemq.transport.discovery.DiscoveryTransportFactory
 
DiskIndexLinkedList - Class in org.apache.activemq.kaha.impl.index
A linked list used by IndexItems
DiskIndexLinkedList(IndexManager, IndexItem) - Constructor for class org.apache.activemq.kaha.impl.index.DiskIndexLinkedList
Constructs an empty list.
dispatch(MessageDispatch) - Method in class org.apache.activemq.ActiveMQConnectionConsumer
 
dispatch(MessageDispatch) - Method in interface org.apache.activemq.ActiveMQDispatcher
 
dispatch(MessageDispatch) - Method in class org.apache.activemq.ActiveMQInputStream
 
dispatch(MessageDispatch) - Method in class org.apache.activemq.ActiveMQMessageConsumer
 
dispatch(MessageDispatch) - Method in class org.apache.activemq.ActiveMQSession
 
dispatch(MessageDispatch) - Method in class org.apache.activemq.AdvisoryConsumer
 
dispatch(MessageReference, MessageEvaluationContext, List<Subscription>) - Method in interface org.apache.activemq.broker.region.policy.DispatchPolicy
Decides how to dispatch a selected message to a collection of consumers.
dispatch(MessageReference, MessageEvaluationContext, List<Subscription>) - Method in class org.apache.activemq.broker.region.policy.RoundRobinDispatchPolicy
 
dispatch(MessageReference, MessageEvaluationContext, List<Subscription>) - Method in class org.apache.activemq.broker.region.policy.SimpleDispatchPolicy
 
dispatch(MessageReference, MessageEvaluationContext, List) - Method in class org.apache.activemq.broker.region.policy.StrictOrderDispatchPolicy
 
dispatch(MessageReference) - Method in class org.apache.activemq.broker.region.PrefetchSubscription
 
dispatch(ConnectionContext, Message) - Method in class org.apache.activemq.broker.region.Topic
 
dispatch(Command) - Method in class org.apache.activemq.broker.TransportConnection
 
dispatchAsync - Variable in class org.apache.activemq.ActiveMQConnection
 
dispatchAsync - Variable in class org.apache.activemq.ActiveMQConnectionFactory
 
dispatchAsync(Command) - Method in interface org.apache.activemq.broker.Connection
Sends a message to the client.
dispatchAsync(Command) - Method in class org.apache.activemq.broker.TransportConnection
 
dispatchAsync - Variable in class org.apache.activemq.command.ConsumerInfo
 
dispatchAsync - Variable in class org.apache.activemq.command.ProducerInfo
 
dispatchCounter - Variable in class org.apache.activemq.broker.region.PrefetchSubscription
 
dispatched - Variable in class org.apache.activemq.broker.region.DestinationStatistics
 
dispatched - Variable in class org.apache.activemq.broker.region.PrefetchSubscription
 
dispatchedCounter - Variable in class org.apache.activemq.broker.region.TopicSubscription
 
dispatchInitialMessage(Message, Destination, ConnectionContext, SubscriptionRecovery) - Method in class org.apache.activemq.broker.region.policy.QueryBasedSubscriptionRecoveryPolicy
 
dispatchPending() - Method in class org.apache.activemq.broker.region.PrefetchSubscription
 
DispatchPolicy - Interface in org.apache.activemq.broker.region.policy
Abstraction to allow different dispatching policies to be plugged into the region implementations.
dispatchQueue - Variable in class org.apache.activemq.broker.TransportConnection
 
DispatchSelector - Interface in org.apache.activemq.broker.region.policy
Determines if a subscription can dispatch a message reference
dispatchStopped - Variable in class org.apache.activemq.broker.TransportConnection
 
dispatchSync(Command) - Method in interface org.apache.activemq.broker.Connection
Sends a message to the client.
dispatchSync(Command) - Method in class org.apache.activemq.broker.TransportConnection
 
dispatchValve - Variable in class org.apache.activemq.broker.region.Topic
 
Disposable - Interface in org.apache.activemq
 
dispose() - Method in class org.apache.activemq.ActiveMQConnectionConsumer
 
dispose() - Method in class org.apache.activemq.ActiveMQInputStream
 
dispose() - Method in class org.apache.activemq.ActiveMQMessageConsumer
 
dispose() - Method in class org.apache.activemq.ActiveMQMessageProducer
 
dispose() - Method in class org.apache.activemq.ActiveMQOutputStream
 
dispose() - Method in class org.apache.activemq.ActiveMQSession
 
dispose() - Method in class org.apache.activemq.AdvisoryConsumer
 
dispose(ConnectionContext, Destination) - Method in class org.apache.activemq.broker.region.AbstractRegion
 
dispose(ConnectionContext, Destination) - Method in class org.apache.activemq.broker.region.AbstractTempRegion
 
dispose(ConnectionContext) - Method in class org.apache.activemq.broker.region.BaseDestination
 
dispose(ConnectionContext) - Method in interface org.apache.activemq.broker.region.Destination
 
dispose(ConnectionContext) - Method in class org.apache.activemq.broker.region.DestinationFilter
 
dispose(ConnectionContext) - Method in class org.apache.activemq.broker.region.Queue
 
dispose(ConnectionContext) - Method in class org.apache.activemq.broker.region.Topic
 
dispose() - Method in interface org.apache.activemq.Disposable
 
dispose() - Method in class org.apache.activemq.kaha.impl.async.ControlFile
 
dispose(Service) - Static method in class org.apache.activemq.util.ServiceSupport
 
disposed - Variable in class org.apache.activemq.network.DemandForwardingBridgeSupport
 
disposed - Variable in class org.apache.activemq.transport.vm.VMTransport
 
divide(Number, Number) - Method in class org.apache.activemq.filter.ArithmeticExpression
 
doAddMessage(Connection, long, String, String, byte[]) - Method in class org.apache.activemq.store.jdbc.adapter.BlobJDBCAdapter
 
doAddMessage(TransactionContext, MessageId, ActiveMQDestination, byte[], long) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
 
doAddMessage(TransactionContext, MessageId, ActiveMQDestination, byte[], long) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
 
doAddMessageReference(TransactionContext, MessageId, ActiveMQDestination, long, String) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
 
doAddMessageReference(TransactionContext, MessageId, ActiveMQDestination, long, String) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
 
doAddRecoveredMessage(MessageReference) - Method in class org.apache.activemq.broker.region.AbstractSubscription
 
doAddRecoveredMessage(MessageReference) - Method in class org.apache.activemq.broker.region.DurableTopicSubscription
 
doAsyncWrite() - Method in class org.apache.activemq.store.amq.AMQMessageStore
 
doBind(URI) - Method in class org.apache.activemq.transport.discovery.DiscoveryTransportFactory
 
doBind(URI) - Method in class org.apache.activemq.transport.failover.FailoverTransportFactory
 
doBind(URI) - Method in class org.apache.activemq.transport.fanout.FanoutTransportFactory
 
doBind(URI) - Method in class org.apache.activemq.transport.mock.MockTransportFactory
 
doBind(URI) - Method in class org.apache.activemq.transport.peer.PeerTransportFactory
 
doBind(URI) - Method in class org.apache.activemq.transport.tcp.SslTransportFactory
Overriding to use SslTransportServer and allow for proper reflection.
doBind(URI) - Method in class org.apache.activemq.transport.tcp.TcpTransportFactory
 
doBind(URI) - Method in class org.apache.activemq.transport.TransportFactory
 
doBind(URI) - Method in class org.apache.activemq.transport.udp.UdpTransportFactory
 
doBind(URI) - Method in class org.apache.activemq.transport.vm.VMTransportFactory
 
doCheckpoint() - Method in class org.apache.activemq.store.amq.AMQPersistenceAdapter
This does the actual checkpoint.
doCheckpoint() - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
This does the actual checkpoint.
doClear() - Method in class org.apache.activemq.kaha.impl.container.BaseContainerImpl
 
doCollection() - Method in class org.apache.activemq.broker.TransportStatusDetector
 
doCollection(TransportConnection) - Method in class org.apache.activemq.broker.TransportStatusDetector
 
doCompositeConnect(URI) - Method in class org.apache.activemq.transport.failover.FailoverTransportFactory
 
doCompositeConnect(URI) - Method in class org.apache.activemq.transport.fanout.FanoutTransportFactory
 
doCompositeConnect(URI) - Method in class org.apache.activemq.transport.mock.MockTransportFactory
 
doCompositeConnect(URI) - Method in class org.apache.activemq.transport.peer.PeerTransportFactory
 
doCompositeConnect(URI, Executor) - Method in class org.apache.activemq.transport.TransportFactory
 
doCompositeConnect(URI) - Method in class org.apache.activemq.transport.TransportFactory
 
doCompositeConnect(URI) - Method in class org.apache.activemq.transport.vm.VMTransportFactory
 
doConnect(URI) - Method in class org.apache.activemq.transport.failover.FailoverTransportFactory
 
doConnect(URI) - Method in class org.apache.activemq.transport.fanout.FanoutTransportFactory
 
doConnect(URI) - Method in class org.apache.activemq.transport.mock.MockTransportFactory
 
doConnect(URI) - Method in class org.apache.activemq.transport.peer.PeerTransportFactory
 
doConnect(URI, Executor) - Method in class org.apache.activemq.transport.TransportFactory
 
doConnect(URI) - Method in class org.apache.activemq.transport.TransportFactory
 
doConnect(URI) - Method in class org.apache.activemq.transport.vm.VMTransportFactory
 
doConsume(Object) - Method in class org.apache.activemq.transport.tcp.SslTransport
Overriding in order to add the client's certificates to ConnectionInfo Commmands.
doConsume(Object) - Method in class org.apache.activemq.transport.TransportSupport
Process the inbound command
doCreateDemandSubscription(ConsumerInfo) - Method in class org.apache.activemq.network.DemandForwardingBridgeSupport
 
doCreateDestination(ConnectionContext, ActiveMQDestination) - Method in class org.apache.activemq.broker.region.AbstractTempRegion
 
doCreateDestination(ConnectionContext, ActiveMQDestination) - Method in class org.apache.activemq.broker.region.TempQueueRegion
 
doCreateDestination(ConnectionContext, ActiveMQDestination) - Method in class org.apache.activemq.broker.region.TempTopicRegion
 
doCreateDiscoveryAgent(URI) - Method in class org.apache.activemq.transport.discovery.DiscoveryAgentFactory
 
doCreateDiscoveryAgent(URI) - Method in class org.apache.activemq.transport.discovery.multicast.MulticastDiscoveryAgentFactory
 
doCreateDiscoveryAgent(URI) - Method in class org.apache.activemq.transport.discovery.rendezvous.RendezvousDiscoveryAgentFactory
 
doCreateDiscoveryAgent(URI) - Method in class org.apache.activemq.transport.discovery.simple.SimpleDiscoveryAgentFactory
 
doCreateTables(TransactionContext) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
 
doCreateTables(TransactionContext) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
 
doDeleteOldMessages(TransactionContext) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
 
doDeleteOldMessages(TransactionContext) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
 
doDeleteSubscription(TransactionContext, ActiveMQDestination, String, String) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
 
doDeleteSubscription(TransactionContext, ActiveMQDestination, String, String) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
 
doDropTables(TransactionContext) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
 
doDropTables(TransactionContext) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
 
doesConsumerExist(ActiveMQDestination) - Method in class org.apache.activemq.network.DurableConduitBridge
 
doesCursorHaveMessagesBuffered() - Method in class org.apache.activemq.broker.jmx.DurableSubscriptionView
 
doesCursorHaveMessagesBuffered() - Method in interface org.apache.activemq.broker.jmx.DurableSubscriptionViewMBean
 
doesCursorHaveMessagesBuffered() - Method in class org.apache.activemq.broker.jmx.QueueView
 
doesCursorHaveMessagesBuffered() - Method in interface org.apache.activemq.broker.jmx.QueueViewMBean
 
doesCursorHaveSpace() - Method in class org.apache.activemq.broker.jmx.DurableSubscriptionView
 
doesCursorHaveSpace() - Method in interface org.apache.activemq.broker.jmx.DurableSubscriptionViewMBean
 
doesCursorHaveSpace() - Method in class org.apache.activemq.broker.jmx.QueueView
 
doesCursorHaveSpace() - Method in interface org.apache.activemq.broker.jmx.QueueViewMBean
 
doesHandleMultipleConnectionStates() - Method in class org.apache.activemq.broker.MapTransportConnectionStateRegister
 
doesHandleMultipleConnectionStates() - Method in class org.apache.activemq.broker.SingleTransportConnectionStateRegister
 
doesHandleMultipleConnectionStates() - Method in interface org.apache.activemq.broker.TransportConnectionStateRegister
 
doesListContainerExist(Object) - Method in class org.apache.activemq.kaha.impl.KahaStore
 
doesListContainerExist(Object, String) - Method in class org.apache.activemq.kaha.impl.KahaStore
 
doesListContainerExist(Object) - Method in interface org.apache.activemq.kaha.Store
Checks if a ListContainer exists in the default container
doesListContainerExist(Object, String) - Method in interface org.apache.activemq.kaha.Store
Checks if a ListContainer exists in the named container
doesMapContainerExist(Object) - Method in class org.apache.activemq.kaha.impl.KahaStore
 
doesMapContainerExist(Object, String) - Method in class org.apache.activemq.kaha.impl.KahaStore
 
doesMapContainerExist(Object) - Method in interface org.apache.activemq.kaha.Store
Checks if a MapContainer exists in the default container
doesMapContainerExist(Object, String) - Method in interface org.apache.activemq.kaha.Store
Checks if a MapContainer exists in the named container
doFillBatch() - Method in class org.apache.activemq.broker.region.cursors.AbstractStoreCursor
 
doFindLogWriterProperties(String) - Method in class org.apache.activemq.util.LogWriterFinder
Given a log writer name, returns a Properties object with a "class" property whose value is a String with the name of the class to be loaded.
doGetAllSubscriptions(TransactionContext, ActiveMQDestination) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
 
doGetAllSubscriptions(TransactionContext, ActiveMQDestination) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
 
doGetDestinations(TransactionContext) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
 
doGetDestinations(TransactionContext) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
 
doGetDurableSubscriberMessageCount(TransactionContext, ActiveMQDestination, String, String) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
 
doGetDurableSubscriberMessageCount(TransactionContext, ActiveMQDestination, String, String) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
 
doGetLastAckedDurableSubscriberMessageId(TransactionContext, ActiveMQDestination, String, String) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
 
doGetLastAckedDurableSubscriberMessageId(TransactionContext, ActiveMQDestination, String, String) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
 
doGetLastMessageBrokerSequenceId(TransactionContext) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
 
doGetLastMessageBrokerSequenceId(TransactionContext) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
 
doGetMessage(TransactionContext, long) - Method in class org.apache.activemq.store.jdbc.adapter.BlobJDBCAdapter
 
doGetMessage(TransactionContext, long) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
 
doGetMessage(TransactionContext, long) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
 
doGetMessageCount(TransactionContext, ActiveMQDestination) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
 
doGetMessageCount(TransactionContext, ActiveMQDestination) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
 
doGetMessageReference(TransactionContext, long) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
 
doGetMessageReference(TransactionContext, long) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
 
doGetNextDurableSubscriberMessageStatement(TransactionContext, ActiveMQDestination, String, String) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
 
doGetSubscriberEntry(TransactionContext, ActiveMQDestination, String, String) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
 
doGetSubscriberEntry(TransactionContext, ActiveMQDestination, String, String) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
 
doHandleReplyTo - Variable in class org.apache.activemq.network.jms.DestinationBridge
 
doLock() - Method in class org.apache.activemq.store.amq.AMQPersistenceAdapter
 
doMark() - Method in class org.apache.activemq.broker.TransportConnection
Mark the Connection, so we can deem if it's collectable on the next sweep
doRecover(TransactionContext, ActiveMQDestination, JDBCMessageRecoveryListener) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
 
doRecover(TransactionContext, ActiveMQDestination, JDBCMessageRecoveryListener) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
 
doRecoverNextMessages(TransactionContext, ActiveMQDestination, String, String, long, int, JDBCMessageRecoveryListener) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
 
doRecoverNextMessages(TransactionContext, ActiveMQDestination, long, int, JDBCMessageRecoveryListener) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
 
doRecoverNextMessages(TransactionContext, ActiveMQDestination, String, String, long, int, JDBCMessageRecoveryListener) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
 
doRecoverNextMessages(TransactionContext, ActiveMQDestination, long, int, JDBCMessageRecoveryListener) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
 
doRecoverSubscription(TransactionContext, ActiveMQDestination, String, String, JDBCMessageRecoveryListener) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
 
doRecoverSubscription(TransactionContext, ActiveMQDestination, String, String, JDBCMessageRecoveryListener) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
 
doRemove(int) - Method in class org.apache.activemq.kaha.impl.container.ListContainerImpl
 
doRemove(int) - Method in interface org.apache.activemq.kaha.ListContainer
remove an objecr from the list without retrieving the old value from the store
doRemoveAllMessages(TransactionContext, ActiveMQDestination) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
 
doRemoveAllMessages(TransactionContext, ActiveMQDestination) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
 
doRemoveMessage(TransactionContext, long) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
 
doRemoveMessage(TransactionContext, long) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
 
doRun() - Method in class org.apache.activemq.transport.tcp.TcpTransport
 
doSetLastAck(TransactionContext, ActiveMQDestination, String, String, long) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
 
doSetLastAck(TransactionContext, ActiveMQDestination, String, String, long) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
 
doSetSubscriberEntry(TransactionContext, SubscriptionInfo, boolean) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
 
doSetSubscriberEntry(TransactionContext, SubscriptionInfo, boolean) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
 
doStart() - Method in class org.apache.activemq.transport.nio.NIOTransport
 
doStart() - Method in class org.apache.activemq.transport.tcp.TcpTransport
 
doStart() - Method in class org.apache.activemq.transport.tcp.TcpTransportServer
 
doStart() - Method in class org.apache.activemq.transport.TransportServerThreadSupport
 
doStart() - Method in class org.apache.activemq.transport.TransportThreadSupport
 
doStart() - Method in class org.apache.activemq.transport.udp.UdpTransport
 
doStart() - Method in class org.apache.activemq.transport.udp.UdpTransportServer
 
doStart() - Method in class org.apache.activemq.util.ServiceSupport
 
doStartTransaction() - Method in class org.apache.activemq.ActiveMQSession
Send TransactionInfo to indicate transaction has started
doStartTransaction() - Method in class org.apache.activemq.ActiveMQXASession
This is called before transacted work is done by the session.
doStop(ServiceStopper) - Method in class org.apache.activemq.broker.jmx.ManagedRegionBroker
 
doStop() - Method in class org.apache.activemq.broker.jmx.ManagedTransportConnection
 
doStop(ServiceStopper) - Method in class org.apache.activemq.broker.region.RegionBroker
 
doStop() - Method in class org.apache.activemq.broker.TransportConnection
 
doStop(ServiceStopper) - Method in class org.apache.activemq.transport.multicast.MulticastTransport
 
doStop(ServiceStopper) - Method in class org.apache.activemq.transport.nio.NIOTransport
 
doStop(ServiceStopper) - Method in class org.apache.activemq.transport.tcp.TcpTransport
 
doStop(ServiceStopper) - Method in class org.apache.activemq.transport.tcp.TcpTransportServer
 
doStop(ServiceStopper) - Method in class org.apache.activemq.transport.TransportServerThreadSupport
 
doStop(ServiceStopper) - Method in class org.apache.activemq.transport.udp.UdpTransport
 
doStop(ServiceStopper) - Method in class org.apache.activemq.transport.udp.UdpTransportServer
 
doStop(ServiceStopper) - Method in class org.apache.activemq.util.ServiceSupport
 
doSweep() - Method in class org.apache.activemq.broker.TransportStatusDetector
 
DotFileInterceptorSupport - Class in org.apache.activemq.broker.view
Useful base class
DotFileInterceptorSupport(Broker, String) - Constructor for class org.apache.activemq.broker.view.DotFileInterceptorSupport
 
DOUBLE - Static variable in class org.apache.activemq.filter.ArithmeticExpression
 
DOUBLE_PROPERTIES - Static variable in interface org.apache.activemq.broker.jmx.CompositeDataConstants