Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

updated javadoc 

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@359832 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
James Strachan 2005-12-29 16:08:59 +00:00
parent 312f2489a3
commit f051364d6b
1 changed files with 16 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
activemq-core/src/test/java/org/apache/activemq/util/MessageList.java
View File

@ -27,7 +27,14 @@ import java.util.List;
import junit.framework.Assert;
/**
* A simple container for performing testing and rendezvous style code.
* A simple container of messages for performing testing and rendezvous style
* code. You can use this class a {@link 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
* {@link #setParent(MessageListener)} method so that you can aggregate the
* total number of messages consumed across a number of consumers.
*
* @version $Revision: 1.6 $
*/
@ -61,7 +68,7 @@ public class MessageList extends Assert implements MessageListener {
public String toString() {
synchronized (semaphore) {
return messages.toString();
return messages.toString();
}
}
@ -81,7 +88,7 @@ public class MessageList extends Assert implements MessageListener {
return new ArrayList(messages);
}
}
public synchronized List getTextMessages() {
synchronized (semaphore) {
ArrayList l = new ArrayList();
@ -89,8 +96,9 @@ public class MessageList extends Assert implements MessageListener {
try {
TextMessage m = (TextMessage) iter.next();
l.add(m.getText());
} catch (Throwable e) {
l.add(""+e);
}
catch (Throwable e) {
l.add("" + e);
}
}
return l;
@ -163,7 +171,6 @@ public class MessageList extends Assert implements MessageListener {
assertTrue("at most: " + messageCount + " messages received. Actual: " + actual, actual <= messageCount);
}
public boolean hasReceivedMessage() {
return getMessageCount() == 0;
}
@ -185,11 +192,11 @@ public class MessageList extends Assert implements MessageListener {
}
/**
* Allows a parent listener to be specified such as to aggregate messages consumed across consumers
* Allows a parent listener to be specified such as to aggregate messages
* consumed across consumers
*/
public void setParent(MessageListener parent) {
this.parent = parent;
}
}