diff options
Diffstat (limited to 'qpid/java')
| -rw-r--r-- | qpid/java/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerEncoder.java | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/qpid/java/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerEncoder.java b/qpid/java/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerEncoder.java index 94a444b590..6437015208 100644 --- a/qpid/java/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerEncoder.java +++ b/qpid/java/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerEncoder.java @@ -29,7 +29,8 @@ import org.apache.qpid.transport.codec.AbstractEncoder; public final class ServerEncoder extends AbstractEncoder { - public static final int DEFAULT_CAPACITY = 4096; + public static final int DEFAULT_CAPACITY = 8192; + private final int _threshold; private ByteBuffer _out; private int _segment; private int _initialCapacity; @@ -42,6 +43,7 @@ public final class ServerEncoder extends AbstractEncoder public ServerEncoder(int capacity) { _initialCapacity = capacity; + _threshold = capacity/16; _out = ByteBuffer.allocate(capacity); _segment = 0; } @@ -51,7 +53,7 @@ public final class ServerEncoder extends AbstractEncoder _out.position(_out.limit()); _out.limit(_out.capacity()); _out = _out.slice(); - if(_out.remaining() < 256) + if(_out.remaining() < _threshold) { _out = ByteBuffer.allocate(_initialCapacity); } |