|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.caucho.jms.connection.JmsSession
com.caucho.jms.connection.TopicSessionImpl
public class TopicSessionImpl
A sample topic session. Lets the client create topics, browsers, etc.
Field Summary |
---|
Fields inherited from class com.caucho.jms.connection.JmsSession |
---|
L, log |
Fields inherited from interface javax.jms.Session |
---|
AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED |
Fields inherited from interface javax.transaction.xa.XAResource |
---|
TMENDRSCAN, TMFAIL, TMJOIN, TMNOFLAGS, TMONEPHASE, TMRESUME, TMSTARTRSCAN, TMSUCCESS, TMSUSPEND, XA_OK, XA_RDONLY |
Constructor Summary | |
---|---|
TopicSessionImpl(ConnectionImpl conn,
boolean isTransacted,
int ackMode,
boolean isXA)
|
Method Summary | |
---|---|
QueueBrowser |
createBrowser(Queue queue)
Creates a QueueBrowser to browse messages in the queue. |
QueueBrowser |
createBrowser(Queue queue,
java.lang.String messageSelector)
Creates a QueueBrowser to browse messages in the queue. |
TopicPublisher |
createPublisher(Topic topic)
Creates a TopicSender to send messages to a topic. |
Queue |
createQueue(java.lang.String queueName)
Creates a new queue. |
TopicSubscriber |
createSubscriber(Topic topic)
Creates a subscriber to receive messages. |
TopicSubscriber |
createSubscriber(Topic topic,
java.lang.String messageSelector,
boolean noLocal)
Creates a subscriber to receive messages. |
TemporaryQueue |
createTemporaryQueue()
Creates a temporary queue. |
TopicSession |
getTopicSession()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Methods inherited from interface javax.jms.XASession |
---|
commit, getSession, getTransacted, getXAResource, rollback |
Methods inherited from interface javax.jms.TopicSession |
---|
createDurableSubscriber, createDurableSubscriber, createTemporaryTopic, createTopic, unsubscribe |
Constructor Detail |
---|
public TopicSessionImpl(ConnectionImpl conn, boolean isTransacted, int ackMode, boolean isXA) throws JMSException
JMSException
Method Detail |
---|
public TopicPublisher createPublisher(Topic topic) throws JMSException
createPublisher
in interface TopicSession
topic
- the topic to send messages to.
JMSException
public TopicSubscriber createSubscriber(Topic topic) throws JMSException
createSubscriber
in interface TopicSession
topic
- the topic to receive messages from.
JMSException
public TopicSubscriber createSubscriber(Topic topic, java.lang.String messageSelector, boolean noLocal) throws JMSException
createSubscriber
in interface TopicSession
topic
- the topic to receive messages from.messageSelector
- topic to restrict the messages.noLocal
- if true, don't receive messages we've sent
JMSException
public QueueBrowser createBrowser(Queue queue) throws JMSException
createBrowser
in interface Session
createBrowser
in class JmsSession
queue
- the queue to send messages to.
JMSException
public QueueBrowser createBrowser(Queue queue, java.lang.String messageSelector) throws JMSException
createBrowser
in interface Session
createBrowser
in class JmsSession
queue
- the queue to send messages to.
JMSException
public Queue createQueue(java.lang.String queueName) throws JMSException
createQueue
in interface Session
createQueue
in class JmsSession
JMSException
public TemporaryQueue createTemporaryQueue() throws JMSException
createTemporaryQueue
in interface Session
createTemporaryQueue
in class JmsSession
JMSException
public TopicSession getTopicSession()
getTopicSession
in interface XATopicSession
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |