public class MockQueueSession extends Object implements javax.jms.QueueSession
Constructor and Description |
---|
MockQueueSession() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
commit() |
javax.jms.QueueBrowser |
createBrowser(javax.jms.Queue arg0) |
javax.jms.QueueBrowser |
createBrowser(javax.jms.Queue arg0,
String arg1) |
javax.jms.BytesMessage |
createBytesMessage() |
javax.jms.MessageConsumer |
createConsumer(javax.jms.Destination arg0) |
javax.jms.MessageConsumer |
createConsumer(javax.jms.Destination arg0,
String arg1) |
javax.jms.MessageConsumer |
createConsumer(javax.jms.Destination arg0,
String arg1,
boolean arg2) |
javax.jms.TopicSubscriber |
createDurableSubscriber(javax.jms.Topic arg0,
String arg1) |
javax.jms.TopicSubscriber |
createDurableSubscriber(javax.jms.Topic arg0,
String arg1,
String arg2,
boolean arg3) |
javax.jms.MapMessage |
createMapMessage() |
javax.jms.Message |
createMessage() |
javax.jms.ObjectMessage |
createObjectMessage() |
javax.jms.ObjectMessage |
createObjectMessage(Serializable arg0) |
javax.jms.MessageProducer |
createProducer(javax.jms.Destination arg0) |
javax.jms.Queue |
createQueue(String arg0) |
javax.jms.QueueReceiver |
createReceiver(javax.jms.Queue arg0) |
javax.jms.QueueReceiver |
createReceiver(javax.jms.Queue arg0,
String arg1) |
javax.jms.QueueSender |
createSender(javax.jms.Queue queue) |
javax.jms.StreamMessage |
createStreamMessage() |
javax.jms.TemporaryQueue |
createTemporaryQueue() |
javax.jms.TemporaryTopic |
createTemporaryTopic() |
javax.jms.TextMessage |
createTextMessage() |
javax.jms.TextMessage |
createTextMessage(String arg0) |
javax.jms.Topic |
createTopic(String arg0) |
int |
getAcknowledgeMode() |
javax.jms.MessageListener |
getMessageListener() |
boolean |
getTransacted() |
void |
recover() |
void |
rollback() |
void |
run() |
void |
setMessageListener(javax.jms.MessageListener arg0) |
void |
unsubscribe(String arg0) |
public MockQueueSession()
public javax.jms.ObjectMessage createObjectMessage() throws javax.jms.JMSException
createObjectMessage
in interface javax.jms.Session
javax.jms.JMSException
public javax.jms.QueueSender createSender(javax.jms.Queue queue) throws javax.jms.JMSException
createSender
in interface javax.jms.QueueSession
javax.jms.JMSException
public javax.jms.QueueBrowser createBrowser(javax.jms.Queue arg0) throws javax.jms.JMSException
createBrowser
in interface javax.jms.QueueSession
createBrowser
in interface javax.jms.Session
javax.jms.JMSException
public javax.jms.QueueBrowser createBrowser(javax.jms.Queue arg0, String arg1) throws javax.jms.JMSException
createBrowser
in interface javax.jms.QueueSession
createBrowser
in interface javax.jms.Session
javax.jms.JMSException
public javax.jms.Queue createQueue(String arg0) throws javax.jms.JMSException
createQueue
in interface javax.jms.QueueSession
createQueue
in interface javax.jms.Session
javax.jms.JMSException
public javax.jms.QueueReceiver createReceiver(javax.jms.Queue arg0) throws javax.jms.JMSException
createReceiver
in interface javax.jms.QueueSession
javax.jms.JMSException
public javax.jms.QueueReceiver createReceiver(javax.jms.Queue arg0, String arg1) throws javax.jms.JMSException
createReceiver
in interface javax.jms.QueueSession
javax.jms.JMSException
public javax.jms.TemporaryQueue createTemporaryQueue() throws javax.jms.JMSException
createTemporaryQueue
in interface javax.jms.QueueSession
createTemporaryQueue
in interface javax.jms.Session
javax.jms.JMSException
public void close() throws javax.jms.JMSException
close
in interface javax.jms.Session
javax.jms.JMSException
public void commit() throws javax.jms.JMSException
commit
in interface javax.jms.Session
javax.jms.JMSException
public javax.jms.BytesMessage createBytesMessage() throws javax.jms.JMSException
createBytesMessage
in interface javax.jms.Session
javax.jms.JMSException
public javax.jms.MessageConsumer createConsumer(javax.jms.Destination arg0) throws javax.jms.JMSException
createConsumer
in interface javax.jms.Session
javax.jms.JMSException
public javax.jms.MessageConsumer createConsumer(javax.jms.Destination arg0, String arg1) throws javax.jms.JMSException
createConsumer
in interface javax.jms.Session
javax.jms.JMSException
public javax.jms.MessageConsumer createConsumer(javax.jms.Destination arg0, String arg1, boolean arg2) throws javax.jms.JMSException
createConsumer
in interface javax.jms.Session
javax.jms.JMSException
public javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic arg0, String arg1) throws javax.jms.JMSException
createDurableSubscriber
in interface javax.jms.Session
javax.jms.JMSException
public javax.jms.TopicSubscriber createDurableSubscriber(javax.jms.Topic arg0, String arg1, String arg2, boolean arg3) throws javax.jms.JMSException
createDurableSubscriber
in interface javax.jms.Session
javax.jms.JMSException
public javax.jms.MapMessage createMapMessage() throws javax.jms.JMSException
createMapMessage
in interface javax.jms.Session
javax.jms.JMSException
public javax.jms.Message createMessage() throws javax.jms.JMSException
createMessage
in interface javax.jms.Session
javax.jms.JMSException
public javax.jms.ObjectMessage createObjectMessage(Serializable arg0) throws javax.jms.JMSException
createObjectMessage
in interface javax.jms.Session
javax.jms.JMSException
public javax.jms.MessageProducer createProducer(javax.jms.Destination arg0) throws javax.jms.JMSException
createProducer
in interface javax.jms.Session
javax.jms.JMSException
public javax.jms.StreamMessage createStreamMessage() throws javax.jms.JMSException
createStreamMessage
in interface javax.jms.Session
javax.jms.JMSException
public javax.jms.TemporaryTopic createTemporaryTopic() throws javax.jms.JMSException
createTemporaryTopic
in interface javax.jms.Session
javax.jms.JMSException
public javax.jms.TextMessage createTextMessage() throws javax.jms.JMSException
createTextMessage
in interface javax.jms.Session
javax.jms.JMSException
public javax.jms.TextMessage createTextMessage(String arg0) throws javax.jms.JMSException
createTextMessage
in interface javax.jms.Session
javax.jms.JMSException
public javax.jms.Topic createTopic(String arg0) throws javax.jms.JMSException
createTopic
in interface javax.jms.Session
javax.jms.JMSException
public int getAcknowledgeMode() throws javax.jms.JMSException
getAcknowledgeMode
in interface javax.jms.Session
javax.jms.JMSException
public javax.jms.MessageListener getMessageListener() throws javax.jms.JMSException
getMessageListener
in interface javax.jms.Session
javax.jms.JMSException
public boolean getTransacted() throws javax.jms.JMSException
getTransacted
in interface javax.jms.Session
javax.jms.JMSException
public void recover() throws javax.jms.JMSException
recover
in interface javax.jms.Session
javax.jms.JMSException
public void rollback() throws javax.jms.JMSException
rollback
in interface javax.jms.Session
javax.jms.JMSException
public void run()
public void setMessageListener(javax.jms.MessageListener arg0) throws javax.jms.JMSException
setMessageListener
in interface javax.jms.Session
javax.jms.JMSException
public void unsubscribe(String arg0) throws javax.jms.JMSException
unsubscribe
in interface javax.jms.Session
javax.jms.JMSException
Copyright © 2005–2017 QOS.ch. All rights reserved.