Make comments match reality.
Project: http://git-wip-us.apache.org/repos/asf/activemq/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/42751573 Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/42751573 Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/42751573 Branch: refs/heads/activemq-5.10.x Commit: 4275157365ada2aa0a6ab4db42e56683115bb06a Parents: b75ccd5 Author: Timothy Bish <[email protected]> Authored: Thu Aug 14 18:17:30 2014 -0400 Committer: Hadrian Zbarcea <[email protected]> Committed: Wed Dec 17 19:38:11 2014 -0500 ---------------------------------------------------------------------- .../main/java/org/apache/activemq/ActiveMQMessageProducer.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq/blob/42751573/activemq-client/src/main/java/org/apache/activemq/ActiveMQMessageProducer.java ---------------------------------------------------------------------- diff --git a/activemq-client/src/main/java/org/apache/activemq/ActiveMQMessageProducer.java b/activemq-client/src/main/java/org/apache/activemq/ActiveMQMessageProducer.java index e45809a..2fec295 100755 --- a/activemq-client/src/main/java/org/apache/activemq/ActiveMQMessageProducer.java +++ b/activemq-client/src/main/java/org/apache/activemq/ActiveMQMessageProducer.java @@ -105,8 +105,7 @@ public class ActiveMQMessageProducer extends ActiveMQMessageProducerSupport impl this.info.setDestination(destination); - // Enable producer window flow control if protocol > 3 and the window - // size > 0 + // Enable producer window flow control if protocol >= 3 and the window size > 0 if (session.connection.getProtocolVersion() >= 3 && this.info.getWindowSize() > 0) { producerWindow = new MemoryUsage("Producer Window: " + producerId); producerWindow.setExecutor(session.getConnectionExecutor());
