Fix test

Author: acogoluegnes

src/main/java/com/rabbitmq/perf/Consumer.java

@@ -283,7 +283,8 @@ public void handleDelivery(
       this.maybeHandleMessage(envelope, properties, body, channel);
     }
 
-    private void maybeHandleMessage(Envelope envelope, BasicProperties properties, byte[] body, Channel ch) throws IOException {
+    private void maybeHandleMessage(
+        Envelope envelope, BasicProperties properties, byte[] body, Channel ch) throws IOException {
       if (ch.isOpen()) {
         handleMessage(envelope, properties, body, ch);
       }

src/test/java/com/rabbitmq/perf/MessageCountTimeLimitAndPublishingIntervalRateTest.java

@@ -337,6 +337,11 @@ public void consumerCount(int consumersCount, int channelsCount) throws Exceptio
     Channel channel =
         proxy(
             Channel.class,
+            callback(
+                "isOpen",
+                (proxy, method, args) -> {
+                  return true;
+                }),
             callback(
                 "basicConsume",
                 (proxy, method, args) -> {
@@ -458,6 +463,11 @@ void shouldAckOneLastTimeWhenQueueIsEmpty() throws Exception {
     Channel channel =
         proxy(
             Channel.class,
+            callback(
+                "isOpen",
+                (proxy, method, args) -> {
+                  return true;
+                }),
             callback(
                 "basicConsume",
                 (proxy, method, args) -> {
@@ -924,6 +934,11 @@ public void pollingWithBasicGet(int consumersCount, int channelsCount) throws Ex
     Channel channel =
         proxy(
             Channel.class,
+            callback(
+                "isOpen",
+                (proxy, method, args) -> {
+                  return true;
+                }),
             callback(
                 "basicGet",
                 (proxy, method, args) -> {
@@ -1014,6 +1029,11 @@ public void ackNack(String nackParameter) throws Exception {
     Channel channel =
         proxy(
             Channel.class,
+            callback(
+                "isOpen",
+                (proxy, method, args) -> {
+                  return true;
+                }),
             callback(
                 "basicConsume",
                 (proxy, method, args) -> {