Author: ritchiem
Date: Wed Jul 16 05:35:06 2008
New Revision: 677256
URL: http://svn.apache.org/viewvc?rev=677256&view=rev
Log:
QPID-1178 : Prevent Rejecting messages destined for known QueueBrowsers
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
Modified:
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java?rev=677256&r1=677255&r2=677256&view=diff
==============================================================================
---
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
(original)
+++
incubator/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
Wed Jul 16 05:35:06 2008
@@ -2840,9 +2840,21 @@
}
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
