org.activemq.spring
Class TestingConsumer

java.lang.Object
  extended by org.activemq.spring.TestingConsumer
All Implemented Interfaces:
MessageListener

public class TestingConsumer
extends Object
implements MessageListener

A simple consumer which is useful for testing which can be used to wait until the consumer has received a specific number of messages.

Version:
$Revision$
Author:
Mike Perham

Constructor Summary
TestingConsumer()
           
TestingConsumer(Object semaphore)
           
 
Method Summary
 List flushMessages()
           
protected  boolean hasReceivedMessage()
           
protected  boolean hasReceivedMessages(int messageCount)
           
 void onMessage(Message message)
           
 void waitForMessagesToArrive(int messageCount)
           
 void waitForMessageToArrive()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

TestingConsumer

public TestingConsumer()

TestingConsumer

public TestingConsumer(Object semaphore)
Method Detail

flushMessages

public List flushMessages()
Returns:
all the messages on the list so far, clearing the buffer

onMessage

public void onMessage(Message message)
Specified by:
onMessage in interface MessageListener

waitForMessageToArrive

public void waitForMessageToArrive()

waitForMessagesToArrive

public void waitForMessagesToArrive(int messageCount)

hasReceivedMessage

protected boolean hasReceivedMessage()

hasReceivedMessages

protected boolean hasReceivedMessages(int messageCount)


Copyright © 2004-2008 Protique, Ltd.. All Rights Reserved.