public class TomEESession
extends ActiveMQSession
| Constructor and Description |
|---|
TomEESession(ActiveMQConnection connection,
SessionId sessionId,
int acknowledgeMode,
boolean asyncDispatch,
boolean sessionAsyncDispatch) |
| Modifier and Type | Method and Description |
|---|---|
MessageConsumer |
createDurableConsumer(Topic topic,
java.lang.String name) |
MessageConsumer |
createDurableConsumer(Topic topic,
java.lang.String name,
java.lang.String messageSelector,
boolean noLocal) |
MessageProducer |
createProducer(Destination destination) |
MessageConsumer |
createSharedConsumer(Topic topic,
java.lang.String sharedSubscriptionName) |
MessageConsumer |
createSharedConsumer(Topic topic,
java.lang.String sharedSubscriptionName,
java.lang.String messageSelector) |
MessageConsumer |
createSharedDurableConsumer(Topic topic,
java.lang.String name) |
MessageConsumer |
createSharedDurableConsumer(Topic topic,
java.lang.String name,
java.lang.String messageSelector) |
public TomEESession(ActiveMQConnection connection,
SessionId sessionId,
int acknowledgeMode,
boolean asyncDispatch,
boolean sessionAsyncDispatch)
throws JMSException
JMSExceptionpublic MessageProducer createProducer(Destination destination)
throws JMSException
JMSExceptionpublic MessageConsumer createDurableConsumer(Topic topic,
java.lang.String name)
throws JMSException
JMSExceptionpublic MessageConsumer createDurableConsumer(Topic topic,
java.lang.String name,
java.lang.String messageSelector,
boolean noLocal)
throws JMSException
JMSExceptionpublic MessageConsumer createSharedConsumer(Topic topic,
java.lang.String sharedSubscriptionName)
throws JMSException
JMSExceptionpublic MessageConsumer createSharedConsumer(Topic topic,
java.lang.String sharedSubscriptionName,
java.lang.String messageSelector)
throws JMSException
JMSExceptionpublic MessageConsumer createSharedDurableConsumer(Topic topic,
java.lang.String name)
throws JMSException
JMSExceptionpublic MessageConsumer createSharedDurableConsumer(Topic topic,
java.lang.String name,
java.lang.String messageSelector)
throws JMSException
JMSException