Repository: qpid-jms Updated Branches: refs/heads/master 6f06f1af2 -> 4cb77adbd
QPIDJMS-122 Allocate a small fixed size buffer for use when encoding the TX commands and reuse it. Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/6c1992c5 Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/6c1992c5 Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/6c1992c5 Branch: refs/heads/master Commit: 6c1992c5e76a8cd22faadfe4c1e697d09b0fcf87 Parents: 6f06f1a Author: Timothy Bish <tabish...@gmail.com> Authored: Fri Oct 9 15:53:43 2015 -0400 Committer: Timothy Bish <tabish...@gmail.com> Committed: Fri Oct 9 15:53:43 2015 -0400 ---------------------------------------------------------------------- .../apache/qpid/jms/provider/amqp/AmqpTransactionContext.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/6c1992c5/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpTransactionContext.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpTransactionContext.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpTransactionContext.java index 222279f..a5e9284 100644 --- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpTransactionContext.java +++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpTransactionContext.java @@ -54,6 +54,8 @@ public class AmqpTransactionContext extends AmqpAbstractResource<JmsSessionInfo, private static final Boolean ROLLBACK_MARKER = Boolean.FALSE; private static final Boolean COMMIT_MARKER = Boolean.TRUE; + private final byte[] OUTBOUND_BUFFER = new byte[64]; + private final AmqpSession session; private JmsTransactionId current; private final AmqpTransferTagGenerator tagGenerator = new AmqpTransferTagGenerator(); @@ -239,7 +241,7 @@ public class AmqpTransactionContext extends AmqpAbstractResource<JmsSessionInfo, private void sendTxCommand(Message message) throws IOException { int encodedSize = 0; - byte[] buffer = new byte[4 * 1024]; + byte[] buffer = OUTBOUND_BUFFER; while (true) { try { encodedSize = message.encode(buffer, 0, buffer.length); --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org For additional commands, e-mail: commits-h...@qpid.apache.org
