Revert the removal of checkShutdown() in QueueingConsumer.

Author: Steve Powell

src/com/rabbitmq/client/QueueingConsumer.java

@@ -121,6 +121,7 @@ public QueueingConsumer(Channel ch, BlockingQueue<Delivery> q) {
                                byte[] body)
         throws IOException
     {
+//        checkShutdown();
         this._queue.add(new Delivery(envelope, properties, body));
     }
 
@@ -163,6 +164,14 @@ public byte[] getBody() {
         }
     }
 
+    /**
+     * Check if we are in shutdown mode and if so throw an exception.
+     */
+    private void checkShutdown() {
+        if (_shutdown != null)
+            throw Utility.fixStackTrace(_shutdown);
+    }
+
     /**
      * If delivery is not POISON nor null, return it.
      * <p/>