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
JMSException
public MessageProducer createProducer(Destination destination) throws JMSException
JMSException
public MessageConsumer createDurableConsumer(Topic topic, java.lang.String name) throws JMSException
JMSException
public MessageConsumer createDurableConsumer(Topic topic, java.lang.String name, java.lang.String messageSelector, boolean noLocal) throws JMSException
JMSException
public MessageConsumer createSharedConsumer(Topic topic, java.lang.String sharedSubscriptionName) throws JMSException
JMSException
public MessageConsumer createSharedConsumer(Topic topic, java.lang.String sharedSubscriptionName, java.lang.String messageSelector) throws JMSException
JMSException
public MessageConsumer createSharedDurableConsumer(Topic topic, java.lang.String name) throws JMSException
JMSException
public MessageConsumer createSharedDurableConsumer(Topic topic, java.lang.String name, java.lang.String messageSelector) throws JMSException
JMSException