more sensible measurements

make sure messages have reached q before stopping publish timer and
starting consume timer.

Author: Matthias Radestock

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

@@ -69,20 +69,23 @@ public void configureSocket(Socket socket)
                 long start;
 
                 start = System.nanoTime();
+
                 for(int i = 0; i < MESSAGE_COUNT; i++) {
                     channel.basicPublish(EXCHANGE, ROUTING_KEY,
                                          MessageProperties.BASIC, MESSAGE);
                 }
-                long publishTime = System.nanoTime() - start;
-
-                start = System.nanoTime();
 
                 QueueingConsumer consumer = new QueueingConsumer(channel);
                 channel.basicConsume(QUEUE, true, consumer);
 
+                long publishTime = System.nanoTime() - start;
+
+                start = System.nanoTime();
+
                 for(int i = 0; i < MESSAGE_COUNT; i++){
                     consumer.nextDelivery();
                 }
+
                 long getTime = System.nanoTime() - start;
 
                 double publishRate =