Add support to BufferPerformanceMetrics for connecting to a remote host.

Author: David R. MacIver

test/src/com/rabbitmq/examples/BufferPerformanceMetrics.java

@@ -10,6 +10,14 @@
 import java.io.IOException;
 import java.util.Random;
 
+import org.apache.commons.cli.CommandLine;
+import org.apache.commons.cli.CommandLineParser;
+import org.apache.commons.cli.GnuParser;
+import org.apache.commons.cli.HelpFormatter;
+import org.apache.commons.cli.Option;
+import org.apache.commons.cli.Options;
+import org.apache.commons.cli.ParseException;
+
 /**
  * Class to explore how performance of sending and receiving messages varies with the buffer size and 
  * enabling/disabling Nagle's algorithm.
@@ -26,10 +34,15 @@ public class BufferPerformanceMetrics{
     public static final int PEAK_SIZE = 20 * 1024;
 
     public static void main(String[] args) throws Exception{
+        String hostName = args.length > 0 ? args[0] : "localhost"; 
+
         Random rnd = new Random();
 
         System.out.println("buffer size, publish rate with nagle, get rate with nagle," + 
             " publish rate without nagle, get rate without nagle");
+    
+      
+
         for(int repeat = 0; repeat < REPEATS; repeat++){
             final int bufferSize = 1 + rnd.nextInt(PEAK_SIZE);
 
@@ -43,7 +56,8 @@ public static void main(String[] args) throws Exception{
                         socket.setSendBufferSize(bufferSize);
                     }
                 };
-                Connection connection = factory.newConnection("localhost");
+
+                Connection connection = factory.newConnection(hostName);
                 Channel channel = connection.createChannel();
                 channel.exchangeDeclare(EXCHANGE, "direct");
                 channel.queueDeclare(QUEUE);