public class JmsTopicSession extends JmsSession implements AutoCloseable
Modifier | Constructor and Description |
---|---|
protected |
JmsTopicSession(JmsConnection connection,
JmsSessionId sessionId,
int acknowledgementMode) |
Modifier and Type | Method and Description |
---|---|
javax.jms.QueueBrowser |
createBrowser(javax.jms.Queue queue) |
javax.jms.QueueBrowser |
createBrowser(javax.jms.Queue queue,
String messageSelector) |
javax.jms.MessageConsumer |
createConsumer(javax.jms.Destination destination) |
javax.jms.MessageConsumer |
createConsumer(javax.jms.Destination destination,
String messageSelector) |
javax.jms.MessageConsumer |
createConsumer(javax.jms.Destination destination,
String messageSelector,
boolean noLocal) |
javax.jms.MessageProducer |
createProducer(javax.jms.Destination destination) |
javax.jms.Queue |
createQueue(String queueName) |
javax.jms.QueueReceiver |
createReceiver(javax.jms.Queue queue) |
javax.jms.QueueReceiver |
createReceiver(javax.jms.Queue queue,
String messageSelector) |
javax.jms.QueueSender |
createSender(javax.jms.Queue queue) |
javax.jms.TemporaryQueue |
createTemporaryQueue() |
add, add, checkClientIDWasSetExplicitly, checkClosed, checkDestination, close, commit, createBytesMessage, createDurableSubscriber, createDurableSubscriber, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createPublisher, createStreamMessage, createSubscriber, createSubscriber, createTemporaryTopic, createTextMessage, createTextMessage, createTopic, doClose, getAcknowledgeMode, getConnection, getMessageListener, getNextConsumerId, getNextProducerId, getPrefetchPolicy, getSessionId, getSessionInfo, getTransacted, getTransactionContext, isAutoAcknowledge, isClientAcknowledge, isClosed, isDupsOkAcknowledge, isStarted, isTransacted, onConnectionInterrupted, onConnectionRecovered, onConnectionRecovery, onConnectionRestored, onException, onException, onInboundMessage, recover, remove, remove, rollback, run, send, setMessageListener, setPrefetchPolicy, setTransactionContext, shutdown, shutdown, start, stop, unsubscribe
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close
protected JmsTopicSession(JmsConnection connection, JmsSessionId sessionId, int acknowledgementMode) throws javax.jms.JMSException
javax.jms.JMSException
public javax.jms.QueueBrowser createBrowser(javax.jms.Queue queue) throws javax.jms.JMSException
createBrowser
in interface javax.jms.QueueSession
createBrowser
in interface javax.jms.Session
createBrowser
in class JmsSession
javax.jms.JMSException
Session.createBrowser(javax.jms.Queue)
public javax.jms.QueueBrowser createBrowser(javax.jms.Queue queue, String messageSelector) throws javax.jms.JMSException
createBrowser
in interface javax.jms.QueueSession
createBrowser
in interface javax.jms.Session
createBrowser
in class JmsSession
javax.jms.JMSException
Session.createBrowser(javax.jms.Queue, java.lang.String)
public javax.jms.MessageConsumer createConsumer(javax.jms.Destination destination) throws javax.jms.JMSException
createConsumer
in interface javax.jms.Session
createConsumer
in class JmsSession
javax.jms.JMSException
Session.createConsumer(javax.jms.Destination)
public javax.jms.MessageConsumer createConsumer(javax.jms.Destination destination, String messageSelector) throws javax.jms.JMSException
createConsumer
in interface javax.jms.Session
createConsumer
in class JmsSession
javax.jms.JMSException
Session.createConsumer(javax.jms.Destination, java.lang.String)
public javax.jms.MessageConsumer createConsumer(javax.jms.Destination destination, String messageSelector, boolean noLocal) throws javax.jms.JMSException
createConsumer
in interface javax.jms.Session
createConsumer
in class JmsSession
javax.jms.JMSException
Session.createConsumer(javax.jms.Destination, java.lang.String)
public javax.jms.MessageProducer createProducer(javax.jms.Destination destination) throws javax.jms.JMSException
createProducer
in interface javax.jms.Session
createProducer
in class JmsSession
javax.jms.JMSException
Session.createProducer(javax.jms.Destination)
public javax.jms.Queue createQueue(String queueName) throws javax.jms.JMSException
createQueue
in interface javax.jms.QueueSession
createQueue
in interface javax.jms.Session
createQueue
in class JmsSession
javax.jms.JMSException
Session.createQueue(java.lang.String)
public javax.jms.TemporaryQueue createTemporaryQueue() throws javax.jms.JMSException
createTemporaryQueue
in interface javax.jms.QueueSession
createTemporaryQueue
in interface javax.jms.Session
createTemporaryQueue
in class JmsSession
javax.jms.JMSException
Session.createTemporaryQueue()
public javax.jms.QueueReceiver createReceiver(javax.jms.Queue queue) throws javax.jms.JMSException
createReceiver
in interface javax.jms.QueueSession
createReceiver
in class JmsSession
javax.jms.JMSException
QueueSession.createReceiver(javax.jms.Queue)
public javax.jms.QueueReceiver createReceiver(javax.jms.Queue queue, String messageSelector) throws javax.jms.JMSException
createReceiver
in interface javax.jms.QueueSession
createReceiver
in class JmsSession
javax.jms.JMSException
QueueSession.createReceiver(javax.jms.Queue, java.lang.String)
public javax.jms.QueueSender createSender(javax.jms.Queue queue) throws javax.jms.JMSException
createSender
in interface javax.jms.QueueSession
createSender
in class JmsSession
javax.jms.JMSException
QueueSession.createSender(javax.jms.Queue)
Copyright © 2013–2016 The Apache Software Foundation. All rights reserved.