Package dk.netarkivet.common.distribute
Class JMSConnectionMockupMQ.TestSession
- java.lang.Object
-
- dk.netarkivet.common.distribute.JMSConnectionMockupMQ.TestSession
-
- All Implemented Interfaces:
Runnable
,javax.jms.Session
- Direct Known Subclasses:
JMSConnectionMockupMQ.TestQueueSession
- Enclosing class:
- JMSConnectionMockupMQ
protected static class JMSConnectionMockupMQ.TestSession extends Object implements javax.jms.Session
-
-
Constructor Summary
Constructors Modifier Constructor Description protected
TestSession()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
void
commit()
javax.jms.QueueBrowser
createBrowser(javax.jms.Queue queue)
javax.jms.QueueBrowser
createBrowser(javax.jms.Queue queue, String string)
javax.jms.BytesMessage
createBytesMessage()
javax.jms.MessageConsumer
createConsumer(javax.jms.Destination destination)
javax.jms.MessageConsumer
createConsumer(javax.jms.Destination destination, String string)
javax.jms.MessageConsumer
createConsumer(javax.jms.Destination destination, String string, boolean b)
javax.jms.TopicSubscriber
createDurableSubscriber(javax.jms.Topic topic, String string)
javax.jms.TopicSubscriber
createDurableSubscriber(javax.jms.Topic topic, String string, String string1, boolean b)
javax.jms.MapMessage
createMapMessage()
javax.jms.Message
createMessage()
javax.jms.ObjectMessage
createObjectMessage()
javax.jms.ObjectMessage
createObjectMessage(Serializable serializable)
javax.jms.MessageProducer
createProducer(javax.jms.Destination destination)
javax.jms.Queue
createQueue(String string)
javax.jms.StreamMessage
createStreamMessage()
javax.jms.TemporaryQueue
createTemporaryQueue()
javax.jms.TemporaryTopic
createTemporaryTopic()
javax.jms.TextMessage
createTextMessage()
javax.jms.TextMessage
createTextMessage(String string)
javax.jms.Topic
createTopic(String string)
int
getAcknowledgeMode()
javax.jms.MessageListener
getMessageListener()
boolean
getTransacted()
void
recover()
void
rollback()
void
run()
void
setMessageListener(javax.jms.MessageListener messageListener)
void
unsubscribe(String string)
-
-
-
Method Detail
-
createObjectMessage
public javax.jms.ObjectMessage createObjectMessage(Serializable serializable) throws javax.jms.JMSException
- Specified by:
createObjectMessage
in interfacejavax.jms.Session
- Throws:
javax.jms.JMSException
-
createBytesMessage
public javax.jms.BytesMessage createBytesMessage() throws javax.jms.JMSException
- Specified by:
createBytesMessage
in interfacejavax.jms.Session
- Throws:
javax.jms.JMSException
-
createProducer
public javax.jms.MessageProducer createProducer(javax.jms.Destination destination) throws javax.jms.JMSException
- Specified by:
createProducer
in interfacejavax.jms.Session
- Throws:
javax.jms.JMSException
-
createConsumer
public javax.jms.MessageConsumer createConsumer(javax.jms.Destination destination) throws javax.jms.JMSException
- Specified by:
createConsumer
in interfacejavax.jms.Session
- Throws:
javax.jms.JMSException
-
createMapMessage
public javax.jms.MapMessage createMapMessage() throws javax.jms.JMSException
- Specified by:
createMapMessage
in interfacejavax.jms.Session
- Throws:
javax.jms.JMSException
-
createMessage
public javax.jms.Message createMessage() throws javax.jms.JMSException
- Specified by:
createMessage
in interfacejavax.jms.Session
- Throws:
javax.jms.JMSException
-
createObjectMessage
public javax.jms.ObjectMessage createObjectMessage() throws javax.jms.JMSException
- Specified by:
createObjectMessage
in interfacejavax.jms.Session
- Throws:
javax.jms.JMSException
-
createStreamMessage
public javax.jms.StreamMessage createStreamMessage() throws javax.jms.JMSException
- Specified by:
createStreamMessage
in interfacejavax.jms.Session
- Throws:
javax.jms.JMSException
-
createTextMessage
public javax.jms.TextMessage createTextMessage() throws javax.jms.JMSException
- Specified by:
createTextMessage
in interfacejavax.jms.Session
- Throws:
javax.jms.JMSException
-
createTextMessage
public javax.jms.TextMessage createTextMessage(String string) throws javax.jms.JMSException
- Specified by:
createTextMessage
in interfacejavax.jms.Session
- Throws:
javax.jms.JMSException
-
getTransacted
public boolean getTransacted() throws javax.jms.JMSException
- Specified by:
getTransacted
in interfacejavax.jms.Session
- Throws:
javax.jms.JMSException
-
getAcknowledgeMode
public int getAcknowledgeMode() throws javax.jms.JMSException
- Specified by:
getAcknowledgeMode
in interfacejavax.jms.Session
- Throws:
javax.jms.JMSException
-
commit
public void commit() throws javax.jms.JMSException
- Specified by:
commit
in interfacejavax.jms.Session
- Throws:
javax.jms.JMSException
-
rollback
public void rollback() throws javax.jms.JMSException
- Specified by:
rollback
in interfacejavax.jms.Session
- Throws:
javax.jms.JMSException
-
close
public void close() throws javax.jms.JMSException
- Specified by:
close
in interfacejavax.jms.Session
- Throws:
javax.jms.JMSException
-
recover
public void recover() throws javax.jms.JMSException
- Specified by:
recover
in interfacejavax.jms.Session
- Throws:
javax.jms.JMSException
-
getMessageListener
public javax.jms.MessageListener getMessageListener() throws javax.jms.JMSException
- Specified by:
getMessageListener
in interfacejavax.jms.Session
- Throws:
javax.jms.JMSException
-
setMessageListener
public void setMessageListener(javax.jms.MessageListener messageListener) throws javax.jms.JMSException
- Specified by:
setMessageListener
in interfacejavax.jms.Session
- Throws:
javax.jms.JMSException
-
run
public void run()
-
createConsumer
public javax.jms.MessageConsumer createConsumer(javax.jms.Destination destination, String string) throws javax.jms.JMSException
- Specified by:
createConsumer
in interfacejavax.jms.Session
- Throws:
javax.jms.JMSException
-
createConsumer
public javax.jms.MessageConsumer createConsumer(javax.jms.Destination destination, String string, boolean b) throws javax.jms.JMSException
- Specified by:
createConsumer
in interfacejavax.jms.Session
- Throws:
javax.jms.JMSException
-
createQueue
public javax.jms.Queue createQueue(String string) throws javax.jms.JMSException
- Specified by:
createQueue
in interfacejavax.jms.Session
- Throws:
javax.jms.JMSException
-
createTopic
public javax.jms.Topic createTopic(String string) throws javax.jms.JMSException
- Specified by:
createTopic
in interfacejavax.jms.Session
- Throws:
javax.jms.JMSException
-
createDurableSubscriber
public javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic topic, String string) throws javax.jms.JMSException
- Specified by:
createDurableSubscriber
in interfacejavax.jms.Session
- Throws:
javax.jms.JMSException
-
createDurableSubscriber
public javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic topic, String string, String string1, boolean b) throws javax.jms.JMSException
- Specified by:
createDurableSubscriber
in interfacejavax.jms.Session
- Throws:
javax.jms.JMSException
-
createBrowser
public javax.jms.QueueBrowser createBrowser(javax.jms.Queue queue) throws javax.jms.JMSException
- Specified by:
createBrowser
in interfacejavax.jms.Session
- Throws:
javax.jms.JMSException
-
createBrowser
public javax.jms.QueueBrowser createBrowser(javax.jms.Queue queue, String string) throws javax.jms.JMSException
- Specified by:
createBrowser
in interfacejavax.jms.Session
- Throws:
javax.jms.JMSException
-
createTemporaryQueue
public javax.jms.TemporaryQueue createTemporaryQueue() throws javax.jms.JMSException
- Specified by:
createTemporaryQueue
in interfacejavax.jms.Session
- Throws:
javax.jms.JMSException
-
createTemporaryTopic
public javax.jms.TemporaryTopic createTemporaryTopic() throws javax.jms.JMSException
- Specified by:
createTemporaryTopic
in interfacejavax.jms.Session
- Throws:
javax.jms.JMSException
-
unsubscribe
public void unsubscribe(String string) throws javax.jms.JMSException
- Specified by:
unsubscribe
in interfacejavax.jms.Session
- Throws:
javax.jms.JMSException
-
-