|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object com.mockrunner.jms.JMSTestModule
public class JMSTestModule
Module for JMS tests.
Note that all indices are zero based.
Note for JMS 1.1:
If you use MockQueueConnectionFactory
for creating your
connections and sessions, you have to use the methods with Queue
in their name. Same with MockTopicConnectionFactory
.
The methods without Queue
and Topic
in the method name are for connections and sessions that were
created using the MockConnectionFactory
.
MockConnectionFactory
also implements the QueueConnectionFactory
and
TopicConnectionFactory
interfaces and can be used to create
queue and topic connections as well as generic JMS 1.1 connections.
It is recommended to use MockQueueConnectionFactory
if you only use queues and MockTopicConnectionFactory
if you only use topics and are not interested in having one factory for both.
It is possible to create a MockQueueConnection
or a MockTopicConnection
using the MockConnectionFactory
.
However, the Queue
methods (e.g. verifyAllQueueReceiversClosed(int)
)
only work, if you use MockQueueConnectionFactory
and the
Topic
methods (e.g. verifyCreatedTopicMapMessageNotAcknowledged(int, int)
)
only work, if you use MockTopicConnectionFactory
.
Constructor Summary | |
---|---|
JMSTestModule(JMSMockObjectFactory mockFactory)
|
Method Summary | |
---|---|
ConfigurationManager |
getConfigurationManager()
Returns the ConfigurationManager . |
MockConnection |
getCurrentConnection()
Returns the current MockConnection based on its
index or null if no connection
was created. |
java.util.List |
getCurrentMessageListFromQueue(java.lang.String name)
Returns the list of messages that are currently present in the queue or null if no such queue exists. |
java.util.List |
getCurrentMessageListFromTemporaryQueue(int indexOfSession,
int indexOfQueue)
Returns the list of messages that are currently present in the temporary queue or null if no such queue exists. |
java.util.List |
getCurrentMessageListFromTemporaryTopic(int indexOfSession,
int indexOfTopic)
Returns the list of messages that are currently present in the temporary topic or null if no such topic exists. |
java.util.List |
getCurrentMessageListFromTopic(java.lang.String name)
Returns the list of messages that are currently present in the topic or null if no such topic exists. |
MockQueueConnection |
getCurrentQueueConnection()
Returns the current MockQueueConnection based on its
index or null if no queue connection
was created. |
MockTopicConnection |
getCurrentTopicConnection()
Returns the current MockTopicConnection based on its
index or null if no topic connection
was created. |
DestinationManager |
getDestinationManager()
Returns the DestinationManager . |
MessageManager |
getMessageManager(int indexOfSession)
Returns the MessageManager for the specified session
or null if the session does not exist. |
MockQueue |
getQueue(java.lang.String name)
Returns the MockQueue with the specified name
or null if no such queue exists. |
MessageManager |
getQueueMessageManager(int indexOfSession)
Returns the MessageManager for the specified session
or null if the session does not exist. |
MockQueueSession |
getQueueSession(int indexOfSession)
Returns the MockQueueSession for the specified index
or null if the session does not exist. |
java.util.List |
getQueueSessionList()
Returns the list of MockQueueSession objects. |
QueueTransmissionManager |
getQueueTransmissionManager(int indexOfSession)
Returns the QueueTransmissionManager for the specified session
or null if the session does not exist. |
TransmissionManagerWrapper |
getQueueTransmissionManagerWrapper(int indexOfSession)
Returns the TransmissionManagerWrapper for the specified session
or null if the session does not exist. |
java.util.List |
getReceivedMessageListFromQueue(java.lang.String name)
Returns the list of messages that were received by the queue or null if no such queue exists. |
java.util.List |
getReceivedMessageListFromTemporaryQueue(int indexOfSession,
int indexOfQueue)
Returns the list of messages that were received by the temporary queue or null if no such queue exists. |
java.util.List |
getReceivedMessageListFromTemporaryTopic(int indexOfSession,
int indexOfTopic)
Returns the list of messages that were received by the temporary topic or null if no such topic exists. |
java.util.List |
getReceivedMessageListFromTopic(java.lang.String name)
Returns the list of messages that were received by the topic or null if no such topic exists. |
MockSession |
getSession(int indexOfSession)
Returns the MockSession for the specified index
or null if the session does not exist. |
java.util.List |
getSessionList()
Returns the list of MockSession objects. |
MockTemporaryQueue |
getTemporaryQueue(int indexOfSession,
int indexOfQueue)
Returns the MockTemporaryQueue with the specified index
for the specified session. |
java.util.List |
getTemporaryQueueList(int indexOfSession)
Returns the list of MockTemporaryQueue objects
for the specified session. |
MockTemporaryTopic |
getTemporaryTopic(int indexOfSession,
int indexOfTopic)
Returns the MockTemporaryTopic with the specified index
for the specified session. |
java.util.List |
getTemporaryTopicList(int indexOfSession)
Returns the list of MockTemporaryTopic objects
for the specified session. |
MockTopic |
getTopic(java.lang.String name)
Returns the MockTopic with the specified name
or null if no such topic exists. |
MessageManager |
getTopicMessageManager(int indexOfSession)
Returns the MessageManager for the specified session
or null if the session does not exist. |
MockTopicSession |
getTopicSession(int indexOfSession)
Returns the MockTopicSession for the specified index
or null if the session does not exist. |
java.util.List |
getTopicSessionList()
Returns the list of MockTopicSession objects. |
TopicTransmissionManager |
getTopicTransmissionManager(int indexOfSession)
Returns the TopicTransmissionManager for the specified session
or null if the session does not exist. |
TransmissionManagerWrapper |
getTopicTransmissionManagerWrapper(int indexOfSession)
Returns the TransmissionManagerWrapper for the specified session
or null if the session does not exist. |
TransmissionManagerWrapper |
getTransmissionManager(int indexOfSession)
Deprecated. use getTransmissionManagerWrapper(int) |
TransmissionManagerWrapper |
getTransmissionManagerWrapper(int indexOfSession)
Returns the TransmissionManagerWrapper for the specified session
or null if the session does not exist. |
void |
registerTestMessageListenerForQueue(MockConnection connection,
java.lang.String queueName,
boolean transacted,
int acknowledgeMode,
javax.jms.MessageListener listener)
Creates a new session and receiver using the specified connection and registers the specified listener. |
void |
registerTestMessageListenerForQueue(MockConnection connection,
java.lang.String queueName,
boolean transacted,
int acknowledgeMode,
java.lang.String messageSelector,
javax.jms.MessageListener listener)
Creates a new session and receiver using the specified connection and registers the specified listener. |
void |
registerTestMessageListenerForQueue(MockConnection connection,
java.lang.String queueName,
javax.jms.MessageListener listener)
Creates a new session and receiver using the specified connection and registers the specified listener. |
void |
registerTestMessageListenerForQueue(java.lang.String queueName,
javax.jms.MessageListener listener)
Creates a new connection and uses it for creating a new session and receiver. |
void |
registerTestMessageListenerForTopic(MockConnection connection,
java.lang.String topicName,
boolean transacted,
int acknowledgeMode,
javax.jms.MessageListener listener)
Creates a new session and subscriber using the specified connection and registers the specified listener. |
void |
registerTestMessageListenerForTopic(MockConnection connection,
java.lang.String topicName,
boolean transacted,
int acknowledgeMode,
java.lang.String messageSelector,
javax.jms.MessageListener listener)
Creates a new session and subscriber using the specified connection and registers the specified listener. |
void |
registerTestMessageListenerForTopic(MockConnection connection,
java.lang.String topicName,
javax.jms.MessageListener listener)
Creates a new session and subscriber using the specified connection and registers the specified listener. |
void |
registerTestMessageListenerForTopic(java.lang.String topicName,
javax.jms.MessageListener listener)
Creates a new connection and uses it for creating a new session and subscriber. |
void |
setCurrentConnectionIndex(int connectionIndex)
Sets the index of the MockConnection that should be used
for the current test. |
void |
setCurrentQueueConnectionIndex(int connectionIndex)
Sets the index of the MockQueueConnection that should be used
for the current test. |
void |
setCurrentTopicConnectionIndex(int connectionIndex)
Sets the index of the MockTopicConnection that should be used
for the current test. |
void |
verifyAllDurableTopicSubscribersClosed(int indexOfSession)
Verifies that all durable subscribers for the specified session are closed. |
void |
verifyAllMessageConsumersClosed(int indexOfSession)
Verifies that all consumers for the specified session are closed. |
void |
verifyAllMessageProducersClosed(int indexOfSession)
Verifies that all producers for the specified session are closed. |
void |
verifyAllQueueBrowsersClosed(int indexOfSession)
Verifies that all browsers for the specified session are closed. |
void |
verifyAllQueueReceiversClosed(int indexOfSession)
Verifies that all receivers for the specified session are closed. |
void |
verifyAllQueueSendersClosed(int indexOfSession)
Verifies that all senders for the specified session are closed. |
void |
verifyAllQueueSessionsClosed()
Verifies that all queue sessions are closed. |
void |
verifyAllQueueSessionsCommitted()
Verifies that all queue sessions were commited. |
void |
verifyAllQueueSessionsRecovered()
Verifies that all queue sessions are recovered. |
void |
verifyAllQueueSessionsRolledBack()
Verifies that all queue sessions were rolled back. |
void |
verifyAllReceivedQueueMessagesAcknowledged(int indexOfSession,
int indexOfQueue)
Verifies that all received messages of the specified temporary queue are acknowledged. |
void |
verifyAllReceivedQueueMessagesAcknowledged(java.lang.String nameOfQueue)
Verifies that all received messages of the specified queue are acknowledged. |
void |
verifyAllReceivedTopicMessagesAcknowledged(int indexOfSession,
int indexOfTopic)
Verifies that all received messages of the specified temporary topic are acknowledged. |
void |
verifyAllReceivedTopicMessagesAcknowledged(java.lang.String nameOfTopic)
Verifies that all received messages of the specified topic are acknowledged. |
void |
verifyAllSessionsClosed()
Verifies that all sessions are closed. |
void |
verifyAllSessionsCommitted()
Verifies that all sessions were commited. |
void |
verifyAllSessionsRecovered()
Verifies that all sessions are recovered. |
void |
verifyAllSessionsRolledBack()
Verifies that all topic sessions were rolled back. |
void |
verifyAllTemporaryQueuesDeleted(int indexOfSession)
Verifies that all temporary queues were deleted. |
void |
verifyAllTemporaryTopicsDeleted(int indexOfSession)
Verifies that all temporary topics were deleted. |
void |
verifyAllTopicPublishersClosed(int indexOfSession)
Verifies that all publishers for the specified session are closed. |
void |
verifyAllTopicSessionsClosed()
Verifies that all topic sessions are closed. |
void |
verifyAllTopicSessionsCommitted()
Verifies that all topic sessions were commited. |
void |
verifyAllTopicSessionsRecovered()
Verifies that all topic sessions are recovered. |
void |
verifyAllTopicSessionsRolledBack()
Verifies that all topic sessions were rolled back. |
void |
verifyAllTopicSubscribersClosed(int indexOfSession)
Verifies that all subscribers for the specified session are closed. |
void |
verifyConnectionClosed()
Verifies that the current MockConnection is closed. |
void |
verifyConnectionStarted()
Verifies that the current MockConnection is started. |
void |
verifyConnectionStopped()
Verifies that the current MockConnection is stopped. |
void |
verifyCreatedBytesMessageAcknowledged(int indexOfSession,
int indexOfMessage)
Verifies that a bytes message created with MockSession.createMessage()
is acknowledged. |
void |
verifyCreatedBytesMessageNotAcknowledged(int indexOfSession,
int indexOfMessage)
Verifies that a bytes message created with MockSession.createMessage()
is not acknowledged. |
void |
verifyCreatedMapMessageAcknowledged(int indexOfSession,
int indexOfMessage)
Verifies that a map message created with MockSession.createMessage()
is acknowledged. |
void |
verifyCreatedMapMessageNotAcknowledged(int indexOfSession,
int indexOfMessage)
Verifies that a map message created with MockSession.createMessage()
is not acknowledged. |
void |
verifyCreatedMessageAcknowledged(int indexOfSession,
int indexOfMessage)
Verifies that a message created with MockSession.createMessage()
is acknowledged. |
void |
verifyCreatedMessageNotAcknowledged(int indexOfSession,
int indexOfMessage)
Verifies that a message created with MockSession.createMessage()
is not acknowledged. |
void |
verifyCreatedObjectMessageAcknowledged(int indexOfSession,
int indexOfMessage)
Verifies that a object message created with MockSession.createMessage()
is acknowledged. |
void |
verifyCreatedObjectMessageNotAcknowledged(int indexOfSession,
int indexOfMessage)
Verifies that a object message created with MockSession.createMessage()
is not acknowledged. |
void |
verifyCreatedQueueBytesMessageAcknowledged(int indexOfSession,
int indexOfMessage)
Verifies that a bytes message created with MockSession.createMessage()
is acknowledged. |
void |
verifyCreatedQueueBytesMessageNotAcknowledged(int indexOfSession,
int indexOfMessage)
Verifies that a bytes message created with MockSession.createMessage()
is not acknowledged. |
void |
verifyCreatedQueueMapMessageAcknowledged(int indexOfSession,
int indexOfMessage)
Verifies that a map message created with MockSession.createMessage()
is acknowledged. |
void |
verifyCreatedQueueMapMessageNotAcknowledged(int indexOfSession,
int indexOfMessage)
Verifies that a map message created with MockSession.createMessage()
is not acknowledged. |
void |
verifyCreatedQueueMessageAcknowledged(int indexOfSession,
int indexOfMessage)
Verifies that a message created with MockSession.createMessage()
is acknowledged. |
void |
verifyCreatedQueueMessageNotAcknowledged(int indexOfSession,
int indexOfMessage)
Verifies that a message created with MockSession.createMessage()
is not acknowledged. |
void |
verifyCreatedQueueObjectMessageAcknowledged(int indexOfSession,
int indexOfMessage)
Verifies that a object message created with MockSession.createMessage()
is acknowledged. |
void |
verifyCreatedQueueObjectMessageNotAcknowledged(int indexOfSession,
int indexOfMessage)
Verifies that a object message created with MockSession.createMessage()
is not acknowledged. |
void |
verifyCreatedQueueStreamMessageAcknowledged(int indexOfSession,
int indexOfMessage)
Verifies that a stream message created with MockSession.createMessage()
is acknowledged. |
void |
verifyCreatedQueueStreamMessageNotAcknowledged(int indexOfSession,
int indexOfMessage)
Verifies that a stream message created with MockSession.createMessage()
is not acknowledged. |
void |
verifyCreatedQueueTextMessageAcknowledged(int indexOfSession,
int indexOfMessage)
Verifies that a text message created with MockSession.createMessage()
is acknowledged. |
void |
verifyCreatedQueueTextMessageNotAcknowledged(int indexOfSession,
int indexOfMessage)
Verifies that a text message created with MockSession.createMessage()
is not acknowledged. |
void |
verifyCreatedStreamMessageAcknowledged(int indexOfSession,
int indexOfMessage)
Verifies that a stream message created with MockSession.createMessage()
is acknowledged. |
void |
verifyCreatedStreamMessageNotAcknowledged(int indexOfSession,
int indexOfMessage)
Verifies that a stream message created with MockSession.createMessage()
is not acknowledged. |
void |
verifyCreatedTextMessageAcknowledged(int indexOfSession,
int indexOfMessage)
Verifies that a text message created with MockSession.createMessage()
is acknowledged. |
void |
verifyCreatedTextMessageNotAcknowledged(int indexOfSession,
int indexOfMessage)
Verifies that a text message created with MockSession.createMessage()
is not acknowledged. |
void |
verifyCreatedTopicBytesMessageAcknowledged(int indexOfSession,
int indexOfMessage)
Verifies that a bytes message created with MockSession.createMessage()
is acknowledged. |
void |
verifyCreatedTopicBytesMessageNotAcknowledged(int indexOfSession,
int indexOfMessage)
Verifies that a bytes message created with MockSession.createMessage()
is not acknowledged. |
void |
verifyCreatedTopicMapMessageAcknowledged(int indexOfSession,
int indexOfMessage)
Verifies that a map message created with MockSession.createMessage()
is acknowledged. |
void |
verifyCreatedTopicMapMessageNotAcknowledged(int indexOfSession,
int indexOfMessage)
Verifies that a map message created with MockSession.createMessage()
is not acknowledged. |
void |
verifyCreatedTopicMessageAcknowledged(int indexOfSession,
int indexOfMessage)
Verifies that a message created with MockSession.createMessage()
is acknowledged. |
void |
verifyCreatedTopicMessageNotAcknowledged(int indexOfSession,
int indexOfMessage)
Verifies that a message created with MockSession.createMessage()
is not acknowledged. |
void |
verifyCreatedTopicObjectMessageAcknowledged(int indexOfSession,
int indexOfMessage)
Verifies that a object message created with MockSession.createMessage()
is acknowledged. |
void |
verifyCreatedTopicObjectMessageNotAcknowledged(int indexOfSession,
int indexOfMessage)
Verifies that a object message created with MockSession.createMessage()
is not acknowledged. |
void |
verifyCreatedTopicStreamMessageAcknowledged(int indexOfSession,
int indexOfMessage)
Verifies that a stream message created with MockSession.createMessage()
is acknowledged. |
void |
verifyCreatedTopicStreamMessageNotAcknowledged(int indexOfSession,
int indexOfMessage)
Verifies that a stream message created with MockSession.createMessage()
is not acknowledged. |
void |
verifyCreatedTopicTextMessageAcknowledged(int indexOfSession,
int indexOfMessage)
Verifies that a text message created with MockSession.createMessage()
is acknowledged. |
void |
verifyCreatedTopicTextMessageNotAcknowledged(int indexOfSession,
int indexOfMessage)
Verifies that a text message created with MockSession.createMessage()
is not acknowledged. |
void |
verifyCurrentQueueMessageEquals(int indexOfSession,
int indexOfQueue,
int indexOfSourceMessage,
MockMessage targetMessage)
Verifies that a message in the specified temporary queue is equal to the specified message by calling the equals() method. |
void |
verifyCurrentQueueMessageEquals(java.lang.String nameOfQueue,
int indexOfSourceMessage,
MockMessage targetMessage)
Verifies that a message in the specified queue is equal to the specified message by calling the equals() method. |
void |
verifyCurrentTopicMessageEquals(int indexOfSession,
int indexOfTopic,
int indexOfSourceMessage,
MockMessage targetMessage)
Verifies that a message in the specified temporary topic is equal to the specified message by calling the equals() method. |
void |
verifyCurrentTopicMessageEquals(java.lang.String nameOfTopic,
int indexOfSourceMessage,
MockMessage targetMessage)
Verifies that a message in the specified topic is equal to the specified message by calling the equals() method. |
void |
verifyDurableTopicSubscriberClosed(int indexOfSession,
java.lang.String name)
Verifies that the specified durable subscriber is closed. |
void |
verifyDurableTopicSubscriberPresent(int indexOfSession,
java.lang.String name)
Verifies that a durable subscriber exists. |
void |
verifyMessageEquals(MockMessage message1,
MockMessage message2)
Verifies that the specified messages are equal by calling the equals() method. |
void |
verifyNumberDurableTopicSubscribers(int indexOfSession,
int numberOfSubscribers)
Verifies the number of durable subscribers for the specified session. |
void |
verifyNumberDurableTopicSubscribers(int indexOfSession,
java.lang.String topicName,
int numberOfSubscribers)
Verifies the number of durable subscribers for the specified session and the specified topic name. |
void |
verifyNumberMessageConsumers(int indexOfSession,
int numberOfConsumers)
Verifies the number of consumers for the specified session. |
void |
verifyNumberMessageProducers(int indexOfSession,
int numberOfProducers)
Verifies the number of producers for the specified session. |
void |
verifyNumberOfCreatedBytesMessages(int indexOfSession,
int number)
Verifies the number of bytes messages created with MockSession.createBytesMessage() . |
void |
verifyNumberOfCreatedMapMessages(int indexOfSession,
int number)
Verifies the number of map messages created with MockSession.createMapMessage() . |
void |
verifyNumberOfCreatedMessages(int indexOfSession,
int number)
Verifies the number of messages created with MockSession.createMessage() . |
void |
verifyNumberOfCreatedObjectMessages(int indexOfSession,
int number)
Verifies the number of object messages created with MockSession.createObjectMessage() . |
void |
verifyNumberOfCreatedQueueBytesMessages(int indexOfSession,
int number)
Verifies the number of bytes messages created with MockSession.createBytesMessage() . |
void |
verifyNumberOfCreatedQueueMapMessages(int indexOfSession,
int number)
Verifies the number of map messages created with MockSession.createMapMessage() . |
void |
verifyNumberOfCreatedQueueMessages(int indexOfSession,
int number)
Verifies the number of messages created with MockSession.createMessage() . |
void |
verifyNumberOfCreatedQueueObjectMessages(int indexOfSession,
int number)
Verifies the number of object messages created with MockSession.createObjectMessage() . |
void |
verifyNumberOfCreatedQueueStreamMessages(int indexOfSession,
int number)
Verifies the number of stream messages created with MockSession.createStreamMessage() . |
void |
verifyNumberOfCreatedQueueTextMessages(int indexOfSession,
int number)
Verifies the number of text messages created with MockSession.createTextMessage() . |
void |
verifyNumberOfCreatedStreamMessages(int indexOfSession,
int number)
Verifies the number of stream messages created with MockSession.createStreamMessage() . |
void |
verifyNumberOfCreatedTextMessages(int indexOfSession,
int number)
Verifies the number of text messages created with MockSession.createTextMessage() . |
void |
verifyNumberOfCreatedTopicBytesMessages(int indexOfSession,
int number)
Verifies the number of bytes messages created with MockSession.createBytesMessage() . |
void |
verifyNumberOfCreatedTopicMapMessages(int indexOfSession,
int number)
Verifies the number of map messages created with MockSession.createMapMessage() . |
void |
verifyNumberOfCreatedTopicMessages(int indexOfSession,
int number)
Verifies the number of messages created with MockSession.createMessage() . |
void |
verifyNumberOfCreatedTopicObjectMessages(int indexOfSession,
int number)
Verifies the number of object messages created with MockSession.createObjectMessage() . |
void |
verifyNumberOfCreatedTopicStreamMessages(int indexOfSession,
int number)
Verifies the number of stream messages created with MockSession.createStreamMessage() . |
void |
verifyNumberOfCreatedTopicTextMessages(int indexOfSession,
int number)
Verifies the number of text messages created with MockSession.createTextMessage() . |
void |
verifyNumberOfCurrentQueueMessages(int indexOfSession,
int indexOfQueue,
int numberOfMessages)
Verifies the number of messages in a temporary queue. |
void |
verifyNumberOfCurrentQueueMessages(java.lang.String nameOfQueue,
int numberOfMessages)
Verifies the number of messages in a queue. |
void |
verifyNumberOfCurrentTopicMessages(int indexOfSession,
int indexOfTopic,
int numberOfMessages)
Verifies the number of messages in a temporary topic. |
void |
verifyNumberOfCurrentTopicMessages(java.lang.String nameOfTopic,
int numberOfMessages)
Verifies the number of messages in a topic. |
void |
verifyNumberOfReceivedQueueMessages(int indexOfSession,
int indexOfQueue,
int numberOfMessages)
Verifies the number of messages received by a temporary queue. |
void |
verifyNumberOfReceivedQueueMessages(java.lang.String nameOfQueue,
int numberOfMessages)
Verifies the number of messages received by a queue. |
void |
verifyNumberOfReceivedTopicMessages(int indexOfSession,
int indexOfTopic,
int numberOfMessages)
Verifies the number of messages received by a temporary topic. |
void |
verifyNumberOfReceivedTopicMessages(java.lang.String nameOfTopic,
int numberOfMessages)
Verifies the number of messages received by a topic. |
void |
verifyNumberQueueBrowsers(int indexOfSession,
int numberOfBrowsers)
Verifies the number of browsers for the specified session. |
void |
verifyNumberQueueBrowsers(int indexOfSession,
java.lang.String queueName,
int numberOfBrowsers)
Verifies the number of browsers for the specified session and the specified queue name. |
void |
verifyNumberQueueReceivers(int indexOfSession,
int numberOfReceivers)
Verifies the number of receivers for the specified session. |
void |
verifyNumberQueueReceivers(int indexOfSession,
java.lang.String queueName,
int numberOfReceivers)
Verifies the number of receivers for the specified session and the specified queue name. |
void |
verifyNumberQueueSenders(int indexOfSession,
int numberOfSenders)
Verifies the number of senders for the specified session. |
void |
verifyNumberQueueSenders(int indexOfSession,
java.lang.String queueName,
int numberOfSenders)
Verifies the number of senders for the specified session and the specified queue name. |
void |
verifyNumberQueueSessions(int number)
Verifies the number of queue sessions. |
void |
verifyNumberSessions(int number)
Verifies the number of sessions. |
void |
verifyNumberTemporaryQueues(int indexOfSession,
int numberQueues)
Verifies the number of temporary queues. |
void |
verifyNumberTemporaryTopics(int indexOfSession,
int numberTopics)
Verifies the number of temporary topics. |
void |
verifyNumberTopicPublishers(int indexOfSession,
int numberOfPublishers)
Verifies the number of publishers for the specified session. |
void |
verifyNumberTopicPublishers(int indexOfSession,
java.lang.String topicName,
int numberOfPublishers)
Verifies the number of publishers for the specified session and the specified topic name. |
void |
verifyNumberTopicSessions(int number)
Verifies the number of topic sessions. |
void |
verifyNumberTopicSubscribers(int indexOfSession,
int numberOfSubscribers)
Verifies the number of subscribers for the specified session. |
void |
verifyNumberTopicSubscribers(int indexOfSession,
java.lang.String topicName,
int numberOfSubscribers)
Verifies the number of subscribers for the specified session and the specified topic name. |
void |
verifyQueueBrowserClosed(int indexOfSession,
java.lang.String queueName,
int indexOfBrowser)
Verifies that the specified browser is closed. |
void |
verifyQueueConnectionClosed()
Verifies that the current MockQueueConnection is closed. |
void |
verifyQueueConnectionStarted()
Verifies that the current MockQueueConnection is started. |
void |
verifyQueueConnectionStopped()
Verifies that the current MockQueueConnection is stopped. |
void |
verifyQueueReceiverClosed(int indexOfSession,
java.lang.String queueName,
int indexOfReceiver)
Verifies that the specified receiver is closed. |
void |
verifyQueueSenderClosed(int indexOfSession,
java.lang.String queueName,
int indexOfSender)
Verifies that the specified sender is closed. |
void |
verifyQueueSessionClosed(int indexOfSession)
Verifies that the queue session with the specified index is closed. |
void |
verifyQueueSessionCommitted(int indexOfSession)
Verifies that the queue session with the specified index was committed. |
void |
verifyQueueSessionNotCommitted(int indexOfSession)
Verifies that the queue session with the specified index was not committed. |
void |
verifyQueueSessionNotRecovered(int indexOfSession)
Verifies that the queue session with the specified index was not recovered. |
void |
verifyQueueSessionNotRolledBack(int indexOfSession)
Verifies that the queue session with the specified index was not rolled back. |
void |
verifyQueueSessionNumberCommits(int indexOfSession,
int numberOfCommits)
Verifies the number of commits of the queue session with the specified index. |
void |
verifyQueueSessionNumberRollbacks(int indexOfSession,
int numberOfRollbacks)
Verifies the number of rollbacks of the queue session with the specified index. |
void |
verifyQueueSessionRecovered(int indexOfSession)
Verifies that the queue session with the specified index was recovered. |
void |
verifyQueueSessionRolledBack(int indexOfSession)
Verifies that the queue session with the specified index was rolled back. |
void |
verifyReceivedQueueMessageAcknowledged(int indexOfSession,
int indexOfQueue,
int indexOfMessage)
Verifies that message received by a temporary queue is acknowledged. |
void |
verifyReceivedQueueMessageAcknowledged(java.lang.String nameOfQueue,
int indexOfMessage)
Verifies that a received message is acknowledged. |
void |
verifyReceivedQueueMessageEquals(int indexOfSession,
int indexOfQueue,
int indexOfSourceMessage,
MockMessage targetMessage)
Verifies that a message received by a temporary queue is equal to the specified message by calling the equals() method. |
void |
verifyReceivedQueueMessageEquals(java.lang.String nameOfQueue,
int indexOfSourceMessage,
MockMessage targetMessage)
Verifies that a received message is equal to the specified message by calling the equals() method. |
void |
verifyReceivedQueueMessageNotAcknowledged(int indexOfSession,
int indexOfQueue,
int indexOfMessage)
Verifies that a received by a temporary queue is not acknowledged. |
void |
verifyReceivedQueueMessageNotAcknowledged(java.lang.String nameOfQueue,
int indexOfMessage)
Verifies that a received message is not acknowledged. |
void |
verifyReceivedTopicMessageAcknowledged(int indexOfSession,
int indexOfTopic,
int indexOfMessage)
Verifies that a message received by a temporary topic is acknowledged. |
void |
verifyReceivedTopicMessageAcknowledged(java.lang.String nameOfTopic,
int indexOfMessage)
Verifies that a received message is acknowledged. |
void |
verifyReceivedTopicMessageEquals(int indexOfSession,
int indexOfTopic,
int indexOfSourceMessage,
MockMessage targetMessage)
Verifies that a message received by a temporary topic is equal to the specified message by calling the equals() method. |
void |
verifyReceivedTopicMessageEquals(java.lang.String nameOfTopic,
int indexOfSourceMessage,
MockMessage targetMessage)
Verifies that a received message is equal to the specified message by calling the equals() method. |
void |
verifyReceivedTopicMessageNotAcknowledged(int indexOfSession,
int indexOfTopic,
int indexOfMessage)
Verifies that a message received by a temporary topic is not acknowledged. |
void |
verifyReceivedTopicMessageNotAcknowledged(java.lang.String nameOfTopic,
int indexOfMessage)
Verifies that a received message is not acknowledged. |
void |
verifySessionClosed(int indexOfSession)
Verifies that the session with the specified index is closed. |
void |
verifySessionCommitted(int indexOfSession)
Verifies that the session with the specified index was committed. |
void |
verifySessionNotCommitted(int indexOfSession)
Verifies that the session with the specified index was not committed. |
void |
verifySessionNotRecovered(int indexOfSession)
Verifies that the session with the specified index was not recovered. |
void |
verifySessionNotRolledBack(int indexOfSession)
Verifies that the session with the specified index was not rolled back. |
void |
verifySessionNumberCommits(int indexOfSession,
int numberOfCommits)
Verifies the number of commits of session with the specified index. |
void |
verifySessionNumberRollbacks(int indexOfSession,
int numberOfRollbacks)
Verifies the number of rollbacks of session with the specified index. |
void |
verifySessionRecovered(int indexOfSession)
Verifies that the session with the specified index was recovered. |
void |
verifySessionRolledBack(int indexOfSession)
Verifies that the session with the specified index was rolled back. |
void |
verifyTemporaryQueueDeleted(int indexOfSession,
int indexOfQueue)
Verifies that the temporary queue with the specified index was deleted. |
void |
verifyTemporaryTopicDeleted(int indexOfSession,
int indexOfTopic)
Verifies that the temporary topic with the specified index was closed. |
void |
verifyTopicConnectionClosed()
Verifies that the current MockTopicConnection is closed. |
void |
verifyTopicConnectionStarted()
Verifies that the current MockTopicConnection is started. |
void |
verifyTopicConnectionStopped()
Verifies that the current MockTopicConnection is stopped. |
void |
verifyTopicPublisherClosed(int indexOfSession,
java.lang.String topicName,
int indexOfPublisher)
Verifies that the specified publisher is closed. |
void |
verifyTopicSessionClosed(int indexOfSession)
Verifies that the topic session with the specified index is closed. |
void |
verifyTopicSessionCommitted(int indexOfSession)
Verifies that the topic session with the specified index was committed. |
void |
verifyTopicSessionNotCommitted(int indexOfSession)
Verifies that the topic session with the specified index was not committed. |
void |
verifyTopicSessionNotRecovered(int indexOfSession)
Verifies that the topic session with the specified index was not recovered. |
void |
verifyTopicSessionNotRolledBack(int indexOfSession)
Verifies that the topic session with the specified index was not rolled back. |
void |
verifyTopicSessionNumberCommits(int indexOfSession,
int numberOfCommits)
Verifies the number of commits of the topic session with the specified index. |
void |
verifyTopicSessionNumberRollbacks(int indexOfSession,
int numberOfRollbacks)
Verifies the number of rollbacks of the topic session with the specified index. |
void |
verifyTopicSessionRecovered(int indexOfSession)
Verifies that the topic session with the specified index was recovered. |
void |
verifyTopicSessionRolledBack(int indexOfSession)
Verifies that the topic session with the specified index was rolled back. |
void |
verifyTopicSubscriberClosed(int indexOfSession,
java.lang.String topicName,
int indexOfSubscriber)
Verifies that the specified subscriber is closed. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public JMSTestModule(JMSMockObjectFactory mockFactory)
Method Detail |
---|
public void setCurrentQueueConnectionIndex(int connectionIndex)
MockQueueConnection
that should be used
for the current test. Per default the latest created connection
is used.
connectionIndex
- the index of the connectionpublic MockQueueConnection getCurrentQueueConnection()
MockQueueConnection
based on its
index or null
if no queue connection
was created. The connection has to be created using the
MockQueueConnectionFactory
.
public void setCurrentTopicConnectionIndex(int connectionIndex)
MockTopicConnection
that should be used
for the current test. Per default the latest created connection
is used.
connectionIndex
- the index of the connectionpublic MockTopicConnection getCurrentTopicConnection()
MockTopicConnection
based on its
index or null
if no topic connection
was created. The connection has to be created using the
MockTopicConnectionFactory
.
public void setCurrentConnectionIndex(int connectionIndex)
MockConnection
that should be used
for the current test. Per default the latest created connection
is used.
connectionIndex
- the index of the connectionpublic MockConnection getCurrentConnection()
MockConnection
based on its
index or null
if no connection
was created. The connection has to be created using the
MockConnectionFactory
.
public void registerTestMessageListenerForQueue(java.lang.String queueName, javax.jms.MessageListener listener)
MockQueueConnectionFactory
for
creating the connection and the session. If you want to use the
MockConnectionFactory
you have to create the connection on your own
and call registerTestMessageListenerForQueue(MockConnection, String, MessageListener)
.
queueName
- the name of the queue used for message receivinglistener
- the listener that should be registeredpublic void registerTestMessageListenerForQueue(MockConnection connection, java.lang.String queueName, javax.jms.MessageListener listener)
connection
- the connection used for creating the sessionqueueName
- the name of the queue used for message receivinglistener
- the listener that should be registeredpublic void registerTestMessageListenerForQueue(MockConnection connection, java.lang.String queueName, boolean transacted, int acknowledgeMode, javax.jms.MessageListener listener)
connection
- the connection used for creating the sessionqueueName
- the name of the queue used for message receivingtransacted
- should the created session be transactedacknowledgeMode
- the acknowledge mode of the created sessionlistener
- the listener that should be registeredpublic void registerTestMessageListenerForQueue(MockConnection connection, java.lang.String queueName, boolean transacted, int acknowledgeMode, java.lang.String messageSelector, javax.jms.MessageListener listener)
connection
- the connection used for creating the sessionqueueName
- the name of the queue used for message receivingtransacted
- should the created session be transactedacknowledgeMode
- the acknowledge mode of the created sessionmessageSelector
- the message selectorlistener
- the listener that should be registeredpublic void registerTestMessageListenerForTopic(java.lang.String topicName, javax.jms.MessageListener listener)
MockTopicConnectionFactory
for
creating the connection and the session. If you want to use the
MockConnectionFactory
you have to create the connection on your own
and call registerTestMessageListenerForTopic(MockConnection, String, MessageListener)
.
topicName
- the name of the topic used for message receivinglistener
- the listener that should be registeredpublic void registerTestMessageListenerForTopic(MockConnection connection, java.lang.String topicName, javax.jms.MessageListener listener)
connection
- the connection used for creating the sessiontopicName
- the name of the topic used for message receivinglistener
- the listener that should be registeredpublic void registerTestMessageListenerForTopic(MockConnection connection, java.lang.String topicName, boolean transacted, int acknowledgeMode, javax.jms.MessageListener listener)
connection
- the connection used for creating the sessiontopicName
- the name of the topic used for message receivingtransacted
- should the created session be transactedacknowledgeMode
- the acknowledge mode of the created sessionlistener
- the listener that should be registeredpublic void registerTestMessageListenerForTopic(MockConnection connection, java.lang.String topicName, boolean transacted, int acknowledgeMode, java.lang.String messageSelector, javax.jms.MessageListener listener)
connection
- the connection used for creating the sessiontopicName
- the name of the topic used for message receivingtransacted
- should the created session be transactedacknowledgeMode
- the acknowledge mode of the created sessionmessageSelector
- the message selectorlistener
- the listener that should be registeredpublic DestinationManager getDestinationManager()
DestinationManager
.
DestinationManager
public ConfigurationManager getConfigurationManager()
ConfigurationManager
.
ConfigurationManager
public MessageManager getQueueMessageManager(int indexOfSession)
MessageManager
for the specified session
or null
if the session does not exist. The returned
MessageManager
is used to keep track of messages sent
to queues.
The session has to be created using the current MockQueueConnection
.
indexOfSession
- the index of the session
MessageManager
public MessageManager getTopicMessageManager(int indexOfSession)
MessageManager
for the specified session
or null
if the session does not exist. The returned
MessageManager
is used to keep track of messages sent
to topics.
The session has to be created using the current MockTopicConnection
.
indexOfSession
- the index of the session
MessageManager
public MessageManager getMessageManager(int indexOfSession)
MessageManager
for the specified session
or null
if the session does not exist. The returned
MessageManager
is used to keep track of messages sent
to topics.
The session has to be created using the current MockConnection
.
indexOfSession
- the index of the session
MessageManager
public QueueTransmissionManager getQueueTransmissionManager(int indexOfSession)
QueueTransmissionManager
for the specified session
or null
if the session does not exist.
The session has to be created using the current MockQueueConnection
.
indexOfSession
- the index of the session
QueueTransmissionManager
public TopicTransmissionManager getTopicTransmissionManager(int indexOfSession)
TopicTransmissionManager
for the specified session
or null
if the session does not exist.
The session has to be created using the current MockTopicConnection
.
indexOfSession
- the index of the session
TopicTransmissionManager
public TransmissionManagerWrapper getTransmissionManager(int indexOfSession)
getTransmissionManagerWrapper(int)
public TransmissionManagerWrapper getTransmissionManagerWrapper(int indexOfSession)
TransmissionManagerWrapper
for the specified session
or null
if the session does not exist.
The session has to be created using the current MockConnection
.
indexOfSession
- the index of the session
TransmissionManagerWrapper
public TransmissionManagerWrapper getQueueTransmissionManagerWrapper(int indexOfSession)
TransmissionManagerWrapper
for the specified session
or null
if the session does not exist.
The session has to be created using the current MockQueueConnection
.
indexOfSession
- the index of the session
TransmissionManagerWrapper
public TransmissionManagerWrapper getTopicTransmissionManagerWrapper(int indexOfSession)
TransmissionManagerWrapper
for the specified session
or null
if the session does not exist.
The session has to be created using the current MockTopicConnection
.
indexOfSession
- the index of the session
TransmissionManagerWrapper
public java.util.List getQueueSessionList()
MockQueueSession
objects.
The sessions have been created using the current MockQueueConnection
.
MockQueueSession
listpublic java.util.List getTopicSessionList()
MockTopicSession
objects.
The sessions have been created using the current MockTopicConnection
.
MockTopicSession
listpublic java.util.List getSessionList()
MockSession
objects.
The sessions have been created using the current MockConnection
.
MockSession
listpublic MockQueueSession getQueueSession(int indexOfSession)
MockQueueSession
for the specified index
or null
if the session does not exist.
The session has to be created using the current MockQueueConnection
.
indexOfSession
- the index of the session
MockQueueSession
public MockTopicSession getTopicSession(int indexOfSession)
MockTopicSession
for the specified index
or null
if the session does not exist.
The session has to be created using the current MockTopicConnection
.
indexOfSession
- the index of the session
MockTopicSession
public MockSession getSession(int indexOfSession)
MockSession
for the specified index
or null
if the session does not exist.
The session has to be created using the current MockConnection
.
indexOfSession
- the index of the session
MockSession
public MockQueue getQueue(java.lang.String name)
MockQueue
with the specified name
or null
if no such queue exists.
name
- the name of the queue
MockQueue
public MockTopic getTopic(java.lang.String name)
MockTopic
with the specified name
or null
if no such topic exists.
name
- the name of the topic
MockTopic
public java.util.List getTemporaryQueueList(int indexOfSession)
MockTemporaryQueue
objects
for the specified session. The session has to be created using
the current MockQueueConnection
.
indexOfSession
- the index of the session
MockTemporaryQueue
listpublic java.util.List getTemporaryTopicList(int indexOfSession)
MockTemporaryTopic
objects
for the specified session. The session has to be created using
the current MockTopicConnection
.
indexOfSession
- the index of the session
MockTemporaryTopic
listpublic MockTemporaryQueue getTemporaryQueue(int indexOfSession, int indexOfQueue)
MockTemporaryQueue
with the specified index
for the specified session. Returns null
if no such
temporary queue exists. The session has to be created using
the current MockQueueConnection
.
indexOfSession
- the index of the sessionindexOfQueue
- the index of the temporary queue
MockTemporaryQueue
public MockTemporaryTopic getTemporaryTopic(int indexOfSession, int indexOfTopic)
MockTemporaryTopic
with the specified index
for the specified session. Returns null
if no such
temporary queue exists. The session has to be created using
the current MockTopicConnection
.
indexOfSession
- the index of the sessionindexOfTopic
- the index of the temporary queue
MockTemporaryTopic
public java.util.List getCurrentMessageListFromQueue(java.lang.String name)
null
if no such queue exists.
name
- the name of the queue
public java.util.List getCurrentMessageListFromTemporaryQueue(int indexOfSession, int indexOfQueue)
null
if no such queue exists.
The session has to be created using the current MockQueueConnection
.
indexOfSession
- the index of the sessionindexOfQueue
- the index of the temporary queue
public java.util.List getReceivedMessageListFromQueue(java.lang.String name)
null
if no such queue exists.
name
- the name of the queue
public java.util.List getReceivedMessageListFromTemporaryQueue(int indexOfSession, int indexOfQueue)
null
if no such queue exists.
The session has to be created using the current MockQueueConnection
.
indexOfSession
- the index of the sessionindexOfQueue
- the index of the temporary queue
public java.util.List getCurrentMessageListFromTopic(java.lang.String name)
null
if no such topic exists.
name
- the name of the queue
public java.util.List getCurrentMessageListFromTemporaryTopic(int indexOfSession, int indexOfTopic)
null
if no such topic exists.
The session has to be created using the current MockTopicConnection
.
indexOfSession
- the index of the sessionindexOfTopic
- the index of the temporary topic
public java.util.List getReceivedMessageListFromTopic(java.lang.String name)
null
if no such topic exists.
name
- the name of the topic
public java.util.List getReceivedMessageListFromTemporaryTopic(int indexOfSession, int indexOfTopic)
null
if no such topic exists.
The session has to be created using the current MockTopicConnection
.
indexOfSession
- the index of the sessionindexOfTopic
- the index of the temporary topic
public void verifyQueueConnectionClosed()
MockQueueConnection
is closed.
The connection has to be created using the current MockQueueConnectionFactory
.
VerifyFailedException
- if verification failspublic void verifyQueueConnectionStarted()
MockQueueConnection
is started.
The connection has to be created using the current MockQueueConnectionFactory
.
VerifyFailedException
- if verification failspublic void verifyQueueConnectionStopped()
MockQueueConnection
is stopped.
The connection has to be created using the current MockQueueConnectionFactory
.
VerifyFailedException
- if verification failspublic void verifyTopicConnectionClosed()
MockTopicConnection
is closed.
The connection has to be created using the current MockTopicConnectionFactory
.
VerifyFailedException
- if verification failspublic void verifyTopicConnectionStarted()
MockTopicConnection
is started.
The connection has to be created using the current MockTopicConnectionFactory
.
VerifyFailedException
- if verification failspublic void verifyTopicConnectionStopped()
MockTopicConnection
is stopped.
The connection has to be created using the current MockTopicConnectionFactory
.
VerifyFailedException
- if verification failspublic void verifyConnectionClosed()
MockConnection
is closed.
The connection has to be created using the current MockConnectionFactory
.
VerifyFailedException
- if verification failspublic void verifyConnectionStarted()
MockConnection
is started.
The connection has to be created using the current MockConnectionFactory
.
VerifyFailedException
- if verification failspublic void verifyConnectionStopped()
MockConnection
is stopped.
The connection has to be created using the current MockConnectionFactory
.
VerifyFailedException
- if verification failspublic void verifyQueueSessionClosed(int indexOfSession)
MockQueueConnection
.
indexOfSession
- the index of the session
VerifyFailedException
- if verification failspublic void verifyQueueSessionCommitted(int indexOfSession)
MockQueueConnection
.
indexOfSession
- the index of the session
VerifyFailedException
- if verification failspublic void verifyQueueSessionNotCommitted(int indexOfSession)
MockQueueConnection
.
indexOfSession
- the index of the session
VerifyFailedException
- if verification failspublic void verifyQueueSessionNumberCommits(int indexOfSession, int numberOfCommits)
MockQueueConnection
.
indexOfSession
- the index of the sessionnumberOfCommits
- the expected number of commits
VerifyFailedException
- if verification failspublic void verifyQueueSessionRolledBack(int indexOfSession)
MockQueueConnection
.
indexOfSession
- the index of the session
VerifyFailedException
- if verification failspublic void verifyQueueSessionNotRolledBack(int indexOfSession)
MockQueueConnection
.
indexOfSession
- the index of the session
VerifyFailedException
- if verification failspublic void verifyQueueSessionNumberRollbacks(int indexOfSession, int numberOfRollbacks)
MockQueueConnection
.
indexOfSession
- the index of the sessionnumberOfRollbacks
- the expected number of rollbacks
VerifyFailedException
- if verification failspublic void verifyQueueSessionRecovered(int indexOfSession)
MockQueueConnection
.
indexOfSession
- the index of the session
VerifyFailedException
- if verification failspublic void verifyQueueSessionNotRecovered(int indexOfSession)
MockQueueConnection
.
indexOfSession
- the index of the session
VerifyFailedException
- if verification failspublic void verifyTopicSessionClosed(int indexOfSession)
MockTopicConnection
.
indexOfSession
- the index of the session
VerifyFailedException
- if verification failspublic void verifyTopicSessionCommitted(int indexOfSession)
MockTopicConnection
.
indexOfSession
- the index of the session
VerifyFailedException
- if verification failspublic void verifyTopicSessionNotCommitted(int indexOfSession)
MockTopicConnection
.
indexOfSession
- the index of the session
VerifyFailedException
- if verification failspublic void verifyTopicSessionNumberCommits(int indexOfSession, int numberOfCommits)
MockTopicConnection
.
indexOfSession
- the index of the sessionnumberOfCommits
- the expected number of commits
VerifyFailedException
- if verification failspublic void verifyTopicSessionRolledBack(int indexOfSession)
MockTopicConnection
.
indexOfSession
- the index of the session
VerifyFailedException
- if verification failspublic void verifyTopicSessionNotRolledBack(int indexOfSession)
MockTopicConnection
.
indexOfSession
- the index of the session
VerifyFailedException
- if verification failspublic void verifyTopicSessionNumberRollbacks(int indexOfSession, int numberOfRollbacks)
MockTopicConnection
.
indexOfSession
- the index of the sessionnumberOfRollbacks
- the expected number of rollbacks
VerifyFailedException
- if verification failspublic void verifyTopicSessionRecovered(int indexOfSession)
MockTopicConnection
.
indexOfSession
- the index of the session
VerifyFailedException
- if verification failspublic void verifyTopicSessionNotRecovered(int indexOfSession)
MockTopicConnection
.
indexOfSession
- the index of the session
VerifyFailedException
- if verification failspublic void verifySessionClosed(int indexOfSession)
MockConnection
.
indexOfSession
- the index of the session
VerifyFailedException
- if verification failspublic void verifySessionCommitted(int indexOfSession)
MockConnection
.
indexOfSession
- the index of the session
VerifyFailedException
- if verification failspublic void verifySessionNotCommitted(int indexOfSession)
MockConnection
.
indexOfSession
- the index of the session
VerifyFailedException
- if verification failspublic void verifySessionNumberCommits(int indexOfSession, int numberOfCommits)
MockConnection
.
indexOfSession
- the index of the sessionnumberOfCommits
- the expected number of commits
VerifyFailedException
- if verification failspublic void verifySessionRolledBack(int indexOfSession)
MockConnection
.
indexOfSession
- the index of the session
VerifyFailedException
- if verification failspublic void verifySessionNotRolledBack(int indexOfSession)
MockConnection
.
indexOfSession
- the index of the session
VerifyFailedException
- if verification failspublic void verifySessionNumberRollbacks(int indexOfSession, int numberOfRollbacks)
MockConnection
.
indexOfSession
- the index of the sessionnumberOfRollbacks
- the expected number of rollbacks
VerifyFailedException
- if verification failspublic void verifySessionRecovered(int indexOfSession)
MockConnection
.
indexOfSession
- the index of the session
VerifyFailedException
- if verification failspublic void verifySessionNotRecovered(int indexOfSession)
MockConnection
.
indexOfSession
- the index of the session
VerifyFailedException
- if verification failspublic void verifyAllQueueSessionsClosed()
MockQueueConnection
.
VerifyFailedException
- if verification failspublic void verifyAllQueueSessionsRecovered()
MockQueueConnection
.
VerifyFailedException
- if verification failspublic void verifyAllQueueSessionsCommitted()
MockQueueConnection
.
VerifyFailedException
- if verification failspublic void verifyAllQueueSessionsRolledBack()
MockQueueConnection
.
VerifyFailedException
- if verification failspublic void verifyAllTopicSessionsClosed()
MockTopicConnection
.
VerifyFailedException
- if verification failspublic void verifyAllTopicSessionsRecovered()
MockTopicConnection
.
VerifyFailedException
- if verification failspublic void verifyAllTopicSessionsCommitted()
MockTopicConnection
.
VerifyFailedException
- if verification failspublic void verifyAllTopicSessionsRolledBack()
MockTopicConnection
.
VerifyFailedException
- if verification failspublic void verifyAllSessionsClosed()
MockConnection
.
VerifyFailedException
- if verification failspublic void verifyAllSessionsRecovered()
MockConnection
.
VerifyFailedException
- if verification failspublic void verifyAllSessionsCommitted()
MockConnection
.
VerifyFailedException
- if verification failspublic void verifyAllSessionsRolledBack()
MockConnection
.
VerifyFailedException
- if verification failspublic void verifyNumberMessageProducers(int indexOfSession, int numberOfProducers)
MockConnection
.
indexOfSession
- the index of the sessionnumberOfProducers
- the expected number of producers
VerifyFailedException
- if verification failspublic void verifyAllMessageProducersClosed(int indexOfSession)
MockConnection
.
indexOfSession
- the index of the session
VerifyFailedException
- if verification failspublic void verifyNumberQueueSenders(int indexOfSession, int numberOfSenders)
MockQueueConnection
.
indexOfSession
- the index of the sessionnumberOfSenders
- the expected number of senders
VerifyFailedException
- if verification failspublic void verifyNumberQueueSenders(int indexOfSession, java.lang.String queueName, int numberOfSenders)
MockQueueConnection
.
indexOfSession
- the index of the sessionqueueName
- the name of the queuenumberOfSenders
- the expected number of senders
VerifyFailedException
- if verification failspublic void verifyQueueSenderClosed(int indexOfSession, java.lang.String queueName, int indexOfSender)
MockQueueConnection
.
indexOfSession
- the index of the sessionqueueName
- the name of the queueindexOfSender
- the index of the sender
VerifyFailedException
- if verification failspublic void verifyAllQueueSendersClosed(int indexOfSession)
MockQueueConnection
.
indexOfSession
- the index of the session
VerifyFailedException
- if verification failspublic void verifyNumberTopicPublishers(int indexOfSession, int numberOfPublishers)
MockTopicConnection
.
indexOfSession
- the index of the sessionnumberOfPublishers
- the expected number of publishers
VerifyFailedException
- if verification failspublic void verifyNumberTopicPublishers(int indexOfSession, java.lang.String topicName, int numberOfPublishers)
MockTopicConnection
.
indexOfSession
- the index of the sessiontopicName
- the name of the topicnumberOfPublishers
- the expected number of publishers
VerifyFailedException
- if verification failspublic void verifyTopicPublisherClosed(int indexOfSession, java.lang.String topicName, int indexOfPublisher)
MockTopicConnection
.
indexOfSession
- the index of the sessiontopicName
- the name of the topicindexOfPublisher
- the index of the publisher
VerifyFailedException
- if verification failspublic void verifyAllTopicPublishersClosed(int indexOfSession)
MockTopicConnection
.
indexOfSession
- the index of the session
VerifyFailedException
- if verification failspublic void verifyNumberMessageConsumers(int indexOfSession, int numberOfConsumers)
MockConnection
.
indexOfSession
- the index of the sessionnumberOfConsumers
- the expected number of consumers
VerifyFailedException
- if verification failspublic void verifyAllMessageConsumersClosed(int indexOfSession)
MockConnection
.
indexOfSession
- the index of the session
VerifyFailedException
- if verification failspublic void verifyNumberQueueReceivers(int indexOfSession, int numberOfReceivers)
MockQueueConnection
.
indexOfSession
- the index of the sessionnumberOfReceivers
- the expected number of receivers
VerifyFailedException
- if verification failspublic void verifyNumberQueueReceivers(int indexOfSession, java.lang.String queueName, int numberOfReceivers)
MockQueueConnection
.
indexOfSession
- the index of the sessionqueueName
- the name of the queuenumberOfReceivers
- the expected number of receivers
VerifyFailedException
- if verification failspublic void verifyQueueReceiverClosed(int indexOfSession, java.lang.String queueName, int indexOfReceiver)
MockQueueConnection
.
indexOfSession
- the index of the sessionqueueName
- the name of the queueindexOfReceiver
- the index of the receiver
VerifyFailedException
- if verification failspublic void verifyAllQueueReceiversClosed(int indexOfSession)
MockQueueConnection
.
indexOfSession
- the index of the session
VerifyFailedException
- if verification failspublic void verifyNumberTopicSubscribers(int indexOfSession, int numberOfSubscribers)
MockTopicConnection
.
indexOfSession
- the index of the sessionnumberOfSubscribers
- the expected number of subscribers
VerifyFailedException
- if verification failspublic void verifyNumberTopicSubscribers(int indexOfSession, java.lang.String topicName, int numberOfSubscribers)
MockTopicConnection
.
indexOfSession
- the index of the sessiontopicName
- the name of the topicnumberOfSubscribers
- the expected number of subscribers
VerifyFailedException
- if verification failspublic void verifyTopicSubscriberClosed(int indexOfSession, java.lang.String topicName, int indexOfSubscriber)
MockTopicConnection
.
indexOfSession
- the index of the sessiontopicName
- the name of the topicindexOfSubscriber
- the index of the receiver
VerifyFailedException
- if verification failspublic void verifyAllTopicSubscribersClosed(int indexOfSession)
MockTopicConnection
.
indexOfSession
- the index of the session
VerifyFailedException
- if verification failspublic void verifyNumberQueueBrowsers(int indexOfSession, int numberOfBrowsers)
MockQueueConnection
.
indexOfSession
- the index of the sessionnumberOfBrowsers
- the expected number of browsers
VerifyFailedException
- if verification failspublic void verifyNumberQueueBrowsers(int indexOfSession, java.lang.String queueName, int numberOfBrowsers)
MockQueueConnection
.
indexOfSession
- the index of the sessionqueueName
- the name of the queuenumberOfBrowsers
- the expected number of browsers
VerifyFailedException
- if verification failspublic void verifyQueueBrowserClosed(int indexOfSession, java.lang.String queueName, int indexOfBrowser)
MockQueueConnection
.
indexOfSession
- the index of the sessionqueueName
- the name of the queueindexOfBrowser
- the index of the browser
VerifyFailedException
- if verification failspublic void verifyAllQueueBrowsersClosed(int indexOfSession)
MockQueueConnection
.
indexOfSession
- the index of the session
VerifyFailedException
- if verification failspublic void verifyDurableTopicSubscriberPresent(int indexOfSession, java.lang.String name)
MockTopicConnection
.
indexOfSession
- the index of the sessionname
- the name of the subscription
VerifyFailedException
- if verification failspublic void verifyNumberDurableTopicSubscribers(int indexOfSession, int numberOfSubscribers)
MockTopicConnection
.
indexOfSession
- the index of the sessionnumberOfSubscribers
- the expected number of durable subscribers
VerifyFailedException
- if verification failspublic void verifyNumberDurableTopicSubscribers(int indexOfSession, java.lang.String topicName, int numberOfSubscribers)
MockTopicConnection
.
indexOfSession
- the index of the sessiontopicName
- the name of the topicnumberOfSubscribers
- the expected number of durable subscribers
VerifyFailedException
- if verification failspublic void verifyDurableTopicSubscriberClosed(int indexOfSession, java.lang.String name)
MockTopicConnection
.
indexOfSession
- the index of the sessionname
- the name of the subscription
VerifyFailedException
- if verification failspublic void verifyAllDurableTopicSubscribersClosed(int indexOfSession)
MockTopicConnection
.
indexOfSession
- the index of the session
VerifyFailedException
- if verification failspublic void verifyNumberQueueSessions(int number)
MockQueueConnection
.
number
- the expected number of queue sessions
VerifyFailedException
- if verification failspublic void verifyNumberTopicSessions(int number)
MockTopicConnection
.
number
- the expected number of topic sessions
VerifyFailedException
- if verification failspublic void verifyNumberSessions(int number)
MockConnection
.
number
- the expected number of sessions
VerifyFailedException
- if verification failspublic void verifyNumberTemporaryQueues(int indexOfSession, int numberQueues)
MockQueueConnection
.
indexOfSession
- the index of the sessionnumberQueues
- the expected number of temporary queues
VerifyFailedException
- if verification failspublic void verifyNumberTemporaryTopics(int indexOfSession, int numberTopics)
MockTopicConnection
.
indexOfSession
- the index of the sessionnumberTopics
- the expected number of temporary topics
VerifyFailedException
- if verification failspublic void verifyTemporaryQueueDeleted(int indexOfSession, int indexOfQueue)
MockQueueConnection
.
indexOfSession
- the index of the sessionindexOfQueue
- the index of the queue
VerifyFailedException
- if verification failspublic void verifyAllTemporaryQueuesDeleted(int indexOfSession)
MockQueueConnection
.
indexOfSession
- the index of the session
VerifyFailedException
- if verification failspublic void verifyTemporaryTopicDeleted(int indexOfSession, int indexOfTopic)
MockTopicConnection
.
indexOfSession
- the index of the sessionindexOfTopic
- the index of the topic
VerifyFailedException
- if verification failspublic void verifyAllTemporaryTopicsDeleted(int indexOfSession)
MockTopicConnection
.
indexOfSession
- the index of the session
VerifyFailedException
- if verification failspublic void verifyMessageEquals(MockMessage message1, MockMessage message2)
equals()
method. All mock messages provide a
suitable implementation of equals()
.
message1
- the first messagemessage2
- the second message
VerifyFailedException
- if verification failspublic void verifyCurrentQueueMessageEquals(java.lang.String nameOfQueue, int indexOfSourceMessage, MockMessage targetMessage)
equals()
method.
All mock messages provide a suitable implementation of equals()
.
nameOfQueue
- the name of the queueindexOfSourceMessage
- the index of the message in the queuetargetMessage
- the message that will be used for comparison
VerifyFailedException
- if verification failspublic void verifyReceivedQueueMessageEquals(java.lang.String nameOfQueue, int indexOfSourceMessage, MockMessage targetMessage)
equals()
method.
All mock messages provide a suitable implementation of equals()
.
nameOfQueue
- the name of the queueindexOfSourceMessage
- the index of the received messagetargetMessage
- the message that will be used for comparison
VerifyFailedException
- if verification failspublic void verifyCurrentQueueMessageEquals(int indexOfSession, int indexOfQueue, int indexOfSourceMessage, MockMessage targetMessage)
equals()
method.
All mock messages provide a suitable implementation of equals()
.
The session has to be created using the current MockQueueConnection
.
indexOfSession
- the index of the sessionindexOfQueue
- the index of the temporary queueindexOfSourceMessage
- the index of the message in the queuetargetMessage
- the message that will be used for comparison
VerifyFailedException
- if verification failspublic void verifyReceivedQueueMessageEquals(int indexOfSession, int indexOfQueue, int indexOfSourceMessage, MockMessage targetMessage)
equals()
method.
All mock messages provide a suitable implementation of equals()
.
The session has to be created using the current MockQueueConnection
.
indexOfSession
- the index of the sessionindexOfQueue
- the index of the temporary queueindexOfSourceMessage
- the index of the received messagetargetMessage
- the message that will be used for comparison
VerifyFailedException
- if verification failspublic void verifyNumberOfCurrentQueueMessages(java.lang.String nameOfQueue, int numberOfMessages)
nameOfQueue
- the name of the queuenumberOfMessages
- the expected number of messages
VerifyFailedException
- if verification failspublic void verifyNumberOfReceivedQueueMessages(java.lang.String nameOfQueue, int numberOfMessages)
nameOfQueue
- the name of the queuenumberOfMessages
- the expected number of messages
VerifyFailedException
- if verification failspublic void verifyNumberOfCurrentQueueMessages(int indexOfSession, int indexOfQueue, int numberOfMessages)
MockQueueConnection
.
indexOfSession
- the index of the sessionindexOfQueue
- the index of the temporary queuenumberOfMessages
- the expected number of messages
VerifyFailedException
- if verification failspublic void verifyNumberOfReceivedQueueMessages(int indexOfSession, int indexOfQueue, int numberOfMessages)
MockQueueConnection
.
indexOfSession
- the index of the sessionindexOfQueue
- the index of the temporary queuenumberOfMessages
- the expected number of messages
VerifyFailedException
- if verification failspublic void verifyAllReceivedQueueMessagesAcknowledged(java.lang.String nameOfQueue)
nameOfQueue
- the name of the queue
VerifyFailedException
- if verification failspublic void verifyAllReceivedQueueMessagesAcknowledged(int indexOfSession, int indexOfQueue)
MockQueueConnection
.
indexOfSession
- the index of the sessionindexOfQueue
- the index of the temporary queue
VerifyFailedException
- if verification failspublic void verifyReceivedQueueMessageAcknowledged(java.lang.String nameOfQueue, int indexOfMessage)
nameOfQueue
- the name of the queueindexOfMessage
- the index of the received message
VerifyFailedException
- if verification failspublic void verifyReceivedQueueMessageNotAcknowledged(java.lang.String nameOfQueue, int indexOfMessage)
nameOfQueue
- the name of the queueindexOfMessage
- the index of the received message
VerifyFailedException
- if verification failspublic void verifyReceivedQueueMessageAcknowledged(int indexOfSession, int indexOfQueue, int indexOfMessage)
MockQueueConnection
.
indexOfSession
- the index of the sessionindexOfQueue
- the index of the temporary queueindexOfMessage
- the index of the received message
VerifyFailedException
- if verification failspublic void verifyReceivedQueueMessageNotAcknowledged(int indexOfSession, int indexOfQueue, int indexOfMessage)
MockQueueConnection
.
indexOfSession
- the index of the sessionindexOfQueue
- the index of the temporary queueindexOfMessage
- the index of the received message
VerifyFailedException
- if verification failspublic void verifyNumberOfCreatedQueueMessages(int indexOfSession, int number)
MockSession.createMessage()
.
The session has to be created using the current MockQueueConnection
.
indexOfSession
- the index of the sessionnumber
- the expected number of messages
VerifyFailedException
- if verification failspublic void verifyNumberOfCreatedQueueBytesMessages(int indexOfSession, int number)
MockSession.createBytesMessage()
.
The session has to be created using the current MockQueueConnection
.
indexOfSession
- the index of the sessionnumber
- the expected number of bytes messages
VerifyFailedException
- if verification failspublic void verifyNumberOfCreatedQueueMapMessages(int indexOfSession, int number)
MockSession.createMapMessage()
.
The session has to be created using the current MockQueueConnection
.
indexOfSession
- the index of the sessionnumber
- the expected number of map messages
VerifyFailedException
- if verification failspublic void verifyNumberOfCreatedQueueTextMessages(int indexOfSession, int number)
MockSession.createTextMessage()
.
The session has to be created using the current MockQueueConnection
.
indexOfSession
- the index of the sessionnumber
- the expected number of text messages
VerifyFailedException
- if verification failspublic void verifyNumberOfCreatedQueueStreamMessages(int indexOfSession, int number)
MockSession.createStreamMessage()
.
The session has to be created using the current MockQueueConnection
.
indexOfSession
- the index of the sessionnumber
- the expected number of stream messages
VerifyFailedException
- if verification failspublic void verifyNumberOfCreatedQueueObjectMessages(int indexOfSession, int number)
MockSession.createObjectMessage()
.
The session has to be created using the current MockQueueConnection
.
indexOfSession
- the index of the sessionnumber
- the expected number of object messages
VerifyFailedException
- if verification failspublic void verifyCreatedQueueMessageAcknowledged(int indexOfSession, int indexOfMessage)
MockSession.createMessage()
is acknowledged.
This method makes sense if messages are not cloned
when sending them. This is the default, use ConfigurationManager.setDoCloneOnSend(boolean)
.
If messages are cloned, the cloned message is acknowledged instead of
the created message.
The session has to be created using the current MockQueueConnection
.
indexOfSession
- the index of the sessionindexOfMessage
- the index of the message
VerifyFailedException
- if verification failspublic void verifyCreatedQueueMessageNotAcknowledged(int indexOfSession, int indexOfMessage)
MockSession.createMessage()
is not acknowledged.
This method makes sense if messages are not cloned
when sending them. This is the default, use ConfigurationManager.setDoCloneOnSend(boolean)
.
If messages are cloned, the cloned message is acknowledged instead of
the created message.
The session has to be created using the current MockQueueConnection
.
indexOfSession
- the index of the sessionindexOfMessage
- the index of the message
VerifyFailedException
- if verification failspublic void verifyCreatedQueueBytesMessageAcknowledged(int indexOfSession, int indexOfMessage)
MockSession.createMessage()
is acknowledged.
This method makes sense if messages are not cloned
when sending them. This is the default, use ConfigurationManager.setDoCloneOnSend(boolean)
.
If messages are cloned, the cloned message is acknowledged instead of
the created message.
The session has to be created using the current MockQueueConnection
.
indexOfSession
- the index of the sessionindexOfMessage
- the index of the message
VerifyFailedException
- if verification failspublic void verifyCreatedQueueBytesMessageNotAcknowledged(int indexOfSession, int indexOfMessage)
MockSession.createMessage()
is not acknowledged.
This method makes sense if messages are not cloned
when sending them. This is the default, use ConfigurationManager.setDoCloneOnSend(boolean)
.
If messages are cloned, the cloned message is acknowledged instead of
the created message.
The session has to be created using the current MockQueueConnection
.
indexOfSession
- the index of the sessionindexOfMessage
- the index of the message
VerifyFailedException
- if verification failspublic void verifyCreatedQueueMapMessageAcknowledged(int indexOfSession, int indexOfMessage)
MockSession.createMessage()
is acknowledged.
This method makes sense if messages are not cloned
when sending them. This is the default, use ConfigurationManager.setDoCloneOnSend(boolean)
.
If messages are cloned, the cloned message is acknowledged instead of
the created message.
The session has to be created using the current MockQueueConnection
.
indexOfSession
- the index of the sessionindexOfMessage
- the index of the message
VerifyFailedException
- if verification failspublic void verifyCreatedQueueMapMessageNotAcknowledged(int indexOfSession, int indexOfMessage)
MockSession.createMessage()
is not acknowledged.
This method makes sense if messages are not cloned
when sending them. This is the default, use ConfigurationManager.setDoCloneOnSend(boolean)
.
If messages are cloned, the cloned message is acknowledged instead of
the created message.
The session has to be created using the current MockQueueConnection
.
indexOfSession
- the index of the sessionindexOfMessage
- the index of the message
VerifyFailedException
- if verification failspublic void verifyCreatedQueueTextMessageAcknowledged(int indexOfSession, int indexOfMessage)
MockSession.createMessage()
is acknowledged.
This method makes sense if messages are not cloned
when sending them. This is the default, use ConfigurationManager.setDoCloneOnSend(boolean)
.
If messages are cloned, the cloned message is acknowledged instead of
the created message.
The session has to be created using the current MockQueueConnection
.
indexOfSession
- the index of the sessionindexOfMessage
- the index of the message
VerifyFailedException
- if verification failspublic void verifyCreatedQueueTextMessageNotAcknowledged(int indexOfSession, int indexOfMessage)
MockSession.createMessage()
is not acknowledged.
This method makes sense if messages are not cloned
when sending them. This is the default, use ConfigurationManager.setDoCloneOnSend(boolean)
.
If messages are cloned, the cloned message is acknowledged instead of
the created message.
The session has to be created using the current MockQueueConnection
.
indexOfSession
- the index of the sessionindexOfMessage
- the index of the message
VerifyFailedException
- if verification failspublic void verifyCreatedQueueStreamMessageAcknowledged(int indexOfSession, int indexOfMessage)
MockSession.createMessage()
is acknowledged.
This method makes sense if messages are not cloned
when sending them. This is the default, use ConfigurationManager.setDoCloneOnSend(boolean)
.
If messages are cloned, the cloned message is acknowledged instead of
the created message.
The session has to be created using the current MockQueueConnection
.
indexOfSession
- the index of the sessionindexOfMessage
- the index of the message
VerifyFailedException
- if verification failspublic void verifyCreatedQueueStreamMessageNotAcknowledged(int indexOfSession, int indexOfMessage)
MockSession.createMessage()
is not acknowledged.
This method makes sense if messages are not cloned
when sending them. This is the default, use ConfigurationManager.setDoCloneOnSend(boolean)
.
If messages are cloned, the cloned message is acknowledged instead of
the created message.
The session has to be created using the current MockQueueConnection
.
indexOfSession
- the index of the sessionindexOfMessage
- the index of the message
VerifyFailedException
- if verification failspublic void verifyCreatedQueueObjectMessageAcknowledged(int indexOfSession, int indexOfMessage)
MockSession.createMessage()
is acknowledged.
This method makes sense if messages are not cloned
when sending them. This is the default, use ConfigurationManager.setDoCloneOnSend(boolean)
.
If messages are cloned, the cloned message is acknowledged instead of
the created message.
The session has to be created using the current MockQueueConnection
.
indexOfSession
- the index of the sessionindexOfMessage
- the index of the message
VerifyFailedException
- if verification failspublic void verifyCreatedQueueObjectMessageNotAcknowledged(int indexOfSession, int indexOfMessage)
MockSession.createMessage()
is not acknowledged.
This method makes sense if messages are not cloned
when sending them. This is the default, use ConfigurationManager.setDoCloneOnSend(boolean)
.
If messages are cloned, the cloned message is acknowledged instead of
the created message.
The session has to be created using the current MockQueueConnection
.
indexOfSession
- the index of the sessionindexOfMessage
- the index of the message
VerifyFailedException
- if verification failspublic void verifyCurrentTopicMessageEquals(java.lang.String nameOfTopic, int indexOfSourceMessage, MockMessage targetMessage)
equals()
method.
All mock messages provide a suitable implementation of equals()
.
nameOfTopic
- the name of the topicindexOfSourceMessage
- the index of the message in the topictargetMessage
- the message that will be used for comparison
VerifyFailedException
- if verification failspublic void verifyReceivedTopicMessageEquals(java.lang.String nameOfTopic, int indexOfSourceMessage, MockMessage targetMessage)
equals()
method.
All mock messages provide a suitable implementation of equals()
.
nameOfTopic
- the name of the topicindexOfSourceMessage
- the index of the received messagetargetMessage
- the message that will be used for comparison
VerifyFailedException
- if verification failspublic void verifyCurrentTopicMessageEquals(int indexOfSession, int indexOfTopic, int indexOfSourceMessage, MockMessage targetMessage)
equals()
method.
All mock messages provide a suitable implementation of equals()
.
The session has to be created using the current MockTopicConnection
.
indexOfSession
- the index of the sessionindexOfTopic
- the index of the temporary topicindexOfSourceMessage
- the index of the message in the topictargetMessage
- the message that will be used for comparison
VerifyFailedException
- if verification failspublic void verifyReceivedTopicMessageEquals(int indexOfSession, int indexOfTopic, int indexOfSourceMessage, MockMessage targetMessage)
equals()
method.
All mock messages provide a suitable implementation of equals()
.
The session has to be created using the current MockTopicConnection
.
indexOfSession
- the index of the sessionindexOfTopic
- the index of the temporary topicindexOfSourceMessage
- the index of the received messagetargetMessage
- the message that will be used for comparison
VerifyFailedException
- if verification failspublic void verifyNumberOfCurrentTopicMessages(java.lang.String nameOfTopic, int numberOfMessages)
nameOfTopic
- the name of the topicnumberOfMessages
- the expected number of messages
VerifyFailedException
- if verification failspublic void verifyNumberOfReceivedTopicMessages(java.lang.String nameOfTopic, int numberOfMessages)
nameOfTopic
- the name of the topicnumberOfMessages
- the expected number of messages
VerifyFailedException
- if verification failspublic void verifyNumberOfCurrentTopicMessages(int indexOfSession, int indexOfTopic, int numberOfMessages)
MockTopicConnection
.
indexOfSession
- the index of the sessionindexOfTopic
- the index of the temporary topicnumberOfMessages
- the expected number of messages
VerifyFailedException
- if verification failspublic void verifyNumberOfReceivedTopicMessages(int indexOfSession, int indexOfTopic, int numberOfMessages)
MockTopicConnection
.
indexOfSession
- the index of the sessionindexOfTopic
- the index of the temporary topicnumberOfMessages
- the expected number of messages
VerifyFailedException
- if verification failspublic void verifyAllReceivedTopicMessagesAcknowledged(java.lang.String nameOfTopic)
nameOfTopic
- the name of the topic
VerifyFailedException
- if verification failspublic void verifyAllReceivedTopicMessagesAcknowledged(int indexOfSession, int indexOfTopic)
MockTopicConnection
.
indexOfSession
- the index of the sessionindexOfTopic
- the index of the temporary topic
VerifyFailedException
- if verification failspublic void verifyReceivedTopicMessageAcknowledged(java.lang.String nameOfTopic, int indexOfMessage)
nameOfTopic
- the name of the topicindexOfMessage
- the index of the received message
VerifyFailedException
- if verification failspublic void verifyReceivedTopicMessageNotAcknowledged(java.lang.String nameOfTopic, int indexOfMessage)
nameOfTopic
- the name of the topicindexOfMessage
- the index of the received message
VerifyFailedException
- if verification failspublic void verifyReceivedTopicMessageAcknowledged(int indexOfSession, int indexOfTopic, int indexOfMessage)
MockTopicConnection
.
indexOfSession
- the index of the sessionindexOfTopic
- the index of the temporary topicindexOfMessage
- the index of the received message
VerifyFailedException
- if verification failspublic void verifyReceivedTopicMessageNotAcknowledged(int indexOfSession, int indexOfTopic, int indexOfMessage)
MockTopicConnection
.
indexOfSession
- the index of the sessionindexOfTopic
- the index of the temporary topicindexOfMessage
- the index of the received message
VerifyFailedException
- if verification failspublic void verifyNumberOfCreatedTopicMessages(int indexOfSession, int number)
MockSession.createMessage()
.
The session has to be created using the current MockTopicConnection
.
indexOfSession
- the index of the sessionnumber
- the expected number of messages
VerifyFailedException
- if verification failspublic void verifyNumberOfCreatedTopicBytesMessages(int indexOfSession, int number)
MockSession.createBytesMessage()
.
The session has to be created using the current MockTopicConnection
.
indexOfSession
- the index of the sessionnumber
- the expected number of bytes messages
VerifyFailedException
- if verification failspublic void verifyNumberOfCreatedTopicMapMessages(int indexOfSession, int number)
MockSession.createMapMessage()
.
The session has to be created using the current MockTopicConnection
.
indexOfSession
- the index of the sessionnumber
- the expected number of map messages
VerifyFailedException
- if verification failspublic void verifyNumberOfCreatedTopicTextMessages(int indexOfSession, int number)
MockSession.createTextMessage()
.
The session has to be created using the current MockTopicConnection
.
indexOfSession
- the index of the sessionnumber
- the expected number of text messages
VerifyFailedException
- if verification failspublic void verifyNumberOfCreatedTopicStreamMessages(int indexOfSession, int number)
MockSession.createStreamMessage()
.
The session has to be created using the current MockTopicConnection
.
indexOfSession
- the index of the sessionnumber
- the expected number of stream messages
VerifyFailedException
- if verification failspublic void verifyNumberOfCreatedTopicObjectMessages(int indexOfSession, int number)
MockSession.createObjectMessage()
.
The session has to be created using the current MockTopicConnection
.
indexOfSession
- the index of the sessionnumber
- the expected number of object messages
VerifyFailedException
- if verification failspublic void verifyCreatedTopicMessageAcknowledged(int indexOfSession, int indexOfMessage)
MockSession.createMessage()
is acknowledged. This method makes sense if messages are not cloned
when sending them. This is the default, use ConfigurationManager.setDoCloneOnSend(boolean)
.
If messages are cloned, the cloned message is acknowledged instead of
the created message.
The session has to be created using the current MockTopicConnection
.
indexOfSession
- the index of the sessionindexOfMessage
- the index of the message
VerifyFailedException
- if verification failspublic void verifyCreatedTopicMessageNotAcknowledged(int indexOfSession, int indexOfMessage)
MockSession.createMessage()
is not acknowledged. This method makes sense if messages are not cloned
when sending them. This is the default, use ConfigurationManager.setDoCloneOnSend(boolean)
.
If messages are cloned, the cloned message is acknowledged instead of
the created message.
The session has to be created using the current MockTopicConnection
.
indexOfSession
- the index of the sessionindexOfMessage
- the index of the message
VerifyFailedException
- if verification failspublic void verifyCreatedTopicBytesMessageAcknowledged(int indexOfSession, int indexOfMessage)
MockSession.createMessage()
is acknowledged. This method makes sense if messages are not cloned
when sending them. This is the default, use ConfigurationManager.setDoCloneOnSend(boolean)
.
If messages are cloned, the cloned message is acknowledged instead of
the created message.
The session has to be created using the current MockTopicConnection
.
indexOfSession
- the index of the sessionindexOfMessage
- the index of the message
VerifyFailedException
- if verification failspublic void verifyCreatedTopicBytesMessageNotAcknowledged(int indexOfSession, int indexOfMessage)
MockSession.createMessage()
is not acknowledged. This method makes sense if messages are not cloned
when sending them. This is the default, use ConfigurationManager.setDoCloneOnSend(boolean)
.
If messages are cloned, the cloned message is acknowledged instead of
the created message.
The session has to be created using the current MockTopicConnection
.
indexOfSession
- the index of the sessionindexOfMessage
- the index of the message
VerifyFailedException
- if verification failspublic void verifyCreatedTopicMapMessageAcknowledged(int indexOfSession, int indexOfMessage)
MockSession.createMessage()
is acknowledged. This method makes sense if messages are not cloned
when sending them. This is the default, use ConfigurationManager.setDoCloneOnSend(boolean)
.
If messages are cloned, the cloned message is acknowledged instead of
the created message.
The session has to be created using the current MockTopicConnection
.
indexOfSession
- the index of the sessionindexOfMessage
- the index of the message
VerifyFailedException
- if verification failspublic void verifyCreatedTopicMapMessageNotAcknowledged(int indexOfSession, int indexOfMessage)
MockSession.createMessage()
is not acknowledged. This method makes sense if messages are not cloned
when sending them. This is the default, use ConfigurationManager.setDoCloneOnSend(boolean)
.
If messages are cloned, the cloned message is acknowledged instead of
the created message.
The session has to be created using the current MockTopicConnection
.
indexOfSession
- the index of the sessionindexOfMessage
- the index of the message
VerifyFailedException
- if verification failspublic void verifyCreatedTopicTextMessageAcknowledged(int indexOfSession, int indexOfMessage)
MockSession.createMessage()
is acknowledged. This method makes sense if messages are not cloned
when sending them. This is the default, use ConfigurationManager.setDoCloneOnSend(boolean)
.
If messages are cloned, the cloned message is acknowledged instead of
the created message.
The session has to be created using the current MockTopicConnection
.
indexOfSession
- the index of the sessionindexOfMessage
- the index of the message
VerifyFailedException
- if verification failspublic void verifyCreatedTopicTextMessageNotAcknowledged(int indexOfSession, int indexOfMessage)
MockSession.createMessage()
is not acknowledged. This method makes sense if messages are not cloned
when sending them. This is the default, use ConfigurationManager.setDoCloneOnSend(boolean)
.
If messages are cloned, the cloned message is acknowledged instead of
the created message.
The session has to be created using the current MockTopicConnection
.
indexOfSession
- the index of the sessionindexOfMessage
- the index of the message
VerifyFailedException
- if verification failspublic void verifyCreatedTopicStreamMessageAcknowledged(int indexOfSession, int indexOfMessage)
MockSession.createMessage()
is acknowledged. This method makes sense if messages are not cloned
when sending them. This is the default, use ConfigurationManager.setDoCloneOnSend(boolean)
.
If messages are cloned, the cloned message is acknowledged instead of
the created message.
The session has to be created using the current MockTopicConnection
.
indexOfSession
- the index of the sessionindexOfMessage
- the index of the message
VerifyFailedException
- if verification failspublic void verifyCreatedTopicStreamMessageNotAcknowledged(int indexOfSession, int indexOfMessage)
MockSession.createMessage()
is not acknowledged. This method makes sense if messages are not cloned
when sending them. This is the default, use ConfigurationManager.setDoCloneOnSend(boolean)
.
If messages are cloned, the cloned message is acknowledged instead of
the created message.
The session has to be created using the current MockTopicConnection
.
indexOfSession
- the index of the sessionindexOfMessage
- the index of the message
VerifyFailedException
- if verification failspublic void verifyCreatedTopicObjectMessageAcknowledged(int indexOfSession, int indexOfMessage)
MockSession.createMessage()
is acknowledged. This method makes sense if messages are not cloned
when sending them. This is the default, use ConfigurationManager.setDoCloneOnSend(boolean)
.
If messages are cloned, the cloned message is acknowledged instead of
the created message.
The session has to be created using the current MockTopicConnection
.
indexOfSession
- the index of the sessionindexOfMessage
- the index of the message
VerifyFailedException
- if verification failspublic void verifyCreatedTopicObjectMessageNotAcknowledged(int indexOfSession, int indexOfMessage)
MockSession.createMessage()
is not acknowledged. This method makes sense if messages are not cloned
when sending them. This is the default, use ConfigurationManager.setDoCloneOnSend(boolean)
.
If messages are cloned, the cloned message is acknowledged instead of
the created message.
The session has to be created using the current MockTopicConnection
.
indexOfSession
- the index of the sessionindexOfMessage
- the index of the message
VerifyFailedException
- if verification failspublic void verifyNumberOfCreatedMessages(int indexOfSession, int number)
MockSession.createMessage()
.
The session has to be created using the current MockConnection
.
indexOfSession
- the index of the sessionnumber
- the expected number of messages
VerifyFailedException
- if verification failspublic void verifyNumberOfCreatedBytesMessages(int indexOfSession, int number)
MockSession.createBytesMessage()
.
The session has to be created using the current MockConnection
.
indexOfSession
- the index of the sessionnumber
- the expected number of bytes messages
VerifyFailedException
- if verification failspublic void verifyNumberOfCreatedMapMessages(int indexOfSession, int number)
MockSession.createMapMessage()
.
The session has to be created using the current MockConnection
.
indexOfSession
- the index of the sessionnumber
- the expected number of map messages
VerifyFailedException
- if verification failspublic void verifyNumberOfCreatedTextMessages(int indexOfSession, int number)
MockSession.createTextMessage()
.
The session has to be created using the current MockConnection
.
indexOfSession
- the index of the sessionnumber
- the expected number of text messages
VerifyFailedException
- if verification failspublic void verifyNumberOfCreatedStreamMessages(int indexOfSession, int number)
MockSession.createStreamMessage()
.
The session has to be created using the current MockConnection
.
indexOfSession
- the index of the sessionnumber
- the expected number of stream messages
VerifyFailedException
- if verification failspublic void verifyNumberOfCreatedObjectMessages(int indexOfSession, int number)
MockSession.createObjectMessage()
.
The session has to be created using the current MockConnection
.
indexOfSession
- the index of the sessionnumber
- the expected number of object messages
VerifyFailedException
- if verification failspublic void verifyCreatedMessageAcknowledged(int indexOfSession, int indexOfMessage)
MockSession.createMessage()
is acknowledged. This method makes sense if messages are not cloned
when sending them. This is the default, use ConfigurationManager.setDoCloneOnSend(boolean)
.
If messages are cloned, the cloned message is acknowledged instead of
the created message.
The session has to be created using the current MockConnection
.
indexOfSession
- the index of the sessionindexOfMessage
- the index of the message
VerifyFailedException
- if verification failspublic void verifyCreatedMessageNotAcknowledged(int indexOfSession, int indexOfMessage)
MockSession.createMessage()
is not acknowledged. This method makes sense if messages are not cloned
when sending them. This is the default, use ConfigurationManager.setDoCloneOnSend(boolean)
.
If messages are cloned, the cloned message is acknowledged instead of
the created message.
The session has to be created using the current MockConnection
.
indexOfSession
- the index of the sessionindexOfMessage
- the index of the message
VerifyFailedException
- if verification failspublic void verifyCreatedBytesMessageAcknowledged(int indexOfSession, int indexOfMessage)
MockSession.createMessage()
is acknowledged. This method makes sense if messages are not cloned
when sending them. This is the default, use ConfigurationManager.setDoCloneOnSend(boolean)
.
If messages are cloned, the cloned message is acknowledged instead of
the created message.
The session has to be created using the current MockConnection
.
indexOfSession
- the index of the sessionindexOfMessage
- the index of the message
VerifyFailedException
- if verification failspublic void verifyCreatedBytesMessageNotAcknowledged(int indexOfSession, int indexOfMessage)
MockSession.createMessage()
is not acknowledged. This method makes sense if messages are not cloned
when sending them. This is the default, use ConfigurationManager.setDoCloneOnSend(boolean)
.
If messages are cloned, the cloned message is acknowledged instead of
the created message.
The session has to be created using the current MockConnection
.
indexOfSession
- the index of the sessionindexOfMessage
- the index of the message
VerifyFailedException
- if verification failspublic void verifyCreatedMapMessageAcknowledged(int indexOfSession, int indexOfMessage)
MockSession.createMessage()
is acknowledged. This method makes sense if messages are not cloned
when sending them. This is the default, use ConfigurationManager.setDoCloneOnSend(boolean)
.
If messages are cloned, the cloned message is acknowledged instead of
the created message.
The session has to be created using the current MockConnection
.
indexOfSession
- the index of the sessionindexOfMessage
- the index of the message
VerifyFailedException
- if verification failspublic void verifyCreatedMapMessageNotAcknowledged(int indexOfSession, int indexOfMessage)
MockSession.createMessage()
is not acknowledged. This method makes sense if messages are not cloned
when sending them. This is the default, use ConfigurationManager.setDoCloneOnSend(boolean)
.
If messages are cloned, the cloned message is acknowledged instead of
the created message.
The session has to be created using the current MockConnection
.
indexOfSession
- the index of the sessionindexOfMessage
- the index of the message
VerifyFailedException
- if verification failspublic void verifyCreatedTextMessageAcknowledged(int indexOfSession, int indexOfMessage)
MockSession.createMessage()
is acknowledged. This method makes sense if messages are not cloned
when sending them. This is the default, use ConfigurationManager.setDoCloneOnSend(boolean)
.
If messages are cloned, the cloned message is acknowledged instead of
the created message.
The session has to be created using the current MockConnection
.
indexOfSession
- the index of the sessionindexOfMessage
- the index of the message
VerifyFailedException
- if verification failspublic void verifyCreatedTextMessageNotAcknowledged(int indexOfSession, int indexOfMessage)
MockSession.createMessage()
is not acknowledged. This method makes sense if messages are not cloned
when sending them. This is the default, use ConfigurationManager.setDoCloneOnSend(boolean)
.
If messages are cloned, the cloned message is acknowledged instead of
the created message.
The session has to be created using the current MockConnection
.
indexOfSession
- the index of the sessionindexOfMessage
- the index of the message
VerifyFailedException
- if verification failspublic void verifyCreatedStreamMessageAcknowledged(int indexOfSession, int indexOfMessage)
MockSession.createMessage()
is acknowledged. This method makes sense if messages are not cloned
when sending them. This is the default, use ConfigurationManager.setDoCloneOnSend(boolean)
.
If messages are cloned, the cloned message is acknowledged instead of
the created message.
The session has to be created using the current MockConnection
.
indexOfSession
- the index of the sessionindexOfMessage
- the index of the message
VerifyFailedException
- if verification failspublic void verifyCreatedStreamMessageNotAcknowledged(int indexOfSession, int indexOfMessage)
MockSession.createMessage()
is not acknowledged. This method makes sense if messages are not cloned
when sending them. This is the default, use ConfigurationManager.setDoCloneOnSend(boolean)
.
If messages are cloned, the cloned message is acknowledged instead of
the created message.
The session has to be created using the current MockConnection
.
indexOfSession
- the index of the sessionindexOfMessage
- the index of the message
VerifyFailedException
- if verification failspublic void verifyCreatedObjectMessageAcknowledged(int indexOfSession, int indexOfMessage)
MockSession.createMessage()
is acknowledged. This method makes sense if messages are not cloned
when sending them. This is the default, use ConfigurationManager.setDoCloneOnSend(boolean)
.
If messages are cloned, the cloned message is acknowledged instead of
the created message.
The session has to be created using the current MockConnection
.
indexOfSession
- the index of the sessionindexOfMessage
- the index of the message
VerifyFailedException
- if verification failspublic void verifyCreatedObjectMessageNotAcknowledged(int indexOfSession, int indexOfMessage)
MockSession.createMessage()
is not acknowledged. This method makes sense if messages are not cloned
when sending them. This is the default, use ConfigurationManager.setDoCloneOnSend(boolean)
.
If messages are cloned, the cloned message is acknowledged instead of
the created message.
The session has to be created using the current MockConnection
.
indexOfSession
- the index of the sessionindexOfMessage
- the index of the message
VerifyFailedException
- if verification fails
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |