|
||||||||||
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.QueueSessionImpl
public class QueueSessionImpl
A sample queue session. Lets the client create queues, 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 | |
---|---|
QueueSessionImpl(ConnectionImpl connection,
boolean isTransacted,
int ackMode,
boolean isXA)
Creates the session |
Method Summary | |
---|---|
TopicSubscriber |
createDurableSubscriber(Topic topic,
java.lang.String name)
Creates a durable subscriber to receive messages. |
TopicSubscriber |
createDurableSubscriber(Topic topic,
java.lang.String name,
java.lang.String messageSelector,
boolean noLocal)
Creates a subscriber to receive messages. |
QueueReceiver |
createReceiver(Queue queue)
Creates a receiver to receive messages. |
QueueReceiver |
createReceiver(Queue queue,
java.lang.String messageSelector)
Creates a receiver to receive messages. |
QueueSender |
createSender(Queue queue)
Creates a QueueSender to send messages to a queue. |
TemporaryTopic |
createTemporaryTopic()
Creates a temporary topic. |
Topic |
createTopic(java.lang.String topicName)
Creates a new topic. |
QueueSession |
getQueueSession()
|
void |
unsubscribe(java.lang.String name)
Unsubscribe from a durable subscription. |
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.Session |
---|
close, createBrowser, createBrowser, createBytesMessage, createConsumer, createConsumer, createConsumer, createMapMessage, createMessage, createObjectMessage, createObjectMessage, createProducer, createQueue, createStreamMessage, createTemporaryQueue, createTextMessage, createTextMessage, getAcknowledgeMode, getMessageListener, recover, run, setMessageListener |
Methods inherited from interface javax.jms.QueueSession |
---|
createBrowser, createBrowser, createQueue, createTemporaryQueue |
Constructor Detail |
---|
public QueueSessionImpl(ConnectionImpl connection, boolean isTransacted, int ackMode, boolean isXA) throws JMSException
JMSException
Method Detail |
---|
public QueueReceiver createReceiver(Queue queue) throws JMSException
createReceiver
in interface QueueSession
queue
- the queue to receive messages from.
JMSException
public QueueReceiver createReceiver(Queue queue, java.lang.String messageSelector) throws JMSException
createReceiver
in interface QueueSession
queue
- the queue to receive messages from.messageSelector
- query to restrict the messages.
JMSException
public QueueSender createSender(Queue queue) throws JMSException
createSender
in interface QueueSession
queue
- the queue to send messages to.
JMSException
public Topic createTopic(java.lang.String topicName) throws JMSException
createTopic
in interface Session
createTopic
in class JmsSession
JMSException
public TemporaryTopic createTemporaryTopic() throws JMSException
createTemporaryTopic
in interface Session
createTemporaryTopic
in class JmsSession
JMSException
public TopicSubscriber createDurableSubscriber(Topic topic, java.lang.String name) throws JMSException
createDurableSubscriber
in interface Session
createDurableSubscriber
in class JmsSession
topic
- the topic to receive messages from.
JMSException
public TopicSubscriber createDurableSubscriber(Topic topic, java.lang.String name, java.lang.String messageSelector, boolean noLocal) throws JMSException
createDurableSubscriber
in interface Session
createDurableSubscriber
in class JmsSession
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 void unsubscribe(java.lang.String name) throws JMSException
unsubscribe
in interface Session
unsubscribe
in class JmsSession
JMSException
public QueueSession getQueueSession()
getQueueSession
in interface XAQueueSession
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |