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

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
This commit is contained in:
Timothy Bish 2014-05-15 15:28:02 -04:00
parent b83a3d4388
commit b9d51bf1d4
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java
View File

@ -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..