If the connection breaks, don't hang awaiting this.

Simon MacMullen · Simon MacMullen · commit de60c33dd263 · 2014-10-06T15:09:48.000+01:00
diff --git a/test/src/com/rabbitmq/examples/perf/Consumer.java b/test/src/com/rabbitmq/examples/perf/Consumer.java
@@ -121,6 +121,11 @@ public void handleDelivery(String consumerTag, Envelope envelope, BasicPropertie
             }
         }
 
+        @Override
+        public void handleShutdownSignal(String consumerTag, ShutdownSignalException sig) {
+            latch.countDown();
+        }
+
         @Override
         public void handleCancel(String consumerTag) throws IOException {
             System.out.println("Consumer cancelled by broker. Re-consuming.");

Original file line number	Diff line number	Diff line change
`@@ -121,6 +121,11 @@ public void handleDelivery(String consumerTag, Envelope envelope, BasicPropertie`
`121`	`121`	`}`
`122`	`122`	`}`
`123`	`123`
	`124`	`+ @Override`
	`125`	`+ public void handleShutdownSignal(String consumerTag, ShutdownSignalException sig) {`
	`126`	`+ latch.countDown();`
	`127`	`+ }`
	`128`	`+`
`124`	`129`	`@Override`
`125`	`130`	`public void handleCancel(String consumerTag) throws IOException {`
`126`	`131`	`System.out.println("Consumer cancelled by broker. Re-consuming.");`