Skip to content

Commit 397672f

Browse files
author
Steve Powell
committed
Forgo checking for shutdown in handleDelivery of QueueingConsumer.
1 parent d4e7e53 commit 397672f

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/com/rabbitmq/client/QueueingConsumer.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -64,7 +64,7 @@
6464
* <code>Connection's</code> thread. This had two main drawbacks. Firstly, the
6565
* <code>Consumer</code> could stall the processing of all
6666
* <code>Channels</code> on the <code>Connection</code>. Secondly, if a
67-
* <code>Consumer</code> made a recursive synchronous call into its
67+
* <code>Consumer</code> made a recursive synchronous call into its
6868
* <code>Channel</code> the client would deadlock.
6969
* <p/>
7070
* <code>QueueingConsumer</code> provided client code with an easy way to
@@ -121,7 +121,7 @@ public QueueingConsumer(Channel ch, BlockingQueue<Delivery> q) {
121121
byte[] body)
122122
throws IOException
123123
{
124-
checkShutdown();
124+
// checkShutdown();
125125
this._queue.add(new Delivery(envelope, properties, body));
126126
}
127127

0 commit comments

Comments
 (0)