@Test public void testMockSQSConnectorWillBeEmptyWhenReset() throws Exception { _mockSQSConnector.sendMessage(_queue, _queueMessage); _mockSQSConnector.sendMessage(_publishableTopic, _topicMessage); _mockSQSConnector.reset(); NevadoMessage resultQueueMessage = _mockSQSConnector.receiveMessage(_nevadoConnection, _queue, DEFAULT_TIMEOUT); NevadoMessage resultTopicMessage = _mockSQSConnector.receiveMessage(_nevadoConnection, _subscribableTopic, DEFAULT_TIMEOUT); Assert.assertNull("queue message was returned and connector should have been reset", resultQueueMessage); Assert.assertNull("topic message was returned and connector should have been reset", resultTopicMessage); }
@Override public void reset() { Collection<MockSQSQueue> mockSQSQueues = buildSetOfAllMockQueues(); for (MockSQSQueue mockSQSQueue : mockSQSQueues) { mockSQSQueue.reset(); } }
MockSQSConnector extends AbstractSQSConnector implements ResettableMock { @Override public void reset() { Collection<MockSQSQueue> mockSQSQueues = buildSetOfAllMockQueues(); for (MockSQSQueue mockSQSQueue : mockSQSQueues) { mockSQSQueue.reset(); } } }
MockSQSConnector extends AbstractSQSConnector implements ResettableMock { @Override public void reset() { Collection<MockSQSQueue> mockSQSQueues = buildSetOfAllMockQueues(); for (MockSQSQueue mockSQSQueue : mockSQSQueues) { mockSQSQueue.reset(); } } MockSQSConnector();  MockSQSConnector(long receiveCheckIntervalMs); }
MockSQSConnector extends AbstractSQSConnector implements ResettableMock { @Override public void reset() { Collection<MockSQSQueue> mockSQSQueues = buildSetOfAllMockQueues(); for (MockSQSQueue mockSQSQueue : mockSQSQueues) { mockSQSQueue.reset(); } } MockSQSConnector();  MockSQSConnector(long receiveCheckIntervalMs); @Override void test(); @Override Collection<NevadoQueue> listQueues(String temporaryQueuePrefix); @Override NevadoTopic createTopic(String topicName); @Override void deleteTopic(NevadoTopic topic); @Override Collection<NevadoTopic> listTopics(); @Override String subscribe(NevadoTopic topic, NevadoQueue topicEndpoint); @Override void unsubscribe(NevadoTopic topic); @Override void reset(); }
MockSQSConnector extends AbstractSQSConnector implements ResettableMock { @Override public void reset() { Collection<MockSQSQueue> mockSQSQueues = buildSetOfAllMockQueues(); for (MockSQSQueue mockSQSQueue : mockSQSQueues) { mockSQSQueue.reset(); } } MockSQSConnector();  MockSQSConnector(long receiveCheckIntervalMs); @Override void test(); @Override Collection<NevadoQueue> listQueues(String temporaryQueuePrefix); @Override NevadoTopic createTopic(String topicName); @Override void deleteTopic(NevadoTopic topic); @Override Collection<NevadoTopic> listTopics(); @Override String subscribe(NevadoTopic topic, NevadoQueue topicEndpoint); @Override void unsubscribe(NevadoTopic topic); @Override void reset(); static final String MESSAGE_ATTRIBUTE_RECEIVE_COUNT; }