| Package | Description |
|---|---|
| org.apache.activemq |
The core JMS client API implementation classes.
|
| org.apache.activemq.camel |
Defines a JMS client which is capable of sending and receiving messages to
Apache Camel
endpoints to provide
Enterprise Integration Patterns
integration in any JMS client application.
|
| org.apache.activemq.pool |
A JMS provider which pools Connection, Session and MessageProducer instances so it can be used with tools like
Spring's JmsTemplate.
|
| org.apache.activemq.ra |
JCA managed connections and resource adapters for working with ActiveMQ
|
| Modifier and Type | Class and Description |
|---|---|
class |
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).
|
| Modifier and Type | Field and Description |
|---|---|
protected ActiveMQSession |
ActiveMQMessageProducerSupport.session |
protected ActiveMQSession |
ActiveMQMessageConsumer.session |
| Modifier and Type | Method and Description |
|---|---|
protected void |
ActiveMQConnection.addSession(ActiveMQSession session)
Used internally for adding Sessions to the Connection
|
void |
ActiveMQSession.DeliveryListener.afterDelivery(ActiveMQSession session,
javax.jms.Message msg) |
void |
ActiveMQSession.DeliveryListener.beforeDelivery(ActiveMQSession session,
javax.jms.Message msg) |
javax.jms.MessageConsumer |
CustomDestination.createConsumer(ActiveMQSession session,
java.lang.String messageSelector) |
javax.jms.MessageConsumer |
CustomDestination.createConsumer(ActiveMQSession session,
java.lang.String messageSelector,
boolean noLocal) |
javax.jms.TopicSubscriber |
CustomDestination.createDurableSubscriber(ActiveMQSession session,
java.lang.String name,
java.lang.String messageSelector,
boolean noLocal) |
javax.jms.MessageProducer |
CustomDestination.createProducer(ActiveMQSession session) |
javax.jms.TopicPublisher |
CustomDestination.createPublisher(ActiveMQSession session) |
javax.jms.QueueReceiver |
CustomDestination.createReceiver(ActiveMQSession session,
java.lang.String messageSelector) |
javax.jms.QueueSender |
CustomDestination.createSender(ActiveMQSession session) |
javax.jms.TopicSubscriber |
CustomDestination.createSubscriber(ActiveMQSession session,
java.lang.String messageSelector,
boolean noLocal) |
protected void |
ActiveMQConnection.removeSession(ActiveMQSession session)
Used interanlly for removing Sessions from a Connection
|
| Constructor and Description |
|---|
ActiveMQMessageConsumer(ActiveMQSession session,
ConsumerId consumerId,
ActiveMQDestination dest,
java.lang.String name,
java.lang.String selector,
int prefetch,
int maximumPendingMessageCount,
boolean noLocal,
boolean browser,
boolean dispatchAsync,
javax.jms.MessageListener messageListener)
Create a MessageConsumer
|
ActiveMQMessageProducer(ActiveMQSession session,
ProducerId producerId,
ActiveMQDestination destination,
int sendTimeout) |
ActiveMQMessageProducerSupport(ActiveMQSession session) |
ActiveMQQueueBrowser(ActiveMQSession session,
ConsumerId consumerId,
ActiveMQDestination destination,
java.lang.String selector,
boolean dispatchAsync)
Constructor for an ActiveMQQueueBrowser - used internally
|
ActiveMQQueueReceiver(ActiveMQSession theSession,
ConsumerId consumerId,
ActiveMQDestination destination,
java.lang.String selector,
int prefetch,
int maximumPendingMessageCount,
boolean asyncDispatch) |
ActiveMQQueueSender(ActiveMQSession session,
ActiveMQDestination destination,
int sendTimeout) |
ActiveMQTopicPublisher(ActiveMQSession session,
ActiveMQDestination destination,
int sendTimeout) |
ActiveMQTopicSubscriber(ActiveMQSession theSession,
ConsumerId consumerId,
ActiveMQDestination dest,
java.lang.String name,
java.lang.String selector,
int prefetch,
int maximumPendingMessageCount,
boolean noLocalValue,
boolean browserValue,
boolean asyncDispatch) |
| Modifier and Type | Method and Description |
|---|---|
ActiveMQSession |
CamelMessageConsumer.getSession() |
| Modifier and Type | Method and Description |
|---|---|
javax.jms.MessageConsumer |
CamelDestination.createConsumer(ActiveMQSession session,
java.lang.String messageSelector) |
javax.jms.MessageConsumer |
CamelDestination.createConsumer(ActiveMQSession session,
java.lang.String messageSelector,
boolean noLocal) |
javax.jms.TopicSubscriber |
CamelTopic.createDurableSubscriber(ActiveMQSession session,
java.lang.String name,
java.lang.String messageSelector,
boolean noLocal) |
javax.jms.TopicSubscriber |
CamelDestination.createDurableSubscriber(ActiveMQSession session,
java.lang.String name,
java.lang.String messageSelector,
boolean noLocal) |
javax.jms.MessageProducer |
CamelDestination.createProducer(ActiveMQSession session) |
javax.jms.TopicPublisher |
CamelTopic.createPublisher(ActiveMQSession session) |
javax.jms.TopicPublisher |
CamelDestination.createPublisher(ActiveMQSession session) |
javax.jms.QueueReceiver |
CamelQueue.createReceiver(ActiveMQSession session,
java.lang.String messageSelector) |
javax.jms.QueueReceiver |
CamelDestination.createReceiver(ActiveMQSession session,
java.lang.String messageSelector) |
javax.jms.QueueSender |
CamelQueue.createSender(ActiveMQSession session) |
javax.jms.QueueSender |
CamelDestination.createSender(ActiveMQSession session) |
javax.jms.TopicSubscriber |
CamelDestination.createSubscriber(ActiveMQSession session,
java.lang.String messageSelector,
boolean noLocal) |
protected org.apache.camel.CamelContext |
CamelDestination.resolveCamelContext(ActiveMQSession session) |
protected org.apache.camel.Endpoint |
CamelDestination.resolveEndpoint(ActiveMQSession session)
Resolves the Camel Endpoint for this destination
|
| Constructor and Description |
|---|
CamelMessageConsumer(CamelDestination destination,
org.apache.camel.Endpoint endpoint,
ActiveMQSession session,
java.lang.String messageSelector,
boolean noLocal) |
CamelMessageProducer(CamelDestination destination,
org.apache.camel.Endpoint endpoint,
ActiveMQSession session) |
CamelQueueReceiver(CamelQueue destination,
org.apache.camel.Endpoint endpoint,
ActiveMQSession session,
java.lang.String name) |
CamelQueueSender(CamelQueue destination,
org.apache.camel.Endpoint endpoint,
ActiveMQSession session) |
CamelTopicPublisher(CamelTopic destination,
org.apache.camel.Endpoint endpoint,
ActiveMQSession session) |
CamelTopicSubscriber(CamelTopic destination,
org.apache.camel.Endpoint endpoint,
ActiveMQSession session,
java.lang.String name,
java.lang.String messageSelector,
boolean noLocal) |
| Modifier and Type | Method and Description |
|---|---|
protected ActiveMQSession |
PooledConnection.createSession(SessionKey key) |
ActiveMQSession |
PooledSession.getInternalSession() |
| Constructor and Description |
|---|
PooledSession(SessionKey key,
ActiveMQSession session,
org.apache.commons.pool.KeyedObjectPool<SessionKey,PooledSession> sessionPool) |
| Modifier and Type | Method and Description |
|---|---|
void |
ServerSessionImpl.afterDelivery(ActiveMQSession session,
javax.jms.Message msg)
The ActiveMQSession's run method will call back to this method after
dispactching a message to the MessageListener.
|
void |
ServerSessionImpl.beforeDelivery(ActiveMQSession session,
javax.jms.Message msg)
The ActiveMQSession's run method will call back to this method before
dispactching a message to the MessageListener.
|
| Constructor and Description |
|---|
ManagedSessionProxy(ActiveMQSession session,
ManagedConnectionProxy connectionProxy) |
ServerSessionImpl(ServerSessionPoolImpl pool,
ActiveMQSession session,
javax.resource.spi.work.WorkManager workManager,
javax.resource.spi.endpoint.MessageEndpoint endpoint,
boolean useRAManagedTx,
int batchSize) |
Copyright © 2005-2013 Red Hat, Inc.. All Rights Reserved.