From cec545424fdbab73d20c0f57cdce9489dd5e8bfb Mon Sep 17 00:00:00 2001
From: Michael Klishin <mklishin@pivotal.io>
Date: Fri, 20 Nov 2015 03:48:52 +0300
Subject: [PATCH] Fixes #105

---
 .../rabbitmq/client/impl/recovery/AutorecoveringChannel.java  | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/src/com/rabbitmq/client/impl/recovery/AutorecoveringChannel.java b/src/com/rabbitmq/client/impl/recovery/AutorecoveringChannel.java
index be24390477..53dca98056 100644
--- a/src/com/rabbitmq/client/impl/recovery/AutorecoveringChannel.java
+++ b/src/com/rabbitmq/client/impl/recovery/AutorecoveringChannel.java
@@ -378,7 +378,9 @@ public String basicConsume(String queue, boolean autoAck, String consumerTag, bo
 
     public void basicCancel(String consumerTag) throws IOException {
         RecordedConsumer c = this.deleteRecordedConsumer(consumerTag);
-        this.maybeDeleteRecordedAutoDeleteQueue(c.getQueue());
+        if(c != null) {
+            this.maybeDeleteRecordedAutoDeleteQueue(c.getQueue());
+        }
         delegate.basicCancel(consumerTag);
     }