|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use ActiveMQSession | |
---|---|
org.apache.activemq | The core JMS client API implementation classes. |
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 |
Uses of ActiveMQSession in org.apache.activemq |
---|
Subclasses of ActiveMQSession in org.apache.activemq | |
---|---|
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). |
Fields in org.apache.activemq declared as ActiveMQSession | |
---|---|
protected ActiveMQSession |
ActiveMQMessageProducerSupport.session
|
protected ActiveMQSession |
ActiveMQMessageConsumer.session
|
Methods in org.apache.activemq with parameters of type ActiveMQSession | |
---|---|
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 |
Constructors in org.apache.activemq with parameters of type ActiveMQSession | |
---|---|
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)
|
Uses of ActiveMQSession in org.apache.activemq.pool |
---|
Methods in org.apache.activemq.pool that return ActiveMQSession | |
---|---|
protected ActiveMQSession |
SessionPool.createSession()
|
protected ActiveMQSession |
PooledConnection.createSession(SessionKey key)
|
ActiveMQSession |
PooledSession.getInternalSession()
|
Constructors in org.apache.activemq.pool with parameters of type ActiveMQSession | |
---|---|
PooledSession(ActiveMQSession aSession,
SessionPool sessionPool)
|
Uses of ActiveMQSession in org.apache.activemq.ra |
---|
Methods in org.apache.activemq.ra with parameters of type ActiveMQSession | |
---|---|
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. |
Constructors in org.apache.activemq.ra with parameters of type ActiveMQSession | |
---|---|
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)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |