Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Make comments match reality.

This commit is contained in:
Timothy Bish 2014-08-14 18:17:30 -04:00
parent 582fc08019
commit deee040151
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
activemq-client/src/main/java/org/apache/activemq/ActiveMQMessageProducer.java
View File

@ -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());