public class QpidRASessionImpl extends Object implements javax.jms.Session, javax.jms.QueueSession, javax.jms.TopicSession, javax.jms.XASession, javax.jms.XAQueueSession, javax.jms.XATopicSession, QpidRASession
Constructor and Description |
---|
QpidRASessionImpl(QpidRAManagedConnection mc,
QpidRAConnectionRequestInfo cri)
Constructor
|
Modifier and Type | Method and Description |
---|---|
void |
checkState()
throws SystemException
throws RollbackException
|
void |
close()
Closes the session.
|
void |
closeSession()
Close session
|
void |
commit()
Commit
|
javax.jms.QueueBrowser |
createBrowser(javax.jms.Queue queue)
Create a browser
|
javax.jms.QueueBrowser |
createBrowser(javax.jms.Queue queue,
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,
String messageSelector)
Create a message consumer
|
javax.jms.MessageConsumer |
createConsumer(javax.jms.Destination destination,
String messageSelector,
boolean noLocal)
Create a message consumer
|
javax.jms.TopicSubscriber |
createDurableSubscriber(javax.jms.Topic topic,
String name)
Create a durable topic subscriber
|
javax.jms.TopicSubscriber |
createDurableSubscriber(javax.jms.Topic topic,
String name,
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(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(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,
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,
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(String string)
Create a text message
|
javax.jms.Topic |
createTopic(String topicName)
Create a topic
|
int |
getAcknowledgeMode()
Get the acknowledge mode
|
javax.resource.spi.ManagedConnection |
getManagedConnection()
for tests only
|
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
|
XAResource |
getXAResource()
Get the XA resource
|
boolean |
isStarted()
Has this session been started?
|
protected void |
lock()
Lock
|
void |
recover()
Recover
|
void |
rollback()
Rollback
|
void |
run()
Always throws an Error.
|
void |
setMessageListener(javax.jms.MessageListener listener)
Set the message listener -- Throws IllegalStateException
|
void |
setQpidSessionFactory(QpidRASessionFactory sf)
Set the session factory
|
void |
start()
Start
|
protected void |
unlock()
Unlock
|
void |
unsubscribe(String name)
Unsubscribe
|
public QpidRASessionImpl(QpidRAManagedConnection mc, QpidRAConnectionRequestInfo cri)
mc
- The managed connectioncri
- The connection request infopublic void setQpidSessionFactory(QpidRASessionFactory sf)
setQpidSessionFactory
in interface QpidRASession
sf
- The session factoryprotected void lock() throws javax.jms.JMSException
javax.jms.JMSException
- Thrown if an error occursjavax.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(Serializable object) throws javax.jms.JMSException
createObjectMessage
in interface javax.jms.Session
object
- The objectjavax.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(String string) throws javax.jms.JMSException
createTextMessage
in interface javax.jms.Session
string
- The textjavax.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 listenerjavax.jms.JMSException
- Thrown if an error occurspublic void run()
public void close() throws javax.jms.JMSException
close
in interface javax.jms.Session
close
in interface QpidRASession
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(String topicName) throws javax.jms.JMSException
createTopic
in interface javax.jms.Session
createTopic
in interface javax.jms.TopicSession
topicName
- The topic namejavax.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 topicjavax.jms.JMSException
- Thrown if an error occurspublic javax.jms.TopicSubscriber createSubscriber(javax.jms.Topic topic, 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 connectionjavax.jms.JMSException
- Thrown if an error occurspublic javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic topic, String name) throws javax.jms.JMSException
createDurableSubscriber
in interface javax.jms.Session
createDurableSubscriber
in interface javax.jms.TopicSession
topic
- The topicname
- The namejavax.jms.JMSException
- Thrown if an error occurspublic javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic topic, String name, 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 connectionjavax.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 topicjavax.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(String name) throws javax.jms.JMSException
unsubscribe
in interface javax.jms.Session
unsubscribe
in interface javax.jms.TopicSession
name
- The namejavax.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 queuejavax.jms.JMSException
- Thrown if an error occurspublic javax.jms.QueueBrowser createBrowser(javax.jms.Queue queue, String messageSelector) throws javax.jms.JMSException
createBrowser
in interface javax.jms.QueueSession
createBrowser
in interface javax.jms.Session
queue
- The queuemessageSelector
- The message selectorjavax.jms.JMSException
- Thrown if an error occurspublic javax.jms.Queue createQueue(String queueName) throws javax.jms.JMSException
createQueue
in interface javax.jms.QueueSession
createQueue
in interface javax.jms.Session
queueName
- The queue namejavax.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 queuejavax.jms.JMSException
- Thrown if an error occurspublic javax.jms.QueueReceiver createReceiver(javax.jms.Queue queue, 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 queuejavax.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 destinationjavax.jms.JMSException
- Thrown if an error occurspublic javax.jms.MessageConsumer createConsumer(javax.jms.Destination destination, String messageSelector) throws javax.jms.JMSException
createConsumer
in interface javax.jms.Session
destination
- The destinationmessageSelector
- The message selectorjavax.jms.JMSException
- Thrown if an error occurspublic javax.jms.MessageConsumer createConsumer(javax.jms.Destination destination, 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 connectionjavax.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 destinationjavax.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 XAResource getXAResource()
getXAResource
in interface javax.jms.XASession
public 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 occurspublic javax.resource.spi.ManagedConnection getManagedConnection()
public void start() throws javax.jms.JMSException
start
in interface QpidRASession
javax.jms.JMSException
- Thrown if an error occurspublic void closeSession() throws javax.jms.JMSException
closeSession
in interface QpidRASession
javax.jms.JMSException
- Thrown if an error occurspublic void checkState() throws javax.jms.JMSException
javax.jms.JMSException
public boolean isStarted()
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.