|
|||||||||
| Home >> All >> org >> [ activemq overview ] | PREV NEXT | ||||||||
A
- ARGUMENT_TYPES - Static variable in class org.activemq.XmlConfigHelper
- ActiveMQConnection - class org.activemq.ActiveMQConnection.
- A
Connectionobject 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,
Connectionobjects provide a special facility for creating aConnectionConsumer(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
ConnectionMetaDataobject provides information describing theConnectionobject. - 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
MessageConsumerobject 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
MessageProducerobject 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
QueueBrowserobject 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
QueueReceiverobject 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
QueueSenderobject 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
Sessionobject 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
TopicPublisherobject 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
TopicSubscriberobject 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
QueueBrowserobject to peek at the messages on the specified queue. - createBrowser(Queue, String) - Method in class org.activemq.ActiveMQSession
- Creates a
QueueBrowserobject 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
BytesMessageobject. - 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
MessageConsumerfor the specified destination. - createConsumer(Destination, String) - Method in class org.activemq.ActiveMQSession
- Creates a
MessageConsumerfor the specified destination, using a message selector. - createConsumer(Destination, String, boolean) - Method in class org.activemq.ActiveMQSession
- Creates
MessageConsumerfor 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
MapMessageobject. - createMapMessage() - Method in class org.activemq.ActiveMQTopicSession
- createMessage() - Method in class org.activemq.ActiveMQQueueSession
- createMessage() - Method in class org.activemq.ActiveMQSession
- Creates a
Messageobject. - 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
ObjectMessageobject. - createObjectMessage(Serializable) - Method in class org.activemq.ActiveMQSession
- Creates an initialized
ObjectMessageobject. - 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
MessageProducerto 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
Queuename. - 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
QueueSessionobject. - 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
QueueReceiverobject to receive messages from the specified queue. - createReceiver(Queue, String) - Method in class org.activemq.ActiveMQSession
- Creates a
QueueReceiverobject 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
QueueSenderobject to send messages to the specified queue. - createSession(boolean, int) - Method in class org.activemq.ActiveMQConnection
- Creates a
Sessionobject. - createSession(boolean, int, boolean) - Method in class org.activemq.ActiveMQConnection
- Creates a
Sessionobject. - 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
StreamMessageobject. - 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
TemporaryQueueobject. - createTemporaryQueue() - Method in class org.activemq.ActiveMQTopicSession
- createTemporaryTopic() - Method in class org.activemq.ActiveMQQueueSession
- createTemporaryTopic() - Method in class org.activemq.ActiveMQSession
- Creates a
TemporaryTopicobject. - 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
TextMessageobject. - createTextMessage(String) - Method in class org.activemq.ActiveMQSession
- Creates an initialized
TextMessageobject. - 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
Topicname. - 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
TopicSessionobject. - 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