public class MemMessageIdList
extends java.lang.Object
implements javax.jms.MessageListener
MessageListener and then make
 assertions about how many messages it has received allowing a certain maximum
 amount of time to ensure that the test does not hang forever.
 
 Also you can chain these instances together with the
 setParent(MessageListener) method so that you can aggregate the
 total number of messages consumed across a number of consumers.| Modifier and Type | Field and Description | 
|---|---|
| protected static org.slf4j.Logger | LOG | 
| Constructor and Description | 
|---|
| MemMessageIdList() | 
| MemMessageIdList(java.lang.Object semaphore) | 
| Modifier and Type | Method and Description | 
|---|---|
| boolean | equals(java.lang.Object that) | 
| java.util.List<java.lang.String> | flushMessages() | 
| int | getMessageCount() | 
| java.util.List<java.lang.String> | getMessageIds() | 
| javax.jms.MessageListener | getParent() | 
| int | hashCode() | 
| boolean | hasReceivedMessage() | 
| boolean | hasReceivedMessages(int messageCount) | 
| boolean | isVerbose() | 
| void | onMessage(javax.jms.Message message) | 
| void | setParent(javax.jms.MessageListener parent)Allows a parent listener to be specified such as to aggregate messages
 consumed across consumers | 
| void | setVerbose(boolean verbose) | 
| java.lang.String | toString() | 
| void | waitForMessagesToArrive(int messageCount) | 
public MemMessageIdList()
public MemMessageIdList(java.lang.Object semaphore)
public boolean equals(java.lang.Object that)
equals in class java.lang.Objectpublic int hashCode()
hashCode in class java.lang.Objectpublic java.lang.String toString()
toString in class java.lang.Objectpublic java.util.List<java.lang.String> flushMessages()
public java.util.List<java.lang.String> getMessageIds()
public void onMessage(javax.jms.Message message)
onMessage in interface javax.jms.MessageListenerpublic int getMessageCount()
public void waitForMessagesToArrive(int messageCount)
public boolean hasReceivedMessage()
public boolean hasReceivedMessages(int messageCount)
public boolean isVerbose()
public void setVerbose(boolean verbose)
public javax.jms.MessageListener getParent()
public void setParent(javax.jms.MessageListener parent)
Copyright © 2005-2014 Red Hat, Inc.. All Rights Reserved.