|
Joram ${version} | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.objectweb.joram.client.jms.Session
Implements the javax.jms.Session
interface.
Field Summary | |
protected javax.jms.MessageListener |
messageListener
The message listener of the session, if any. |
static java.lang.String |
PENDING_MSG_MAX
|
static java.lang.String |
PENDING_MSG_MIN
|
static java.lang.String |
RECEIVE_ACK
|
static boolean |
receiveAck
|
Fields inherited from interface javax.jms.Session |
AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED |
Method Summary | |
protected void |
addConsumer(MessageConsumer mc)
Called here and by sub-classes. |
protected void |
addProducer(MessageProducer mp)
Called here and by sub-classes. |
protected void |
checkClosed()
Checks if the session is closed. |
void |
close()
API method. |
void |
commit()
API method. |
javax.jms.QueueBrowser |
createBrowser(javax.jms.Queue queue)
API method |
javax.jms.QueueBrowser |
createBrowser(javax.jms.Queue queue,
java.lang.String selector)
API method |
javax.jms.BytesMessage |
createBytesMessage()
API method. |
javax.jms.MessageConsumer |
createConsumer(javax.jms.Destination dest)
API method. |
javax.jms.MessageConsumer |
createConsumer(javax.jms.Destination dest,
java.lang.String selector)
API method. |
javax.jms.MessageConsumer |
createConsumer(javax.jms.Destination dest,
java.lang.String selector,
boolean noLocal)
API method. |
javax.jms.TopicSubscriber |
createDurableSubscriber(javax.jms.Topic topic,
java.lang.String name)
API method. |
javax.jms.TopicSubscriber |
createDurableSubscriber(javax.jms.Topic topic,
java.lang.String name,
java.lang.String selector,
boolean noLocal)
API method. |
javax.jms.MapMessage |
createMapMessage()
API method. |
javax.jms.Message |
createMessage()
API method. |
javax.jms.ObjectMessage |
createObjectMessage()
API method. |
javax.jms.ObjectMessage |
createObjectMessage(java.io.Serializable obj)
API method. |
javax.jms.MessageProducer |
createProducer(javax.jms.Destination dest)
API method. |
javax.jms.Queue |
createQueue(java.lang.String queueName)
API method. |
javax.jms.StreamMessage |
createStreamMessage()
API method. |
javax.jms.TemporaryQueue |
createTemporaryQueue()
API method. |
javax.jms.TemporaryTopic |
createTemporaryTopic()
API method. |
javax.jms.TextMessage |
createTextMessage()
API method. |
javax.jms.TextMessage |
createTextMessage(java.lang.String text)
API method. |
javax.jms.Topic |
createTopic(java.lang.String topicName)
API method. |
int |
getAcknowledgeMode()
API method. |
javax.jms.MessageListener |
getMessageListener()
API method. |
boolean |
getTransacted()
API method. |
boolean |
isAutoAck()
|
void |
recover()
API method. |
void |
rollback()
API method. |
void |
run()
API method. |
void |
setMessageListener(javax.jms.MessageListener messageListener)
API method. |
void |
setTransacted(boolean t)
set transacted. |
java.lang.String |
toString()
Returns a String image of this session. |
void |
unsubscribe(java.lang.String name)
API method. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Field Detail |
public static final java.lang.String RECEIVE_ACK
public static boolean receiveAck
public static final java.lang.String PENDING_MSG_MAX
public static final java.lang.String PENDING_MSG_MIN
protected javax.jms.MessageListener messageListener
Method Detail |
protected void checkClosed() throws javax.jms.IllegalStateException
javax.jms.IllegalStateException
public java.lang.String toString()
public final int getAcknowledgeMode() throws javax.jms.JMSException
getAcknowledgeMode
in interface javax.jms.Session
javax.jms.JMSException
- Actually never thrown.public final boolean getTransacted() throws javax.jms.JMSException
getTransacted
in interface javax.jms.Session
javax.jms.IllegalStateException
- If the session is closed.
javax.jms.JMSException
public void setTransacted(boolean t)
public void setMessageListener(javax.jms.MessageListener messageListener) throws javax.jms.JMSException
setMessageListener
in interface javax.jms.Session
javax.jms.JMSException
- Actually never thrown.public javax.jms.MessageListener getMessageListener() throws javax.jms.JMSException
getMessageListener
in interface javax.jms.Session
javax.jms.JMSException
- Actually never thrown.public javax.jms.Message createMessage() throws javax.jms.JMSException
createMessage
in interface javax.jms.Session
javax.jms.IllegalStateException
- If the session is closed.
javax.jms.JMSException
public javax.jms.TextMessage createTextMessage() throws javax.jms.JMSException
createTextMessage
in interface javax.jms.Session
javax.jms.IllegalStateException
- If the session is closed.
javax.jms.JMSException
public javax.jms.TextMessage createTextMessage(java.lang.String text) throws javax.jms.JMSException
createTextMessage
in interface javax.jms.Session
javax.jms.IllegalStateException
- If the session is closed.
javax.jms.JMSException
public javax.jms.BytesMessage createBytesMessage() throws javax.jms.JMSException
createBytesMessage
in interface javax.jms.Session
javax.jms.IllegalStateException
- If the session is closed.
javax.jms.JMSException
public javax.jms.MapMessage createMapMessage() throws javax.jms.JMSException
createMapMessage
in interface javax.jms.Session
javax.jms.IllegalStateException
- If the session is closed.
javax.jms.JMSException
public javax.jms.ObjectMessage createObjectMessage() throws javax.jms.JMSException
createObjectMessage
in interface javax.jms.Session
javax.jms.IllegalStateException
- If the session is closed.
javax.jms.JMSException
public javax.jms.ObjectMessage createObjectMessage(java.io.Serializable obj) throws javax.jms.JMSException
createObjectMessage
in interface javax.jms.Session
javax.jms.IllegalStateException
- If the session is closed.
javax.jms.JMSException
public javax.jms.StreamMessage createStreamMessage() throws javax.jms.JMSException
createStreamMessage
in interface javax.jms.Session
javax.jms.IllegalStateException
- If the session is closed.
javax.jms.JMSException
public javax.jms.QueueBrowser createBrowser(javax.jms.Queue queue, java.lang.String selector) throws javax.jms.JMSException
createBrowser
in interface javax.jms.Session
javax.jms.IllegalStateException
- If the session is closed.
javax.jms.JMSException
public javax.jms.QueueBrowser createBrowser(javax.jms.Queue queue) throws javax.jms.JMSException
createBrowser
in interface javax.jms.Session
javax.jms.IllegalStateException
- If the session is closed.
javax.jms.JMSException
public javax.jms.MessageProducer createProducer(javax.jms.Destination dest) throws javax.jms.JMSException
createProducer
in interface javax.jms.Session
javax.jms.IllegalStateException
- If the session is closed or if the
connection is broken.
javax.jms.JMSException
- If the creation fails for any other reason.public javax.jms.MessageConsumer createConsumer(javax.jms.Destination dest, java.lang.String selector, boolean noLocal) throws javax.jms.JMSException
createConsumer
in interface javax.jms.Session
javax.jms.IllegalStateException
- If the session is closed or if the
connection is broken.
javax.jms.JMSException
- If the creation fails for any other reason.public javax.jms.MessageConsumer createConsumer(javax.jms.Destination dest, java.lang.String selector) throws javax.jms.JMSException
createConsumer
in interface javax.jms.Session
javax.jms.IllegalStateException
- If the session is closed or if the
connection is broken.
javax.jms.JMSException
- If the creation fails for any other reason.public javax.jms.MessageConsumer createConsumer(javax.jms.Destination dest) throws javax.jms.JMSException
createConsumer
in interface javax.jms.Session
javax.jms.IllegalStateException
- If the session is closed or if the
connection is broken.
javax.jms.JMSException
- If the creation fails for any other reason.public javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic topic, java.lang.String name, java.lang.String selector, boolean noLocal) throws javax.jms.JMSException
createDurableSubscriber
in interface javax.jms.Session
javax.jms.IllegalStateException
- If the session is closed or if the
connection is broken.
javax.jms.JMSException
- If the creation fails for any other reason.public javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic topic, java.lang.String name) throws javax.jms.JMSException
createDurableSubscriber
in interface javax.jms.Session
javax.jms.IllegalStateException
- If the session is closed or if the
connection is broken.
javax.jms.JMSException
- If the creation fails for any other reason.public javax.jms.Queue createQueue(java.lang.String queueName) throws javax.jms.JMSException
createQueue
in interface javax.jms.Session
javax.jms.IllegalStateException
- If the session is closed.
javax.jms.JMSException
public javax.jms.Topic createTopic(java.lang.String topicName) throws javax.jms.JMSException
createTopic
in interface javax.jms.Session
javax.jms.IllegalStateException
- If the session is closed.
javax.jms.JMSException
- If the topic creation failed.public javax.jms.TemporaryQueue createTemporaryQueue() throws javax.jms.JMSException
createTemporaryQueue
in interface javax.jms.Session
javax.jms.IllegalStateException
- If the session is closed or if the
connection is broken.
javax.jms.JMSException
- If the request fails for any other reason.public javax.jms.TemporaryTopic createTemporaryTopic() throws javax.jms.JMSException
createTemporaryTopic
in interface javax.jms.Session
javax.jms.IllegalStateException
- If the session is closed or if the
connection is broken.
javax.jms.JMSException
- If the request fails for any other reason.public void run()
run
in interface javax.jms.Session
public void commit() throws javax.jms.JMSException
commit
in interface javax.jms.Session
javax.jms.IllegalStateException
- If the session is closed, or not
transacted, or if the connection is broken.
javax.jms.JMSException
public void rollback() throws javax.jms.JMSException
rollback
in interface javax.jms.Session
javax.jms.IllegalStateException
- If the session is closed, or not
transacted.
javax.jms.JMSException
public void recover() throws javax.jms.JMSException
recover
in interface javax.jms.Session
javax.jms.IllegalStateException
- If the session is closed, or transacted.
javax.jms.JMSException
public void unsubscribe(java.lang.String name) throws javax.jms.JMSException
unsubscribe
in interface javax.jms.Session
javax.jms.IllegalStateException
- If the session is closed or if the
connection is broken.
InvalidDestinationException
- If the subscription does not
exist.
javax.jms.JMSException
- If the request fails for any other reason.public void close() throws javax.jms.JMSException
close
in interface javax.jms.Session
javax.jms.JMSException
protected void addConsumer(MessageConsumer mc)
protected void addProducer(MessageProducer mp)
public final boolean isAutoAck()
|
Joram ${version} | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |