Docjar: A Java Source and Docuemnt Enginecom.*    java.*    javax.*    org.*    all    new    plug-in

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

A

ARGUMENT_TYPES - Static variable in class org.activemq.XmlConfigHelper
 
ActiveMQConnection - class org.activemq.ActiveMQConnection.
A Connection object is a client's active connection to its JMS provider.
ActiveMQConnection(ActiveMQConnectionFactory, String, String, TransportChannel) - Constructor for class org.activemq.ActiveMQConnection
Constructs a connection from an existing TransportChannel and user/password.
ActiveMQConnection(ActiveMQConnectionFactory, String, String) - Constructor for class org.activemq.ActiveMQConnection
 
ActiveMQConnectionConsumer - class org.activemq.ActiveMQConnectionConsumer.
For application servers, Connection objects provide a special facility for creating a ConnectionConsumer (optional).
ActiveMQConnectionConsumer(ActiveMQConnection, ServerSessionPool, ConsumerInfo, int) - Constructor for class org.activemq.ActiveMQConnectionConsumer
Create a ConnectionConsumer
ActiveMQConnectionFactory - class org.activemq.ActiveMQConnectionFactory.
A ConnectionFactory is an an Administed object, and is used for creating Connections.
ActiveMQConnectionFactory() - Constructor for class org.activemq.ActiveMQConnectionFactory
Default Constructor for ActiveMQConnectionFactory
ActiveMQConnectionFactory(String) - Constructor for class org.activemq.ActiveMQConnectionFactory
 
ActiveMQConnectionFactory(String, String, String) - Constructor for class org.activemq.ActiveMQConnectionFactory
 
ActiveMQConnectionFactory(BrokerContainer) - Constructor for class org.activemq.ActiveMQConnectionFactory
Constructs a javax.jms.ConnectionFactory with an already configured and started org.activemq.broker.BrokerContainer ready for use in embedded mode.
ActiveMQConnectionFactory(BrokerContainer, String) - Constructor for class org.activemq.ActiveMQConnectionFactory
Constructs a javax.jms.ConnectionFactory with an already configured and started org.activemq.broker.BrokerContainer ready for use in embedded mode and the brokerURL connection.
ActiveMQConnectionMetaData - class org.activemq.ActiveMQConnectionMetaData.
A ConnectionMetaData object provides information describing the Connection object.
ActiveMQConnectionMetaData() - Constructor for class org.activemq.ActiveMQConnectionMetaData
 
ActiveMQMessageAudit - class org.activemq.ActiveMQMessageAudit.
Provides basic audit functions for Messages
ActiveMQMessageAudit() - Constructor for class org.activemq.ActiveMQMessageAudit
Default Constructor windowSize = 1024, maximumNumberOfProducersToTrack = 128
ActiveMQMessageAudit(int, int) - Constructor for class org.activemq.ActiveMQMessageAudit
Construct a MessageAudit
ActiveMQMessageAuditTest - class org.activemq.ActiveMQMessageAuditTest.
ActiveMQMessageAuditTest
ActiveMQMessageAuditTest(String) - Constructor for class org.activemq.ActiveMQMessageAuditTest
Constructor for ActiveMQMessageAuditTest.
ActiveMQMessageConsumer - class org.activemq.ActiveMQMessageConsumer.
A client uses a MessageConsumer object to receive messages from a destination.
ActiveMQMessageConsumer(ActiveMQSession, ActiveMQDestination, String, String, int, int, boolean, boolean) - Constructor for class org.activemq.ActiveMQMessageConsumer
Create a MessageConsumer
ActiveMQMessageDispatcher - interface org.activemq.ActiveMQMessageDispatcher.
An internal dispatcher for ActiveMQMessage types
ActiveMQMessageProducer - class org.activemq.ActiveMQMessageProducer.
A client uses a MessageProducer object to send messages to a destination.
ActiveMQMessageProducer(ActiveMQSession, ActiveMQDestination) - Constructor for class org.activemq.ActiveMQMessageProducer
 
ActiveMQMessageTransformation - class org.activemq.ActiveMQMessageTransformation.
Transforms foreign Destinations and Messages to ActiveMQ formats
ActiveMQMessageTransformation() - Constructor for class org.activemq.ActiveMQMessageTransformation
 
ActiveMQPrefetchPolicy - class org.activemq.ActiveMQPrefetchPolicy.
Defines the pretech message policies for different types of consumers
ActiveMQPrefetchPolicy() - Constructor for class org.activemq.ActiveMQPrefetchPolicy
Initialize default prefetch policies
ActiveMQQueueBrowser - class org.activemq.ActiveMQQueueBrowser.
A client uses a QueueBrowser object to look at messages on a queue without removing them.
ActiveMQQueueBrowser(ActiveMQSession, ActiveMQQueue, String, int) - Constructor for class org.activemq.ActiveMQQueueBrowser
Constructor for an ActiveMQQueueBrowser - used internally
ActiveMQQueueReceiver - class org.activemq.ActiveMQQueueReceiver.
A client uses a QueueReceiver object to receive messages that have been delivered to a queue.
ActiveMQQueueReceiver(ActiveMQSession, ActiveMQDestination, String, int, int) - Constructor for class org.activemq.ActiveMQQueueReceiver
 
ActiveMQQueueSender - class org.activemq.ActiveMQQueueSender.
A client uses a QueueSender object to send messages to a queue.
ActiveMQQueueSender(ActiveMQSession, ActiveMQDestination) - Constructor for class org.activemq.ActiveMQQueueSender
 
ActiveMQQueueSession - class org.activemq.ActiveMQQueueSession.
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.activemq.ActiveMQQueueSession
 
ActiveMQSession - class org.activemq.ActiveMQSession.
A Session object is a single-threaded context for producing and consuming messages.
ActiveMQSession(ActiveMQConnection, int) - Constructor for class org.activemq.ActiveMQSession
Construct the Session
ActiveMQSession(ActiveMQConnection, int, boolean) - Constructor for class org.activemq.ActiveMQSession
Construct the Session
ActiveMQSession.DeliveryListener - interface org.activemq.ActiveMQSession.DeliveryListener.
 
ActiveMQSessionExecutor - class org.activemq.ActiveMQSessionExecutor.
A utility class used by the Session for dispatching messages asynchronously to consumers
ActiveMQSessionExecutor(ActiveMQSession, MemoryBoundedQueue) - Constructor for class org.activemq.ActiveMQSessionExecutor
 
ActiveMQTopicPublisher - class org.activemq.ActiveMQTopicPublisher.
A client uses a TopicPublisher object to publish messages on a topic.
ActiveMQTopicPublisher(ActiveMQSession, ActiveMQDestination) - Constructor for class org.activemq.ActiveMQTopicPublisher
 
ActiveMQTopicSession - class org.activemq.ActiveMQTopicSession.
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.activemq.ActiveMQTopicSession
 
ActiveMQTopicSubscriber - class org.activemq.ActiveMQTopicSubscriber.
A client uses a TopicSubscriber object to receive messages that have been published to a topic.
ActiveMQTopicSubscriber(ActiveMQSession, ActiveMQDestination, String, String, int, int, boolean, boolean) - Constructor for class org.activemq.ActiveMQTopicSubscriber
 
ActiveMQXAConnection - class org.activemq.ActiveMQXAConnection.
The XAConnection interface extends the capability of Connection by providing an XASession (optional).
ActiveMQXAConnection(ActiveMQConnectionFactory, String, String, TransportChannel) - Constructor for class org.activemq.ActiveMQXAConnection
 
ActiveMQXAConnection(ActiveMQConnectionFactory, String, String) - Constructor for class org.activemq.ActiveMQXAConnection
 
ActiveMQXAConnectionFactory - class org.activemq.ActiveMQXAConnectionFactory.
The XAConnectionFactory interface is a base interface for the XAQueueConnectionFactory and XATopicConnectionFactory interfaces.
ActiveMQXAConnectionFactory() - Constructor for class org.activemq.ActiveMQXAConnectionFactory
 
ActiveMQXAConnectionFactory(String) - Constructor for class org.activemq.ActiveMQXAConnectionFactory
 
ActiveMQXAConnectionFactory(String, String, String) - Constructor for class org.activemq.ActiveMQXAConnectionFactory
 
ActiveMQXAConnectionFactory(BrokerContainer) - Constructor for class org.activemq.ActiveMQXAConnectionFactory
 
ActiveMQXAConnectionFactory(BrokerContainer, String) - Constructor for class org.activemq.ActiveMQXAConnectionFactory
 
ActiveMQXASession - class org.activemq.ActiveMQXASession.
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, int) - Constructor for class org.activemq.ActiveMQXASession
 
AlreadyClosedException - exception org.activemq.AlreadyClosedException.
An exception which is closed if you try to access a resource which has already been closed
AlreadyClosedException() - Constructor for class org.activemq.AlreadyClosedException
 
AlreadyClosedException(String) - Constructor for class org.activemq.AlreadyClosedException
 
accessThread - Variable in class org.activemq.ActiveMQMessageConsumer
 
acknowledge(ActiveMQMessage) - Method in class org.activemq.ActiveMQSession
Acknowledges all consumed messages of the session of this consumed message.
acknowledgeMode - Variable in class org.activemq.ActiveMQSession
 
activeXid - Variable in class org.activemq.TransactionContext
 
addConnectionConsumer(ActiveMQConnectionConsumer) - Method in class org.activemq.ActiveMQConnection
Add a ConnectionConsumer
addConsumer(ActiveMQMessageConsumer) - Method in class org.activemq.ActiveMQSession
 
addMessageDispatcher(ActiveMQMessageDispatcher) - Method in class org.activemq.ActiveMQConnection
Add a Message dispatcher to receive messages from the Broker
addProducer(ActiveMQMessageProducer) - Method in class org.activemq.ActiveMQSession
 
addSession(ActiveMQSession) - Method in class org.activemq.ActiveMQConnection
Used internally for adding Sessions to the Connection
addSession(ActiveMQSession) - Method in class org.activemq.TransactionContext
 
addToTransientConsumedRedeliverCache(ActiveMQMessage) - Method in class org.activemq.ActiveMQConnection
 
afterDelivery(ActiveMQSession, Message) - Method in interface org.activemq.ActiveMQSession.DeliveryListener
 
afterMessageDelivered(ActiveMQMessage, boolean, boolean, boolean) - Method in class org.activemq.ActiveMQMessageConsumer
 
afterMessageDelivered(boolean, ActiveMQMessage, boolean, boolean, boolean) - Method in class org.activemq.ActiveMQSession
 
assembleMessage(ActiveMQMessage) - Method in class org.activemq.ActiveMQConnection
 
assemblies - Variable in class org.activemq.ActiveMQConnection
 
assertMessagesAreReceived() - Method in class org.activemq.JmsSendReceiveTestSupport
 
assertMessagesReceivedAreValid(List) - Method in class org.activemq.JmsSendReceiveTestSupport
 
assertReceiveEquals(JmsDurableSubscriptionTest.Topics, String) - Method in class org.activemq.JmsDurableSubscriptionTest
 
assertTextMessagesEqual(String, Message[], Message[]) - Method in class org.activemq.TestSupport
 
associatedXid - Variable in class org.activemq.TransactionContext
 
asyncSendPacket(Packet) - Method in class org.activemq.ActiveMQConnection
send a Packet through the Connection - for internal use only
asyncSendPacket(Packet, boolean) - Method in class org.activemq.ActiveMQConnection
send a Packet through the Connection - for internal use only

B

BrokerAdminCommandsTest - class org.activemq.BrokerAdminCommandsTest.
 
BrokerAdminCommandsTest() - Constructor for class org.activemq.BrokerAdminCommandsTest
 
beforeDelivery(ActiveMQSession, Message) - Method in interface org.activemq.ActiveMQSession.DeliveryListener
 
beforeMessageDelivered(ActiveMQMessage) - Method in class org.activemq.ActiveMQMessageConsumer
 
beforeMessageDelivered(ActiveMQMessage) - Method in class org.activemq.ActiveMQSession
 
begin() - Method in class org.activemq.TransactionContext
Start a local transaction.
beginEvent() - Method in interface org.activemq.LocalTransactionEventListener
 
boundedQueueManager - Variable in class org.activemq.ActiveMQConnection
 
broker - Variable in class org.activemq.LargeMessageTestSupport
 
brokerContainer - Variable in class org.activemq.ActiveMQConnectionFactory
 
brokerContainerFactory - Variable in class org.activemq.ActiveMQConnectionFactory
 
brokerContext - Variable in class org.activemq.ActiveMQConnectionFactory
 
brokerName - Variable in class org.activemq.ActiveMQConnectionFactory
 
brokerURL - Variable in class org.activemq.ActiveMQConnectionFactory
 
brokerXmlConfig - Variable in class org.activemq.ActiveMQConnectionFactory
 
browser - Variable in class org.activemq.ActiveMQMessageConsumer
 
buildFromProperties(Properties) - Method in class org.activemq.ActiveMQConnectionFactory
Set the properties that will represent the instance in JNDI

C

CONSUMER_DISPATCH_ASYNC - Static variable in class org.activemq.ActiveMQSession
 
CONSUMER_DISPATCH_SYNC - Static variable in class org.activemq.ActiveMQSession
 
CONSUMER_DISPATCH_UNSET - Static variable in class org.activemq.ActiveMQSession
 
Closeable - interface org.activemq.Closeable.
Provides a uniform interface that can be used to close all the JMS obejcts that provide a close() method.
CompressionMessageTest - class org.activemq.CompressionMessageTest.
 
CompressionMessageTest() - Constructor for class org.activemq.CompressionMessageTest
 
ConfigurationException - exception org.activemq.ConfigurationException.
An exception thrown when a service is not correctly configured
ConfigurationException(String) - Constructor for class org.activemq.ConfigurationException
 
ConnectionCleanupTest - class org.activemq.ConnectionCleanupTest.
 
ConnectionCleanupTest() - Constructor for class org.activemq.ConnectionCleanupTest
 
ConnectionClosedException - exception org.activemq.ConnectionClosedException.
An exception thrown when attempt is made to use a connection when the connection has been closed.
ConnectionClosedException() - Constructor for class org.activemq.ConnectionClosedException
 
ConsumerReceiveWithTimeoutTest - class org.activemq.ConsumerReceiveWithTimeoutTest.
 
ConsumerReceiveWithTimeoutTest() - Constructor for class org.activemq.ConsumerReceiveWithTimeoutTest
 
cachingEnabled - Variable in class org.activemq.ActiveMQConnection
 
cachingEnabled - Variable in class org.activemq.ActiveMQConnectionFactory
 
capacityChanged(CapacityMonitorEvent) - Method in class org.activemq.ActiveMQConnection
CapacityMonitorEventListener implementation called when the capacity of a CapacityService changes
changeUserInfo(String, String) - Method in class org.activemq.ActiveMQConnection
Changes the associated username/password that is associated with this connection.
checkClientIDWasManuallySpecified() - Method in class org.activemq.ActiveMQConnection
Ensures that the clientID was manually specified and not auto-generated.
checkClosed() - Method in class org.activemq.ActiveMQConnection
simply throws an exception if the Connection is already closed
checkClosed() - Method in class org.activemq.ActiveMQMessageConsumer
 
checkClosed() - Method in class org.activemq.ActiveMQMessageProducer
 
checkClosed() - Method in class org.activemq.ActiveMQQueueBrowser
 
checkClosed() - Method in class org.activemq.ActiveMQSession
 
cleanup() - Method in class org.activemq.ActiveMQConnection
Cleans up this connection so that it's state is as if the connection was just created.
clear() - Method in class org.activemq.ActiveMQSessionExecutor
 
clearDeliveredMessages() - Method in class org.activemq.ActiveMQSession
 
clearMessagesInProgress() - Method in class org.activemq.ActiveMQConnection
 
clearMessagesInProgress() - Method in class org.activemq.ActiveMQMessageConsumer
 
clearMessagesInProgress() - Method in class org.activemq.ActiveMQSession
 
clearMessagesInProgress() - Method in class org.activemq.ActiveMQSessionExecutor
 
clientConnection - Variable in class org.activemq.JmsTopicRequestReplyTest
 
clientID - Variable in class org.activemq.ActiveMQConnection
 
clientID - Variable in class org.activemq.ActiveMQConnectionFactory
 
clientID - Variable in class org.activemq.DuplicateDurableSubscriptionException
 
clientIDSet - Variable in class org.activemq.ActiveMQConnection
 
clientIdGenerator - Variable in class org.activemq.ActiveMQConnection
 
clientSideClientID - Variable in class org.activemq.JmsTopicRequestReplyTest
 
close() - Method in class org.activemq.ActiveMQConnection
Closes the connection.
close() - Method in class org.activemq.ActiveMQConnectionConsumer
Closes the connection consumer.
close() - Method in class org.activemq.ActiveMQMessageConsumer
Closes the message consumer.
close() - Method in class org.activemq.ActiveMQMessageProducer
Closes the message producer.
close() - Method in class org.activemq.ActiveMQQueueBrowser
 
close() - Method in class org.activemq.ActiveMQQueueSession
 
close() - Method in class org.activemq.ActiveMQSession
Closes the session.
close() - Method in class org.activemq.ActiveMQSessionExecutor
 
close() - Method in class org.activemq.ActiveMQTopicSession
 
close() - Method in interface org.activemq.Closeable
Closes a JMS object.
close() - Method in class org.activemq.JmsDurableSubscriptionTest.Topics
 
closeTemporaryDestinations() - Method in class org.activemq.ActiveMQConnection
 
closed - Variable in class org.activemq.ActiveMQConnection
 
closed - Variable in class org.activemq.ActiveMQConnectionConsumer
 
closed - Variable in class org.activemq.ActiveMQMessageConsumer
 
closed - Variable in class org.activemq.ActiveMQMessageProducer
 
closed - Variable in class org.activemq.ActiveMQQueueBrowser
 
closed - Variable in class org.activemq.ActiveMQSession
 
closed - Variable in class org.activemq.ActiveMQSessionExecutor
 
cnum - Variable in class org.activemq.ActiveMQQueueBrowser
 
commit() - Method in class org.activemq.ActiveMQQueueSession
 
commit() - Method in class org.activemq.ActiveMQSession
Commits all messages done in this transaction and releases any locks currently held.
commit() - Method in class org.activemq.ActiveMQTopicSession
 
commit() - Method in class org.activemq.ActiveMQXASession
 
commit() - Method in class org.activemq.TransactionContext
Commits all messages done in this transaction and releases any locks currently held.
commit(Xid, boolean) - Method in class org.activemq.TransactionContext
 
commitEvent() - Method in interface org.activemq.LocalTransactionEventListener
 
compression - Variable in class org.activemq.ActiveMQSession
 
connection - Variable in class org.activemq.ActiveMQConnectionConsumer
 
connection - Variable in class org.activemq.ActiveMQSession
 
connection - Variable in class org.activemq.BrokerAdminCommandsTest
 
connection - Variable in class org.activemq.ConnectionCleanupTest
 
connection - Variable in class org.activemq.ConsumerReceiveWithTimeoutTest
 
connection - Variable in class org.activemq.JmsClientAckTest
 
connection - Variable in class org.activemq.JmsCreateConsumerInOnMessageTest
 
connection - Variable in class org.activemq.JmsDurableSubscriptionTest.Topics
 
connection - Variable in class org.activemq.JmsRedeliveredTest
 
connection - Variable in class org.activemq.JmsSessionRecoverTest
 
connection - Variable in class org.activemq.JmsTempDestinationTest
 
connection - Variable in class org.activemq.JmsTopicSendReceiveTest
 
connection - Variable in class org.activemq.JmsTransactionTestSupport
 
connection - Variable in class org.activemq.TransactionContext
 
connectionConsumers - Variable in class org.activemq.ActiveMQConnection
 
connectionCount - Variable in class org.activemq.ActiveMQConnectionFactory
 
connectionFactory - Variable in class org.activemq.JmsTransactionTestSupport
 
connectionFactory - Variable in class org.activemq.TestSupport
 
connectionMetaData - Variable in class org.activemq.ActiveMQConnection
 
consume(Packet) - Method in class org.activemq.ActiveMQConnection
Implementation of the PacketListener interface - consume a packet
consumeMessage(Message, List) - Method in class org.activemq.JmsSendReceiveTestSupport
 
consumer - Variable in class org.activemq.ActiveMQQueueBrowser
 
consumer - Variable in class org.activemq.JmsCreateConsumerInOnMessageTest
 
consumer - Variable in class org.activemq.JmsDurableSubscriptionTest.Topics
 
consumer - Variable in class org.activemq.JmsSendReceiveTestSupport
 
consumer - Variable in class org.activemq.JmsTransactionTestSupport
 
consumer - Variable in class org.activemq.LargeMessageTestSupport
 
consumerConnection - Variable in class org.activemq.LargeMessageTestSupport
 
consumerDestination - Variable in class org.activemq.JmsSendReceiveTestSupport
 
consumerDispatchState - Variable in class org.activemq.ActiveMQSession
 
consumerIdentifier - Variable in class org.activemq.ActiveMQMessageConsumer
 
consumerInfo - Variable in class org.activemq.ActiveMQConnectionConsumer
 
consumerName - Variable in class org.activemq.ActiveMQMessageConsumer
 
consumerName - Variable in class org.activemq.DuplicateDurableSubscriptionException
 
consumerNumber - Variable in class org.activemq.ActiveMQMessageConsumer
 
consumerNumberGenerator - Variable in class org.activemq.ActiveMQConnection
 
consumerSession - Variable in class org.activemq.JmsCreateConsumerInOnMessageTest
 
consumerSession - Variable in class org.activemq.LargeMessageTestSupport
 
consumers - Variable in class org.activemq.ActiveMQSession
 
copyMessageOnSend - Variable in class org.activemq.ActiveMQConnection
 
copyMessageOnSend - Variable in class org.activemq.ActiveMQConnectionFactory
 
createActiveMQXAConnection(String, String) - Method in class org.activemq.ActiveMQXAConnectionFactory
 
createBrokerConnector(String) - Method in class org.activemq.ActiveMQConnectionFactory
 
createBrokerContainerFactory() - Method in class org.activemq.ActiveMQConnectionFactory
 
createBrokerContainerFactory(String) - Static method in class org.activemq.XmlConfigHelper
Creates an instance of the broker factory which uses the Spring XML configuration file mechanism.
createBrowser(Queue) - Method in class org.activemq.ActiveMQQueueSession
 
createBrowser(Queue, String) - Method in class org.activemq.ActiveMQQueueSession
 
createBrowser(Queue) - Method in class org.activemq.ActiveMQSession
Creates a QueueBrowser object to peek at the messages on the specified queue.
createBrowser(Queue, String) - Method in class org.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.activemq.ActiveMQTopicSession
 
createBrowser(Queue, String) - Method in class org.activemq.ActiveMQTopicSession
 
createBytesMessage() - Method in class org.activemq.ActiveMQQueueSession
 
createBytesMessage() - Method in class org.activemq.ActiveMQSession
Creates a BytesMessage object.
createBytesMessage() - Method in class org.activemq.ActiveMQTopicSession
 
createConcurrentList() - Method in class org.activemq.JmsSendReceiveTestSupport
 
createConnection() - Method in class org.activemq.ActiveMQConnectionFactory
Create a JMS Connection
createConnection(String, String) - Method in class org.activemq.ActiveMQConnectionFactory
 
createConnection() - Method in class org.activemq.ActiveMQXAConnectionFactory
 
createConnection(String, String) - Method in class org.activemq.ActiveMQXAConnectionFactory
 
createConnection() - Method in class org.activemq.ConsumerReceiveWithTimeoutTest
 
createConnection() - Method in class org.activemq.JmsClientAckTest
 
createConnection() - Method in class org.activemq.JmsRedeliveredTest
 
createConnection() - Method in class org.activemq.TestSupport
Factory method to create a new connection
createConnectionConsumer(Destination, String, ServerSessionPool, int) - Method in class org.activemq.ActiveMQConnection
Creates a connection consumer for this connection (optional operation).
createConnectionConsumer(Destination, String, ServerSessionPool, int, boolean) - Method in class org.activemq.ActiveMQConnection
Creates a connection consumer for this connection (optional operation).
createConnectionConsumer(Topic, String, ServerSessionPool, int) - Method in class org.activemq.ActiveMQConnection
Creates a connection consumer for this connection (optional operation).
createConnectionConsumer(Queue, String, ServerSessionPool, int) - Method in class org.activemq.ActiveMQConnection
Creates a connection consumer for this connection (optional operation).
createConnectionFactory() - Method in class org.activemq.CompressionMessageTest
 
createConnectionFactory() - Method in class org.activemq.FragmentPersistentQueueTest
 
createConnectionFactory() - Method in class org.activemq.FragmentTopicTest
 
createConnectionFactory() - Method in class org.activemq.FragmentTransientQueueTest
 
createConnectionFactory() - Method in class org.activemq.JmsTopicSendReceiveWithTwoConnectionsTest
 
createConnectionFactory() - Method in class org.activemq.JmsXAResourceProvider
 
createConnectionFactory() - Method in class org.activemq.LargeMessageTestSupport
 
createConnectionFactory() - Method in class org.activemq.TestSupport
 
createConsumer() - Method in class org.activemq.ActiveMQQueueBrowser
 
createConsumer(Destination) - Method in class org.activemq.ActiveMQQueueSession
 
createConsumer(Destination, String) - Method in class org.activemq.ActiveMQQueueSession
 
createConsumer(Destination, String, boolean) - Method in class org.activemq.ActiveMQQueueSession
 
createConsumer(Destination) - Method in class org.activemq.ActiveMQSession
Creates a MessageConsumer for the specified destination.
createConsumer(Destination, String) - Method in class org.activemq.ActiveMQSession
Creates a MessageConsumer for the specified destination, using a message selector.
createConsumer(Destination, String, boolean) - Method in class org.activemq.ActiveMQSession
Creates MessageConsumer for the specified destination, using a message selector.
createConsumer(Destination) - Method in class org.activemq.ActiveMQTopicSession
 
createConsumer(Destination, String) - Method in class org.activemq.ActiveMQTopicSession
 
createConsumer(Destination, String, boolean) - Method in class org.activemq.ActiveMQTopicSession
 
createConsumer() - Method in class org.activemq.JmsTopicSendReceiveSubscriberTest
 
createConsumer() - Method in class org.activemq.JmsTopicSendReceiveTest
 
createConsumer() - Method in class org.activemq.LargeMessageTestSupport
 
createConsumerInfo(ActiveMQMessageConsumer) - Method in class org.activemq.ActiveMQSession
 
createDestination(Session) - Method in class org.activemq.JmsTopicRequestReplyTest
 
createDestination() - Method in class org.activemq.LargeMessageTestSupport
 
createDestination(String) - Method in class org.activemq.TestSupport
 
createDurableConnectionConsumer(Topic, String, String, ServerSessionPool, int) - Method in class org.activemq.ActiveMQConnection
Create a durable connection consumer for this connection (optional operation).
createDurableConnectionConsumer(Topic, String, String, ServerSessionPool, int, boolean) - Method in class org.activemq.ActiveMQConnection
Create a durable connection consumer for this connection (optional operation).
createDurableSubscriber(Topic, String) - Method in class org.activemq.ActiveMQQueueSession
 
createDurableSubscriber(Topic, String, String, boolean) - Method in class org.activemq.ActiveMQQueueSession
 
createDurableSubscriber(Topic, String) - Method in class org.activemq.ActiveMQSession
Creates a durable subscriber to the specified topic.
createDurableSubscriber(Topic, String, String, boolean) - Method in class org.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.activemq.ActiveMQTopicSession
 
createDurableSubscriber(Topic, String, String, boolean) - Method in class org.activemq.ActiveMQTopicSession
 
createMapMessage() - Method in class org.activemq.ActiveMQQueueSession
 
createMapMessage() - Method in class org.activemq.ActiveMQSession
Creates a MapMessage object.
createMapMessage() - Method in class org.activemq.ActiveMQTopicSession
 
createMessage() - Method in class org.activemq.ActiveMQQueueSession
 
createMessage() - Method in class org.activemq.ActiveMQSession
Creates a Message object.
createMessage() - Method in class org.activemq.ActiveMQTopicSession
 
createMessage() - Method in class org.activemq.TestSupport
 
createMulticastClientID() - Method in class org.activemq.ActiveMQConnectionFactory
Creates the clientID for the multicast client (used to dispatch local messages over a multicast bus)
createObjectMessage() - Method in class org.activemq.ActiveMQQueueSession
 
createObjectMessage(Serializable) - Method in class org.activemq.ActiveMQQueueSession
 
createObjectMessage() - Method in class org.activemq.ActiveMQSession
Creates an ObjectMessage object.
createObjectMessage(Serializable) - Method in class org.activemq.ActiveMQSession
Creates an initialized ObjectMessage object.
createObjectMessage() - Method in class org.activemq.ActiveMQTopicSession
 
createObjectMessage(Serializable) - Method in class org.activemq.ActiveMQTopicSession
 
createProducer(Destination) - Method in class org.activemq.ActiveMQQueueSession
 
createProducer(Destination) - Method in class org.activemq.ActiveMQSession
Creates a MessageProducer to send messages to the specified destination.
createProducer(Destination) - Method in class org.activemq.ActiveMQTopicSession
 
createProducer(Session, Destination) - Method in class org.activemq.JmsRedeliveredTest
 
createProducerInfo(ActiveMQMessageProducer) - Method in class org.activemq.ActiveMQSession
 
createPublisher(Topic) - Method in class org.activemq.ActiveMQSession
Creates a publisher for the specified topic.
createPublisher(Topic) - Method in class org.activemq.ActiveMQTopicSession
 
createQueue(String) - Method in class org.activemq.ActiveMQQueueSession
 
createQueue(String) - Method in class org.activemq.ActiveMQSession
Creates a queue identity given a Queue name.
createQueue(String) - Method in class org.activemq.ActiveMQTopicSession
 
createQueueConnection() - Method in class org.activemq.ActiveMQConnectionFactory
Create a JMS QueueConnection
createQueueConnection(String, String) - Method in class org.activemq.ActiveMQConnectionFactory
 
createQueueConnection() - Method in class org.activemq.ActiveMQXAConnectionFactory
 
createQueueConnection(String, String) - Method in class org.activemq.ActiveMQXAConnectionFactory
 
createQueueSession(boolean, int) - Method in class org.activemq.ActiveMQConnection
Creates a QueueSession object.
createReceiveConnection() - Method in class org.activemq.JmsTopicSendReceiveWithTwoConnectionsTest
 
createReceiver(Queue) - Method in class org.activemq.ActiveMQQueueSession
 
createReceiver(Queue, String) - Method in class org.activemq.ActiveMQQueueSession
 
createReceiver(Queue) - Method in class org.activemq.ActiveMQSession
Creates a QueueReceiver object to receive messages from the specified queue.
createReceiver(Queue, String) - Method in class org.activemq.ActiveMQSession
Creates a QueueReceiver object to receive messages from the specified queue using a message selector.
createSendConnection() - Method in class org.activemq.JmsTopicSendReceiveWithTwoConnectionsTest
 
createSender(Queue) - Method in class org.activemq.ActiveMQQueueSession
 
createSender(Queue) - Method in class org.activemq.ActiveMQSession
Creates a QueueSender object to send messages to the specified queue.
createSession(boolean, int) - Method in class org.activemq.ActiveMQConnection
Creates a Session object.
createSession(boolean, int, boolean) - Method in class org.activemq.ActiveMQConnection
Creates a Session object.
createSession(boolean, int) - Method in class org.activemq.ActiveMQXAConnection
 
createSessionInfo(ActiveMQSession) - Method in class org.activemq.ActiveMQConnection
 
createStreamMessage() - Method in class org.activemq.ActiveMQQueueSession
 
createStreamMessage() - Method in class org.activemq.ActiveMQSession
Creates a StreamMessage object.
createStreamMessage() - Method in class org.activemq.ActiveMQTopicSession
 
createSubscriber(Topic) - Method in class org.activemq.ActiveMQSession
Creates a nondurable subscriber to the specified topic.
createSubscriber(Topic, String, boolean) - Method in class org.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.activemq.ActiveMQTopicSession
 
createSubscriber(Topic, String, boolean) - Method in class org.activemq.ActiveMQTopicSession
 
createTemporaryDestination(Session) - Method in class org.activemq.JmsTopicRequestReplyTest
 
createTemporaryQueue() - Method in class org.activemq.ActiveMQQueueSession
 
createTemporaryQueue() - Method in class org.activemq.ActiveMQSession
Creates a TemporaryQueue object.
createTemporaryQueue() - Method in class org.activemq.ActiveMQTopicSession
 
createTemporaryTopic() - Method in class org.activemq.ActiveMQQueueSession
 
createTemporaryTopic() - Method in class org.activemq.ActiveMQSession
Creates a TemporaryTopic object.
createTemporaryTopic() - Method in class org.activemq.ActiveMQTopicSession
 
createTextMessage() - Method in class org.activemq.ActiveMQQueueSession
 
createTextMessage(String) - Method in class org.activemq.ActiveMQQueueSession
 
createTextMessage() - Method in class org.activemq.ActiveMQSession
Creates a TextMessage object.
createTextMessage(String) - Method in class org.activemq.ActiveMQSession
Creates an initialized TextMessage object.
createTextMessage() - Method in class org.activemq.ActiveMQTopicSession
 
createTextMessage(String) - Method in class org.activemq.ActiveMQTopicSession
 
createTextMessage(Session) - Method in class org.activemq.JmsRedeliveredTest
 
createTopic(String) - Method in class org.activemq.ActiveMQQueueSession
 
createTopic(String) - Method in class org.activemq.ActiveMQSession
Creates a topic identity given a Topic name.
createTopic(String) - Method in class org.activemq.ActiveMQTopicSession
 
createTopicConnection() - Method in class org.activemq.ActiveMQConnectionFactory
Create a JMS TopicConnection
createTopicConnection(String, String) - Method in class org.activemq.ActiveMQConnectionFactory
 
createTopicConnection() - Method in class org.activemq.ActiveMQXAConnectionFactory
 
createTopicConnection(String, String) - Method in class org.activemq.ActiveMQXAConnectionFactory
 
createTopicSession(boolean, int) - Method in class org.activemq.ActiveMQConnection
Creates a TopicSession object.
createTransportChannel(String) - Method in class org.activemq.ActiveMQConnectionFactory
Factory method to create a TransportChannel from a URL
createURI(String, URI) - Method in class org.activemq.ActiveMQConnectionFactory
 
createURI(String) - Method in class org.activemq.ActiveMQConnectionFactory
 
createXAConnection() - Method in class org.activemq.ActiveMQXAConnectionFactory
 
createXAConnection(String, String) - Method in class org.activemq.ActiveMQXAConnectionFactory
 
createXAQueueConnection() - Method in class org.activemq.ActiveMQXAConnectionFactory
 
createXAQueueConnection(String, String) - Method in class org.activemq.ActiveMQXAConnectionFactory
 
createXAQueueSession() - Method in class org.activemq.ActiveMQXAConnection
 
createXASession() - Method in class org.activemq.ActiveMQXAConnection
 
createXATopicConnection() - Method in class org.activemq.ActiveMQXAConnectionFactory
 
createXATopicConnection(String, String) - Method in class org.activemq.ActiveMQXAConnectionFactory
 
createXATopicSession() - Method in class org.activemq.ActiveMQXAConnection
 

D

DEFAULT_BROKER_URL - Static variable in class org.activemq.ActiveMQConnection
Default URL for the ActiveMQ Broker
DEFAULT_CONNECTION_MEMORY_LIMIT - Static variable in class org.activemq.ActiveMQConnection
 
DEFAULT_PASSWORD - Static variable in class org.activemq.ActiveMQConnection
Default Password for the Connection
DEFAULT_URL - Static variable in class org.activemq.ActiveMQConnection
Default client URL.
DEFAULT_USER - Static variable in class org.activemq.ActiveMQConnection
Default UserName for the Connection
DEFAULT_WINDOW_SIZE - Static variable in class org.activemq.ActiveMQMessageAudit
 
DuplicateDurableSubscriptionException - exception org.activemq.DuplicateDurableSubscriptionException.
There is only meant to be a single durable subscription open for a given clientID and subscriber name; this exception is thrown if a user tries to subscribe twice for the same clientID and subscriber name.
DuplicateDurableSubscriptionException(ConsumerInfo) - Constructor for class org.activemq.DuplicateDurableSubscriptionException
 
data - Variable in class org.activemq.JmsSendReceiveTestSupport
 
defaultBroker - Variable in class org.activemq.LargeMessageTestSupport
 
defaultDeliveryMode - Variable in class org.activemq.ActiveMQMessageProducer
 
defaultDestination - Variable in class org.activemq.ActiveMQMessageProducer
 
defaultPriority - Variable in class org.activemq.ActiveMQMessageProducer
 
defaultTimeToLive - Variable in class org.activemq.ActiveMQMessageProducer
 
deliver(ActiveMQMessage) - Method in class org.activemq.ActiveMQSession
Delivers a message to the messageListern
deliveredMessages - Variable in class org.activemq.ActiveMQSession
 
deliveryListener - Variable in class org.activemq.ActiveMQSession
 
deliveryMode - Variable in class org.activemq.JmsSendReceiveTestSupport
 
deliveryMode - Variable in class org.activemq.LargeMessageTestSupport
 
dequeueNoWait() - Method in class org.activemq.ActiveMQSessionExecutor
 
dest - Variable in class org.activemq.JmsSessionRecoverTest
 
destination - Variable in class org.activemq.ActiveMQMessageConsumer
 
destination - Variable in class org.activemq.ActiveMQQueueBrowser
 
destination - Variable in class org.activemq.JmsDurableSubscriptionTest.Topics
 
destination - Variable in class org.activemq.JmsTopicRequestorTest
 
destination - Variable in class org.activemq.JmsTransactionTestSupport
 
destination - Variable in class org.activemq.LargeMessageTestSupport
 
destroyConsumer() - Method in class org.activemq.ActiveMQQueueBrowser
 
destroyDestination(ActiveMQDestination) - Method in class org.activemq.ActiveMQConnection
Tells the broker to destroy a destination.
determineResourceManagerId() - Method in class org.activemq.ActiveMQConnection
Get's the resource manager id.
disableMessageID - Variable in class org.activemq.ActiveMQMessageProducer
 
disableMessageTimestamp - Variable in class org.activemq.ActiveMQMessageProducer
 
disableTimeStampsByDefault - Variable in class org.activemq.ActiveMQConnection
 
disableTimeStampsByDefault - Variable in class org.activemq.ActiveMQConnectionFactory
 
dispatch(ActiveMQMessage) - Method in class org.activemq.ActiveMQConnectionConsumer
Dispatch an ActiveMQMessage
dispatch(ActiveMQMessage) - Method in interface org.activemq.ActiveMQMessageDispatcher
Dispatch an ActiveMQMessage
dispatch(ActiveMQMessage) - Method in class org.activemq.ActiveMQSession
Dispatch an ActiveMQMessage
dispatch(ActiveMQMessage) - Method in class org.activemq.ActiveMQSessionExecutor
 
dispatchToQueue(ActiveMQMessage) - Method in class org.activemq.ActiveMQConnectionConsumer
 
dispatchToSession(ActiveMQMessage) - Method in class org.activemq.ActiveMQConnectionConsumer
 
dispatchedBySessionPool - Variable in class org.activemq.ActiveMQSessionExecutor
 
doAcknowledge(boolean) - Method in class org.activemq.ActiveMQSession
 
doClose() - Method in class org.activemq.ActiveMQSession
 
doMessageCompression - Variable in class org.activemq.ActiveMQConnection
 
doMessageCompression - Variable in class org.activemq.ActiveMQConnectionFactory
 
doMessageFragmentation - Variable in class org.activemq.ActiveMQConnection
 
doMessageFragmentation - Variable in class org.activemq.ActiveMQConnectionFactory
 
doReconnect() - Method in class org.activemq.ActiveMQConnection
 
doSendMessageAck(ActiveMQMessage, boolean, boolean) - Method in class org.activemq.ActiveMQSession
 
doStartTransaction() - Method in class org.activemq.ActiveMQSession
Send TransactionInfo to indicate transaction has started
doStartTransaction() - Method in class org.activemq.ActiveMQXASession
This is called before transacted work is done by the session.
doTestAsynchRecover() - Method in class org.activemq.JmsSessionRecoverTest
Test to make sure that a Async recover works.
doTestAsynchRecoverWithAutoAck() - Method in class org.activemq.JmsSessionRecoverTest
Test to make sure that a Async recover works when using AUTO_ACKNOWLEDGE.
doTestSynchRecover() - Method in class org.activemq.JmsSessionRecoverTest
Test to make sure that a Sync recover works.
durable - Variable in class org.activemq.JmsSendReceiveTestSupport
 
durableTopicPrefetch - Variable in class org.activemq.ActiveMQPrefetchPo