Created new ping client that sends messages only. Usefull for examaning known queue states in mgmnt console.

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2@528424 13f79535-47bb-0310-9956-ffa450edef68

3 files changed, 67 insertions, 3 deletions

diff --git a/java/perftests/src/main/java/org/apache/qpid/ping/PingDurableClient.java b/java/perftests/src/main/java/org/apache/qpid/ping/PingDurableClient.java
index d56d31a1df..0e832ef100 100644
--- a/java/perftests/src/main/java/org/apache/qpid/ping/PingDurableClient.java
+++ b/java/perftests/src/main/java/org/apache/qpid/ping/PingDurableClient.java
@@ -1,3 +1,4 @@
+/* Copyright Rupert Smith, 2005 to 2006, all rights reserved. */

 /*

  *

  * Licensed to the Apache Software Foundation (ASF) under one

@@ -178,6 +179,7 @@ public class PingDurableClient extends PingPongProducer implements ExceptionList
 

             // Run the test procedure.

             int sent = pingProducer.send();

+            pingProducer.closeConnection();

             pingProducer.waitForUser("Press return to begin receiving the pings.");

             pingProducer.receive(sent);

 

@@ -302,6 +304,13 @@ public class PingDurableClient extends PingPongProducer implements ExceptionList
         System.out.println("Messages sent: " + messagesSent + ", Messages Committed = " + messagesCommitted

             + ", Messages not Committed = " + messagesNotCommitted);

 

+

+

+        return messagesSent;

+    }

+

+    protected void closeConnection()

+    {

         // Clean up the connection.

         try

         {

@@ -314,8 +323,6 @@ public class PingDurableClient extends PingPongProducer implements ExceptionList
 

             // Ignore as did best could manage to clean up.

         }

-

-        return messagesSent;

     }

 

     protected void receive(int messagesSent) throws Exception

diff --git a/java/perftests/src/main/java/org/apache/qpid/ping/PingSendOnlyClient.java b/java/perftests/src/main/java/org/apache/qpid/ping/PingSendOnlyClient.java
new file mode 100644
index 0000000000..7cf5e4516f
--- /dev/null
+++ b/java/perftests/src/main/java/org/apache/qpid/ping/PingSendOnlyClient.java
@@ -0,0 +1,57 @@
+/* Copyright Rupert Smith, 2005 to 2006, all rights reserved. */

+package org.apache.qpid.ping;

+

+import java.util.Properties;

+

+import org.apache.log4j.Logger;

+

+import org.apache.qpid.util.CommandLineParser;

+

+/**

+ * <p><table id="crc"><caption>CRC Card</caption>

+ * <tr><th> Responsibilities <th> Collaborations

+ * </table>

+ */

+public class PingSendOnlyClient extends PingDurableClient

+{

+    private static final Logger log = Logger.getLogger(PingSendOnlyClient.class);

+

+    public PingSendOnlyClient(Properties overrides) throws Exception

+    {

+        super(overrides);

+    }

+

+    /**

+     * Starts the ping/wait/receive process.

+     *

+     * @param args The command line arguments.

+     */

+    public static void main(String[] args)

+    {

+        try

+        {

+            // Create a ping producer overriding its defaults with all options passed on the command line.

+            Properties options = CommandLineParser.processCommandLine(args, new CommandLineParser(new String[][] {}));

+            PingDurableClient pingProducer = new PingSendOnlyClient(options);

+

+            // Create a shutdown hook to terminate the ping-pong producer.

+            Runtime.getRuntime().addShutdownHook(pingProducer.getShutdownHook());

+

+            // Ensure that the ping pong producer is registered to listen for exceptions on the connection too.

+            // pingProducer.getConnection().setExceptionListener(pingProducer);

+

+            // Run the test procedure.

+            int sent = pingProducer.send();

+            pingProducer.waitForUser("Press return to close connection and quit.");

+            pingProducer.closeConnection();

+

+            System.exit(0);

+        }

+        catch (Exception e)

+        {

+            System.err.println(e.getMessage());

+            log.error("Top level handler caught execption.", e);

+            System.exit(1);

+        }

+    }

+}

diff --git a/java/perftests/src/main/java/org/apache/qpid/requestreply/PingPongProducer.java b/java/perftests/src/main/java/org/apache/qpid/requestreply/PingPongProducer.java
index ce0181558f..ecaf27167f 100644
--- a/java/perftests/src/main/java/org/apache/qpid/requestreply/PingPongProducer.java
+++ b/java/perftests/src/main/java/org/apache/qpid/requestreply/PingPongProducer.java
@@ -1301,7 +1301,7 @@ public class PingPongProducer implements Runnable, MessageListener, ExceptionLis
      *

      * @param prompt The prompt to display on the console.

      */

-    protected void waitForUser(String prompt)

+    public void waitForUser(String prompt)

     {

         System.out.println(prompt);