Package | Description |
---|---|
org.apache.activemq |
The core JMS client API implementation classes.
|
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 CopyOnWriteArrayList<ActiveMQSession> |
ActiveMQConnection.getSessions() |
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,
Message msg) |
void |
ActiveMQSession.DeliveryListener.beforeDelivery(ActiveMQSession session,
Message msg) |
MessageConsumer |
CustomDestination.createConsumer(ActiveMQSession session,
String messageSelector) |
MessageConsumer |
CustomDestination.createConsumer(ActiveMQSession session,
String messageSelector,
boolean noLocal) |
TopicSubscriber |
CustomDestination.createDurableSubscriber(ActiveMQSession session,
String name,
String messageSelector,
boolean noLocal) |
MessageProducer |
CustomDestination.createProducer(ActiveMQSession session) |
TopicPublisher |
CustomDestination.createPublisher(ActiveMQSession session) |
QueueReceiver |
CustomDestination.createReceiver(ActiveMQSession session,
String messageSelector) |
QueueSender |
CustomDestination.createSender(ActiveMQSession session) |
TopicSubscriber |
CustomDestination.createSubscriber(ActiveMQSession session,
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,
String name,
String selector,
int prefetch,
int maximumPendingMessageCount,
boolean noLocal,
boolean browser,
boolean dispatchAsync,
MessageListener messageListener)
Create a MessageConsumer
|
ActiveMQMessageProducer(ActiveMQSession session,
ProducerId producerId,
ActiveMQDestination destination,
int sendTimeout) |
ActiveMQMessageProducerSupport(ActiveMQSession session) |
ActiveMQQueueBrowser(ActiveMQSession session,
ConsumerId consumerId,
ActiveMQDestination destination,
String selector,
boolean dispatchAsync)
Constructor for an ActiveMQQueueBrowser - used internally
|
ActiveMQQueueReceiver(ActiveMQSession theSession,
ConsumerId consumerId,
ActiveMQDestination destination,
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,
String name,
String selector,
int prefetch,
int maximumPendingMessageCount,
boolean noLocalValue,
boolean browserValue,
boolean asyncDispatch) |
Copyright © 2005–2016 FuseSource, Corp.. All rights reserved.