activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject git commit: https://issues.apache.org/jira/browse/AMQ-5195
Date Fri, 23 May 2014 15:34:23 GMT
Repository: activemq
Updated Branches:
  refs/heads/trunk 9b6f419d4 -> ba519d8bd


https://issues.apache.org/jira/browse/AMQ-5195

Use largest incoming capaity value, broker will do flow control based on
destination policies. 

Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/ba519d8b
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/ba519d8b
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/ba519d8b

Branch: refs/heads/trunk
Commit: ba519d8bd3e1f17d5885a48da0b58999eebd2e12
Parents: 9b6f419
Author: Timothy Bish <tabish121@gmail.com>
Authored: Fri May 23 11:26:55 2014 -0400
Committer: Timothy Bish <tabish121@gmail.com>
Committed: Fri May 23 11:26:55 2014 -0400

----------------------------------------------------------------------
 .../org/apache/activemq/transport/amqp/AmqpProtocolConverter.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq/blob/ba519d8b/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java
----------------------------------------------------------------------
diff --git a/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java
b/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java
index 36a41e6..f8e5686 100644
--- a/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java
+++ b/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java
@@ -464,7 +464,7 @@ class AmqpProtocolConverter implements IAmqpProtocolConverter {
         AmqpSessionContext sessionContext = new AmqpSessionContext(connectionId, nextSessionId++);
         session.setContext(sessionContext);
         sendToActiveMQ(new SessionInfo(sessionContext.sessionId), null);
-        session.setIncomingCapacity(AmqpWireFormat.DEFAULT_MAX_FRAME_SIZE * prefetch);
+        session.setIncomingCapacity(Integer.MAX_VALUE);
         session.open();
     }
 


Mime
View raw message