|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.jboss.messaging.ra.JBMSession
public class JBMSession
A joint interface for JMS sessions
Field Summary |
---|
Fields inherited from interface javax.jms.Session |
---|
AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED |
Fields inherited from interface javax.jms.Session |
---|
AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED |
Fields inherited from interface javax.jms.Session |
---|
AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED |
Fields inherited from interface javax.jms.Session |
---|
AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED |
Fields inherited from interface javax.jms.Session |
---|
AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED |
Fields inherited from interface javax.jms.Session |
---|
AUTO_ACKNOWLEDGE, CLIENT_ACKNOWLEDGE, DUPS_OK_ACKNOWLEDGE, SESSION_TRANSACTED |
Constructor Summary | |
---|---|
JBMSession(JBMManagedConnection mc,
JBMConnectionRequestInfo cri)
Constructor |
Method Summary | |
---|---|
void |
close()
Closes the session. |
void |
commit()
Commit |
javax.jms.QueueBrowser |
createBrowser(javax.jms.Queue queue)
Create a browser |
javax.jms.QueueBrowser |
createBrowser(javax.jms.Queue queue,
java.lang.String messageSelector)
Create a browser |
javax.jms.BytesMessage |
createBytesMessage()
Create a bytes message |
javax.jms.MessageConsumer |
createConsumer(javax.jms.Destination destination)
Create a message consumer |
javax.jms.MessageConsumer |
createConsumer(javax.jms.Destination destination,
java.lang.String messageSelector)
Create a message consumer |
javax.jms.MessageConsumer |
createConsumer(javax.jms.Destination destination,
java.lang.String messageSelector,
boolean noLocal)
Create a message consumer |
javax.jms.TopicSubscriber |
createDurableSubscriber(javax.jms.Topic topic,
java.lang.String name)
Create a durable topic subscriber |
javax.jms.TopicSubscriber |
createDurableSubscriber(javax.jms.Topic topic,
java.lang.String name,
java.lang.String messageSelector,
boolean noLocal)
Create a topic subscriber |
javax.jms.MapMessage |
createMapMessage()
Create a map message |
javax.jms.Message |
createMessage()
Create a message |
javax.jms.ObjectMessage |
createObjectMessage()
Create an object message |
javax.jms.ObjectMessage |
createObjectMessage(java.io.Serializable object)
Create an object message |
javax.jms.MessageProducer |
createProducer(javax.jms.Destination destination)
Create a message producer |
javax.jms.TopicPublisher |
createPublisher(javax.jms.Topic topic)
Create a topic publisher |
javax.jms.Queue |
createQueue(java.lang.String queueName)
Create a queue |
javax.jms.QueueReceiver |
createReceiver(javax.jms.Queue queue)
Create a queue receiver |
javax.jms.QueueReceiver |
createReceiver(javax.jms.Queue queue,
java.lang.String messageSelector)
Create a queue receiver |
javax.jms.QueueSender |
createSender(javax.jms.Queue queue)
Create a queue sender |
javax.jms.StreamMessage |
createStreamMessage()
Create a stream message |
javax.jms.TopicSubscriber |
createSubscriber(javax.jms.Topic topic)
Create a topic subscriber |
javax.jms.TopicSubscriber |
createSubscriber(javax.jms.Topic topic,
java.lang.String messageSelector,
boolean noLocal)
Create a topic subscriber |
javax.jms.TemporaryQueue |
createTemporaryQueue()
Create a temporary queue |
javax.jms.TemporaryTopic |
createTemporaryTopic()
Create a temporary topic |
javax.jms.TextMessage |
createTextMessage()
Create a text message |
javax.jms.TextMessage |
createTextMessage(java.lang.String string)
Create a text message |
javax.jms.Topic |
createTopic(java.lang.String topicName)
Create a topic |
int |
getAcknowledgeMode()
Get the acknowledge mode |
javax.jms.MessageListener |
getMessageListener()
Get the message listener -- throws IllegalStateException |
javax.jms.QueueSession |
getQueueSession()
Get the queue session |
javax.jms.Session |
getSession()
Get the session |
javax.jms.TopicSession |
getTopicSession()
Get the topic session |
boolean |
getTransacted()
Get transacted |
javax.transaction.xa.XAResource |
getXAResource()
Get the XA resource |
protected void |
lock()
Lock |
void |
recover()
Recover |
void |
rollback()
Rollback |
void |
run()
Always throws an Error. |
void |
setJBMSessionFactory(JBMSessionFactory sf)
Set the session factory |
void |
setMessageListener(javax.jms.MessageListener listener)
Set the message listener -- Throws IllegalStateException |
protected void |
unlock()
Unlock |
void |
unsubscribe(java.lang.String name)
Unsubscribe |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public JBMSession(JBMManagedConnection mc, JBMConnectionRequestInfo cri)
mc
- The managed connectioncri
- The connection request infoMethod Detail |
---|
public void setJBMSessionFactory(JBMSessionFactory sf)
sf
- The session factoryprotected void lock() throws javax.jms.JMSException
javax.jms.JMSException
- Thrown if an error occurs
javax.jms.IllegalStateException
- The session is closedprotected void unlock()
public javax.jms.BytesMessage createBytesMessage() throws javax.jms.JMSException
createBytesMessage
in interface javax.jms.Session
javax.jms.JMSException
- Thrown if an error occurspublic javax.jms.MapMessage createMapMessage() throws javax.jms.JMSException
createMapMessage
in interface javax.jms.Session
javax.jms.JMSException
- Thrown if an error occurspublic javax.jms.Message createMessage() throws javax.jms.JMSException
createMessage
in interface javax.jms.Session
javax.jms.JMSException
- Thrown if an error occurspublic javax.jms.ObjectMessage createObjectMessage() throws javax.jms.JMSException
createObjectMessage
in interface javax.jms.Session
javax.jms.JMSException
- Thrown if an error occurspublic javax.jms.ObjectMessage createObjectMessage(java.io.Serializable object) throws javax.jms.JMSException
createObjectMessage
in interface javax.jms.Session
object
- The object
javax.jms.JMSException
- Thrown if an error occurspublic javax.jms.StreamMessage createStreamMessage() throws javax.jms.JMSException
createStreamMessage
in interface javax.jms.Session
javax.jms.JMSException
- Thrown if an error occurspublic javax.jms.TextMessage createTextMessage() throws javax.jms.JMSException
createTextMessage
in interface javax.jms.Session
javax.jms.JMSException
- Thrown if an error occurspublic javax.jms.TextMessage createTextMessage(java.lang.String string) throws javax.jms.JMSException
createTextMessage
in interface javax.jms.Session
string
- The text
javax.jms.JMSException
- Thrown if an error occurspublic boolean getTransacted() throws javax.jms.JMSException
getTransacted
in interface javax.jms.Session
getTransacted
in interface javax.jms.XASession
javax.jms.JMSException
- Thrown if an error occurspublic javax.jms.MessageListener getMessageListener() throws javax.jms.JMSException
getMessageListener
in interface javax.jms.Session
javax.jms.JMSException
- Thrown if an error occurspublic void setMessageListener(javax.jms.MessageListener listener) throws javax.jms.JMSException
setMessageListener
in interface javax.jms.Session
listener
- The message listener
javax.jms.JMSException
- Thrown if an error occurspublic void run()
run
in interface java.lang.Runnable
run
in interface javax.jms.Session
java.lang.Error
- Method not allowed.public void close() throws javax.jms.JMSException
close
in interface javax.jms.Session
javax.jms.JMSException
- Failed to close session.public void commit() throws javax.jms.JMSException
commit
in interface javax.jms.Session
commit
in interface javax.jms.XASession
javax.jms.JMSException
- Failed to close session.public void rollback() throws javax.jms.JMSException
rollback
in interface javax.jms.Session
rollback
in interface javax.jms.XASession
javax.jms.JMSException
- Failed to close session.public void recover() throws javax.jms.JMSException
recover
in interface javax.jms.Session
javax.jms.JMSException
- Failed to close session.public javax.jms.Topic createTopic(java.lang.String topicName) throws javax.jms.JMSException
createTopic
in interface javax.jms.Session
createTopic
in interface javax.jms.TopicSession
topicName
- The topic name
javax.jms.JMSException
- Thrown if an error occurspublic javax.jms.TopicSubscriber createSubscriber(javax.jms.Topic topic) throws javax.jms.JMSException
createSubscriber
in interface javax.jms.TopicSession
topic
- The topic
javax.jms.JMSException
- Thrown if an error occurspublic javax.jms.TopicSubscriber createSubscriber(javax.jms.Topic topic, java.lang.String messageSelector, boolean noLocal) throws javax.jms.JMSException
createSubscriber
in interface javax.jms.TopicSession
topic
- The topicmessageSelector
- The message selectornoLocal
- If true inhibits the delivery of messages published by its own connection
javax.jms.JMSException
- Thrown if an error occurspublic javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic topic, java.lang.String name) throws javax.jms.JMSException
createDurableSubscriber
in interface javax.jms.Session
createDurableSubscriber
in interface javax.jms.TopicSession
topic
- The topicname
- The name
javax.jms.JMSException
- Thrown if an error occurspublic javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic topic, java.lang.String name, java.lang.String messageSelector, boolean noLocal) throws javax.jms.JMSException
createDurableSubscriber
in interface javax.jms.Session
createDurableSubscriber
in interface javax.jms.TopicSession
topic
- The topicname
- The namemessageSelector
- The message selectornoLocal
- If true inhibits the delivery of messages published by its own connection
javax.jms.JMSException
- Thrown if an error occurspublic javax.jms.TopicPublisher createPublisher(javax.jms.Topic topic) throws javax.jms.JMSException
createPublisher
in interface javax.jms.TopicSession
topic
- The topic
javax.jms.JMSException
- Thrown if an error occurspublic javax.jms.TemporaryTopic createTemporaryTopic() throws javax.jms.JMSException
createTemporaryTopic
in interface javax.jms.Session
createTemporaryTopic
in interface javax.jms.TopicSession
javax.jms.JMSException
- Thrown if an error occurspublic void unsubscribe(java.lang.String name) throws javax.jms.JMSException
unsubscribe
in interface javax.jms.Session
unsubscribe
in interface javax.jms.TopicSession
name
- The name
javax.jms.JMSException
- Thrown if an error occurspublic javax.jms.QueueBrowser createBrowser(javax.jms.Queue queue) throws javax.jms.JMSException
createBrowser
in interface javax.jms.QueueSession
createBrowser
in interface javax.jms.Session
queue
- The queue
javax.jms.JMSException
- Thrown if an error occurspublic javax.jms.QueueBrowser createBrowser(javax.jms.Queue queue, java.lang.String messageSelector) throws javax.jms.JMSException
createBrowser
in interface javax.jms.QueueSession
createBrowser
in interface javax.jms.Session
queue
- The queuemessageSelector
- The message selector
javax.jms.JMSException
- Thrown if an error occurspublic javax.jms.Queue createQueue(java.lang.String queueName) throws javax.jms.JMSException
createQueue
in interface javax.jms.QueueSession
createQueue
in interface javax.jms.Session
queueName
- The queue name
javax.jms.JMSException
- Thrown if an error occurspublic javax.jms.QueueReceiver createReceiver(javax.jms.Queue queue) throws javax.jms.JMSException
createReceiver
in interface javax.jms.QueueSession
queue
- The queue
javax.jms.JMSException
- Thrown if an error occurspublic javax.jms.QueueReceiver createReceiver(javax.jms.Queue queue, java.lang.String messageSelector) throws javax.jms.JMSException
createReceiver
in interface javax.jms.QueueSession
queue
- The queuemessageSelector
-
javax.jms.JMSException
- Thrown if an error occurspublic javax.jms.QueueSender createSender(javax.jms.Queue queue) throws javax.jms.JMSException
createSender
in interface javax.jms.QueueSession
queue
- The queue
javax.jms.JMSException
- Thrown if an error occurspublic javax.jms.TemporaryQueue createTemporaryQueue() throws javax.jms.JMSException
createTemporaryQueue
in interface javax.jms.QueueSession
createTemporaryQueue
in interface javax.jms.Session
javax.jms.JMSException
- Thrown if an error occurspublic javax.jms.MessageConsumer createConsumer(javax.jms.Destination destination) throws javax.jms.JMSException
createConsumer
in interface javax.jms.Session
destination
- The destination
javax.jms.JMSException
- Thrown if an error occurspublic javax.jms.MessageConsumer createConsumer(javax.jms.Destination destination, java.lang.String messageSelector) throws javax.jms.JMSException
createConsumer
in interface javax.jms.Session
destination
- The destinationmessageSelector
- The message selector
javax.jms.JMSException
- Thrown if an error occurspublic javax.jms.MessageConsumer createConsumer(javax.jms.Destination destination, java.lang.String messageSelector, boolean noLocal) throws javax.jms.JMSException
createConsumer
in interface javax.jms.Session
destination
- The destinationmessageSelector
- The message selectornoLocal
- If true inhibits the delivery of messages published by its own connection
javax.jms.JMSException
- Thrown if an error occurspublic javax.jms.MessageProducer createProducer(javax.jms.Destination destination) throws javax.jms.JMSException
createProducer
in interface javax.jms.Session
destination
- The destination
javax.jms.JMSException
- Thrown if an error occurspublic int getAcknowledgeMode() throws javax.jms.JMSException
getAcknowledgeMode
in interface javax.jms.Session
javax.jms.JMSException
- Thrown if an error occurspublic javax.transaction.xa.XAResource getXAResource()
getXAResource
in interface javax.jms.XASession
javax.jms.IllegalStateException
- If non XA connectionpublic javax.jms.Session getSession() throws javax.jms.JMSException
getSession
in interface javax.jms.XASession
javax.jms.JMSException
- Thrown if an error occurspublic javax.jms.QueueSession getQueueSession() throws javax.jms.JMSException
getQueueSession
in interface javax.jms.XAQueueSession
javax.jms.JMSException
- Thrown if an error occurspublic javax.jms.TopicSession getTopicSession() throws javax.jms.JMSException
getTopicSession
in interface javax.jms.XATopicSession
javax.jms.JMSException
- Thrown if an error occurs
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |