add test for POISON object before readding it

David R. MacIver · David R. MacIver · commit bfb21720ac23 · 2010-02-10T18:01:17.000Z
diff --git a/src/com/rabbitmq/client/QueueingConsumer.java b/src/com/rabbitmq/client/QueueingConsumer.java
@@ -134,7 +134,7 @@ private void checkShutdown(){
     private Delivery handle(Delivery delivery)
     {
       if(delivery == POISON || (delivery == null && _shutdown != null)){
-        _queue.add(POISON);
+        if(delivery == POISON) _queue.add(POISON);
         throw Utility.fixStackTrace(_shutdown);
       }
       return delivery;

Original file line number	Diff line number	Diff line change
`@@ -134,7 +134,7 @@ private void checkShutdown(){`
`134`	`134`	`private Delivery handle(Delivery delivery)`
`135`	`135`	`{`
`136`	`136`	`if(delivery == POISON \|\| (delivery == null && _shutdown != null)){`
`137`		`- _queue.add(POISON);`
	`137`	`+ if(delivery == POISON) _queue.add(POISON);`
`138`	`138`	`throw Utility.fixStackTrace(_shutdown);`
`139`	`139`	`}`
`140`	`140`	`return delivery;`