activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject git commit: Use a fixed buffer to handle incoming deliveries from proton via the receiver.recv method instead of allocating a new byte array each time as the contents are copied out to create the complete frane
Date Thu, 15 May 2014 19:28:18 GMT
Repository: activemq
Updated Branches:
  refs/heads/trunk b83a3d438 -> b9d51bf1d


Use a fixed buffer to handle incoming deliveries from proton via the
receiver.recv method instead of allocating a new byte array each time as
the contents are copied out to create the complete frane

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

Branch: refs/heads/trunk
Commit: b9d51bf1d4dc9e4fd9f4275356ac03c2fe652c54
Parents: b83a3d4
Author: Timothy Bish <tabish121@gmail.com>
Authored: Thu May 15 15:28:02 2014 -0400
Committer: Timothy Bish <tabish121@gmail.com>
Committed: Thu May 15 15:28:02 2014 -0400

----------------------------------------------------------------------
 .../apache/activemq/transport/amqp/AmqpProtocolConverter.java | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq/blob/b9d51bf1/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 b8a27c4..05e20dc 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
@@ -511,6 +511,8 @@ class AmqpProtocolConverter implements IAmqpProtocolConverter {
 
         ByteArrayOutputStream current = new ByteArrayOutputStream();
 
+        private final byte[] recvBuffer = new byte[1024 * 8];
+
         @Override
         public void onDelivery(Delivery delivery) throws Exception {
             Receiver receiver = ((Receiver) delivery.getLink());
@@ -524,9 +526,8 @@ class AmqpProtocolConverter implements IAmqpProtocolConverter {
             }
 
             int count;
-            byte data[] = new byte[1024 * 4];
-            while ((count = receiver.recv(data, 0, data.length)) > 0) {
-                current.write(data, 0, count);
+            while ((count = receiver.recv(recvBuffer, 0, recvBuffer.length)) > 0) {
+                current.write(recvBuffer, 0, count);
             }
 
             // Expecting more deliveries..


Mime
View raw message