Repository: activemq Updated Branches: refs/heads/master 5d697cff3 -> 6f524bfea
https://issues.apache.org/jira/browse/AMQ-6017 - respect ioBufferSize for nio transport Project: http://git-wip-us.apache.org/repos/asf/activemq/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/6f524bfe Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/6f524bfe Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/6f524bfe Branch: refs/heads/master Commit: 6f524bfea0df670fe0db5ca1fa759123ac6b47e0 Parents: 5d697cf Author: Dejan Bosanac <[email protected]> Authored: Thu Oct 22 11:41:02 2015 +0200 Committer: Dejan Bosanac <[email protected]> Committed: Thu Oct 22 11:41:17 2015 +0200 ---------------------------------------------------------------------- .../java/org/apache/activemq/transport/nio/NIOTransport.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq/blob/6f524bfe/activemq-client/src/main/java/org/apache/activemq/transport/nio/NIOTransport.java ---------------------------------------------------------------------- diff --git a/activemq-client/src/main/java/org/apache/activemq/transport/nio/NIOTransport.java b/activemq-client/src/main/java/org/apache/activemq/transport/nio/NIOTransport.java index 81a2938..0a15fa5 100644 --- a/activemq-client/src/main/java/org/apache/activemq/transport/nio/NIOTransport.java +++ b/activemq-client/src/main/java/org/apache/activemq/transport/nio/NIOTransport.java @@ -92,11 +92,11 @@ public class NIOTransport extends TcpTransport { // Send the data via the channel // inputBuffer = ByteBuffer.allocateDirect(8*1024); - inputBuffer = ByteBuffer.allocate(8 * 1024); + inputBuffer = ByteBuffer.allocate(getIoBufferSize()); currentBuffer = inputBuffer; nextFrameSize = -1; currentBuffer.limit(4); - NIOOutputStream outPutStream = new NIOOutputStream(channel, 16 * 1024); + NIOOutputStream outPutStream = new NIOOutputStream(channel, getIoBufferSize()); this.dataOut = new DataOutputStream(outPutStream); this.buffOut = outPutStream; }
