You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by jo...@apache.org on 2010/08/19 22:40:26 UTC
svn commit: r987303 -
/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/Drain.java
Author: jonathan
Date: Thu Aug 19 20:40:26 2010
New Revision: 987303
URL: http://svn.apache.org/viewvc?rev=987303&view=rev
Log:
Added -c count parameter - exits after reading c messages.
Modified:
qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/Drain.java
Modified: qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/Drain.java
URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/Drain.java?rev=987303&r1=987302&r2=987303&view=diff
==============================================================================
--- qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/Drain.java (original)
+++ qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/Drain.java Thu Aug 19 20:40:26 2010
@@ -40,12 +40,21 @@ public class Drain extends OptionParser
null,
Boolean.class);
+ static final Option COUNT = new Option ("c",
+ "count",
+ "read c messages, then exit",
+ "COUNT",
+ "0",
+ Integer.class);
+
+
static
{
optDefs.add(BROKER);
optDefs.add(HELP);
optDefs.add(TIMEOUT);
optDefs.add(FOREVER);
+ optDefs.add(COUNT);
optDefs.add(CON_OPTIONS);
optDefs.add(BROKER_OPTIONS);
}
@@ -62,14 +71,24 @@ public class Drain extends OptionParser
Message msg;
long timeout = -1;
+ int count = 0;
+ int i = 0;
+
if (containsOp(TIMEOUT)) { timeout = Integer.parseInt(getOp(TIMEOUT))*1000; }
if (containsOp(FOREVER)) { timeout = 0; }
+ if (containsOp(COUNT)) { count = Integer.parseInt(getOp(COUNT)); }
while ((msg = consumer.receive(timeout)) != null)
{
System.out.println("\n------------- Msg -------------");
System.out.println(msg);
System.out.println("-------------------------------\n");
+
+ if (count > 0) {
+ if (++i == count) {
+ break;
+ }
+ }
}
ssn.close();
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:commits-subscribe@qpid.apache.org