diff options
| author | Martin Ritchie <ritchiem@apache.org> | 2008-07-16 12:35:06 +0000 |
|---|---|---|
| committer | Martin Ritchie <ritchiem@apache.org> | 2008-07-16 12:35:06 +0000 |
| commit | 4cb209af983c23cbe5e7b70b6e7b24d8890f9fc5 (patch) | |
| tree | 5b9bcf99b40c2e675a8fee525b1ade4034bd279c /java/client | |
| parent | 48886608aa16594be0523df603462b2b77d73172 (diff) | |
| download | qpid-python-4cb209af983c23cbe5e7b70b6e7b24d8890f9fc5.tar.gz | |
QPID-1178 : Prevent Rejecting messages destined for known QueueBrowsers
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@677256 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/client')
| -rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/AMQSession.java | 18 |
1 files changed, 15 insertions, 3 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/AMQSession.java b/java/client/src/main/java/org/apache/qpid/client/AMQSession.java index 2f593ce0c3..544c8014b4 100644 --- a/java/client/src/main/java/org/apache/qpid/client/AMQSession.java +++ b/java/client/src/main/java/org/apache/qpid/client/AMQSession.java @@ -2840,9 +2840,21 @@ public abstract class AMQSession extends Closeable implements Session, QueueSess } else { - _dispatcherLogger.info("Received a message(" + System.identityHashCode(message) + ")" + "[" - + message.getDeliveryTag() + "] from queue " + " consumer(" - + message.getConsumerTag() + ") is closed rejecting(requeue)..."); + if (consumer.isNoConsume()) + { + _dispatcherLogger.info("Received a message(" + System.identityHashCode(message) + ")" + "[" + + message.getDeliveryTag() + "] from queue " + " consumer(" + + message.getConsumerTag() + ") is closed and a browser so dropping..."); + //DROP MESSAGE + return; + + } + else + { + _dispatcherLogger.info("Received a message(" + System.identityHashCode(message) + ")" + "[" + + message.getDeliveryTag() + "] from queue " + " consumer(" + + message.getConsumerTag() + ") is closed rejecting(requeue)..."); + } } } // Don't reject if we're already closing |