com.sun.genericra.outbound
Class SessionAdapter
java.lang.Object
com.sun.genericra.outbound.SessionAdapter
- All Implemented Interfaces:
- java.lang.Runnable, javax.jms.QueueSession, javax.jms.Session, javax.jms.TopicSession
public class SessionAdapter
- extends java.lang.Object
- implements javax.jms.Session, javax.jms.TopicSession, javax.jms.QueueSession
SessionWrapper of the resource adapter.
- Author:
- Sivakumar Thyagarajan
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 |
Method Summary |
void |
close()
|
void |
commit()
|
javax.jms.QueueBrowser |
createBrowser(javax.jms.Queue name)
|
javax.jms.QueueBrowser |
createBrowser(javax.jms.Queue queue,
java.lang.String msgSel)
|
javax.jms.BytesMessage |
createBytesMessage()
|
javax.jms.MessageConsumer |
createConsumer(javax.jms.Destination dest)
|
javax.jms.MessageConsumer |
createConsumer(javax.jms.Destination dest,
java.lang.String msgSel)
|
javax.jms.MessageConsumer |
createConsumer(javax.jms.Destination dest,
java.lang.String msgSel,
boolean noLocal)
|
javax.jms.TopicSubscriber |
createDurableSubscriber(javax.jms.Topic topic,
java.lang.String name)
|
javax.jms.TopicSubscriber |
createDurableSubscriber(javax.jms.Topic topic,
java.lang.String name,
java.lang.String msgSel,
boolean noLocal)
|
javax.jms.MapMessage |
createMapMessage()
|
javax.jms.Message |
createMessage()
|
javax.jms.ObjectMessage |
createObjectMessage()
|
javax.jms.ObjectMessage |
createObjectMessage(java.io.Serializable ser)
|
javax.jms.MessageProducer |
createProducer(javax.jms.Destination dest)
|
javax.jms.TopicPublisher |
createPublisher(javax.jms.Topic topic)
|
javax.jms.Queue |
createQueue(java.lang.String name)
|
javax.jms.QueueReceiver |
createReceiver(javax.jms.Queue queue)
|
javax.jms.QueueReceiver |
createReceiver(javax.jms.Queue queue,
java.lang.String msgSel)
|
javax.jms.QueueSender |
createSender(javax.jms.Queue queue)
|
javax.jms.StreamMessage |
createStreamMessage()
|
javax.jms.TopicSubscriber |
createSubscriber(javax.jms.Topic topic)
|
javax.jms.TopicSubscriber |
createSubscriber(javax.jms.Topic topic,
java.lang.String msgSel,
boolean noLocal)
|
javax.jms.TemporaryQueue |
createTemporaryQueue()
|
javax.jms.TemporaryTopic |
createTemporaryTopic()
|
javax.jms.TextMessage |
createTextMessage()
|
javax.jms.TextMessage |
createTextMessage(java.lang.String msg)
|
javax.jms.Topic |
createTopic(java.lang.String name)
|
int |
getAcknowledgeMode()
|
javax.jms.MessageListener |
getMessageListener()
|
boolean |
getTransacted()
|
boolean |
isInUse()
|
void |
recover()
|
void |
rollback()
|
void |
run()
|
void |
setInUse()
|
void |
setInvalid()
|
void |
setMessageListener(javax.jms.MessageListener ml)
|
void |
unsubscribe(java.lang.String name)
|
Methods inherited from class java.lang.Object |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
SessionAdapter
public SessionAdapter(javax.jms.Session physicalSession,
ConnectionHandle ch)
getAcknowledgeMode
public int getAcknowledgeMode()
throws javax.jms.JMSException
- Specified by:
getAcknowledgeMode
in interface javax.jms.Session
- Throws:
javax.jms.JMSException
setInUse
public void setInUse()
setInvalid
public void setInvalid()
throws javax.jms.JMSException
- Throws:
javax.jms.JMSException
isInUse
public boolean isInUse()
close
public void close()
throws javax.jms.JMSException
- Specified by:
close
in interface javax.jms.Session
- Throws:
javax.jms.JMSException
commit
public void commit()
throws javax.jms.JMSException
- Specified by:
commit
in interface javax.jms.Session
- Throws:
javax.jms.JMSException
recover
public void recover()
throws javax.jms.JMSException
- Specified by:
recover
in interface javax.jms.Session
- Throws:
javax.jms.JMSException
rollback
public void rollback()
throws javax.jms.JMSException
- Specified by:
rollback
in interface javax.jms.Session
- Throws:
javax.jms.JMSException
run
public void run()
- Specified by:
run
in interface java.lang.Runnable
- Specified by:
run
in interface javax.jms.Session
getTransacted
public boolean getTransacted()
throws javax.jms.JMSException
- Specified by:
getTransacted
in interface javax.jms.Session
- Throws:
javax.jms.JMSException
unsubscribe
public void unsubscribe(java.lang.String name)
throws javax.jms.JMSException
- Specified by:
unsubscribe
in interface javax.jms.Session
- Specified by:
unsubscribe
in interface javax.jms.TopicSession
- Throws:
javax.jms.JMSException
createBytesMessage
public javax.jms.BytesMessage createBytesMessage()
throws javax.jms.JMSException
- Specified by:
createBytesMessage
in interface javax.jms.Session
- Throws:
javax.jms.JMSException
createMapMessage
public javax.jms.MapMessage createMapMessage()
throws javax.jms.JMSException
- Specified by:
createMapMessage
in interface javax.jms.Session
- Throws:
javax.jms.JMSException
createMessage
public javax.jms.Message createMessage()
throws javax.jms.JMSException
- Specified by:
createMessage
in interface javax.jms.Session
- Throws:
javax.jms.JMSException
getMessageListener
public javax.jms.MessageListener getMessageListener()
throws javax.jms.JMSException
- Specified by:
getMessageListener
in interface javax.jms.Session
- Throws:
javax.jms.JMSException
setMessageListener
public void setMessageListener(javax.jms.MessageListener ml)
throws javax.jms.JMSException
- Specified by:
setMessageListener
in interface javax.jms.Session
- Throws:
javax.jms.JMSException
createObjectMessage
public javax.jms.ObjectMessage createObjectMessage()
throws javax.jms.JMSException
- Specified by:
createObjectMessage
in interface javax.jms.Session
- Throws:
javax.jms.JMSException
createStreamMessage
public javax.jms.StreamMessage createStreamMessage()
throws javax.jms.JMSException
- Specified by:
createStreamMessage
in interface javax.jms.Session
- Throws:
javax.jms.JMSException
createTemporaryQueue
public javax.jms.TemporaryQueue createTemporaryQueue()
throws javax.jms.JMSException
- Specified by:
createTemporaryQueue
in interface javax.jms.QueueSession
- Specified by:
createTemporaryQueue
in interface javax.jms.Session
- Throws:
javax.jms.JMSException
createTemporaryTopic
public javax.jms.TemporaryTopic createTemporaryTopic()
throws javax.jms.JMSException
- Specified by:
createTemporaryTopic
in interface javax.jms.Session
- Specified by:
createTemporaryTopic
in interface javax.jms.TopicSession
- Throws:
javax.jms.JMSException
createTextMessage
public javax.jms.TextMessage createTextMessage()
throws javax.jms.JMSException
- Specified by:
createTextMessage
in interface javax.jms.Session
- Throws:
javax.jms.JMSException
createConsumer
public javax.jms.MessageConsumer createConsumer(javax.jms.Destination dest)
throws javax.jms.JMSException
- Specified by:
createConsumer
in interface javax.jms.Session
- Throws:
javax.jms.JMSException
createProducer
public javax.jms.MessageProducer createProducer(javax.jms.Destination dest)
throws javax.jms.JMSException
- Specified by:
createProducer
in interface javax.jms.Session
- Throws:
javax.jms.JMSException
createObjectMessage
public javax.jms.ObjectMessage createObjectMessage(java.io.Serializable ser)
throws javax.jms.JMSException
- Specified by:
createObjectMessage
in interface javax.jms.Session
- Throws:
javax.jms.JMSException
createQueue
public javax.jms.Queue createQueue(java.lang.String name)
throws javax.jms.JMSException
- Specified by:
createQueue
in interface javax.jms.QueueSession
- Specified by:
createQueue
in interface javax.jms.Session
- Throws:
javax.jms.JMSException
createBrowser
public javax.jms.QueueBrowser createBrowser(javax.jms.Queue name)
throws javax.jms.JMSException
- Specified by:
createBrowser
in interface javax.jms.QueueSession
- Specified by:
createBrowser
in interface javax.jms.Session
- Throws:
javax.jms.JMSException
createTextMessage
public javax.jms.TextMessage createTextMessage(java.lang.String msg)
throws javax.jms.JMSException
- Specified by:
createTextMessage
in interface javax.jms.Session
- Throws:
javax.jms.JMSException
createTopic
public javax.jms.Topic createTopic(java.lang.String name)
throws javax.jms.JMSException
- Specified by:
createTopic
in interface javax.jms.Session
- Specified by:
createTopic
in interface javax.jms.TopicSession
- Throws:
javax.jms.JMSException
createConsumer
public javax.jms.MessageConsumer createConsumer(javax.jms.Destination dest,
java.lang.String msgSel)
throws javax.jms.JMSException
- Specified by:
createConsumer
in interface javax.jms.Session
- Throws:
javax.jms.JMSException
createConsumer
public javax.jms.MessageConsumer createConsumer(javax.jms.Destination dest,
java.lang.String msgSel,
boolean noLocal)
throws javax.jms.JMSException
- Specified by:
createConsumer
in interface javax.jms.Session
- Throws:
javax.jms.JMSException
createBrowser
public javax.jms.QueueBrowser createBrowser(javax.jms.Queue queue,
java.lang.String msgSel)
throws javax.jms.JMSException
- Specified by:
createBrowser
in interface javax.jms.QueueSession
- Specified by:
createBrowser
in interface javax.jms.Session
- Throws:
javax.jms.JMSException
createDurableSubscriber
public javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic topic,
java.lang.String name)
throws javax.jms.JMSException
- Specified by:
createDurableSubscriber
in interface javax.jms.Session
- Specified by:
createDurableSubscriber
in interface javax.jms.TopicSession
- Throws:
javax.jms.JMSException
createDurableSubscriber
public javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic topic,
java.lang.String name,
java.lang.String msgSel,
boolean noLocal)
throws javax.jms.JMSException
- Specified by:
createDurableSubscriber
in interface javax.jms.Session
- Specified by:
createDurableSubscriber
in interface javax.jms.TopicSession
- Throws:
javax.jms.JMSException
createPublisher
public javax.jms.TopicPublisher createPublisher(javax.jms.Topic topic)
throws javax.jms.JMSException
- Specified by:
createPublisher
in interface javax.jms.TopicSession
- Throws:
javax.jms.JMSException
createSubscriber
public javax.jms.TopicSubscriber createSubscriber(javax.jms.Topic topic)
throws javax.jms.JMSException
- Specified by:
createSubscriber
in interface javax.jms.TopicSession
- Throws:
javax.jms.JMSException
createSubscriber
public javax.jms.TopicSubscriber createSubscriber(javax.jms.Topic topic,
java.lang.String msgSel,
boolean noLocal)
throws javax.jms.JMSException
- Specified by:
createSubscriber
in interface javax.jms.TopicSession
- Throws:
javax.jms.JMSException
createReceiver
public javax.jms.QueueReceiver createReceiver(javax.jms.Queue queue)
throws javax.jms.JMSException
- Specified by:
createReceiver
in interface javax.jms.QueueSession
- Throws:
javax.jms.JMSException
createSender
public javax.jms.QueueSender createSender(javax.jms.Queue queue)
throws javax.jms.JMSException
- Specified by:
createSender
in interface javax.jms.QueueSession
- Throws:
javax.jms.JMSException
createReceiver
public javax.jms.QueueReceiver createReceiver(javax.jms.Queue queue,
java.lang.String msgSel)
throws javax.jms.JMSException
- Specified by:
createReceiver
in interface javax.jms.QueueSession
- Throws:
javax.jms.JMSException