diff options
Diffstat (limited to 'qpid/java')
| -rw-r--r-- | qpid/java/amqp-1-0-client/src/main/java/org/apache/qpid/amqp_1_0/client/Receiver.java | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/qpid/java/amqp-1-0-client/src/main/java/org/apache/qpid/amqp_1_0/client/Receiver.java b/qpid/java/amqp-1-0-client/src/main/java/org/apache/qpid/amqp_1_0/client/Receiver.java index d76899a88b..ad2924c01e 100644 --- a/qpid/java/amqp-1-0-client/src/main/java/org/apache/qpid/amqp_1_0/client/Receiver.java +++ b/qpid/java/amqp-1-0-client/src/main/java/org/apache/qpid/amqp_1_0/client/Receiver.java @@ -505,7 +505,7 @@ public class Receiver implements DeliveryStateHandler _endpoint.setTarget(null); _endpoint.close(); Message msg; - while((msg = receive(-1l)) != null) + while((msg = receive(0l)) != null) { release(msg); } @@ -518,7 +518,7 @@ public class Receiver implements DeliveryStateHandler _endpoint.setTarget(null); _endpoint.detach(); Message msg; - while((msg = receive(-1l)) != null) + while((msg = receive(0l)) != null) { release(msg); } |