diff options
| author | Martin Ritchie <ritchiem@apache.org> | 2006-10-24 11:50:09 +0000 |
|---|---|---|
| committer | Martin Ritchie <ritchiem@apache.org> | 2006-10-24 11:50:09 +0000 |
| commit | 2c0b7ee474bd76c3e950cbd16816dcffd9911194 (patch) | |
| tree | db6b1df9537652bc0b006b29fbef45fd71b91dbd /qpid/java/common/src | |
| parent | c1aa1730f2da9b59f719ab52871aa83833a246b8 (diff) | |
| download | qpid-python-2c0b7ee474bd76c3e950cbd16816dcffd9911194.tar.gz | |
QPID-48
Enabled buffer compression on delivery queue as a configuration option from the xml.(advanced.compressBufferOnQueue)
Changed DeliveryManager.java to use ConcurrentLinkedQueueNoSize.java this is the standard ConcurrentLinkedQueue but where the size() method returns 0(empty) or 1(has content) as it is an expensive operation.
Previously there was a race condition with the use of the _queueing boolean. Under load the consumer would sometimes stop getting messages. This was due to the messages being enqueued without starting the Worker thread.
There is still an issue (QPID-54) on high receiving load messages rate received by a client drops.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@467313 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/common/src')
| -rw-r--r-- | qpid/java/common/src/org/apache/qpid/framing/ContentBody.java | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/qpid/java/common/src/org/apache/qpid/framing/ContentBody.java b/qpid/java/common/src/org/apache/qpid/framing/ContentBody.java index d7b668534c..14344a3870 100644 --- a/qpid/java/common/src/org/apache/qpid/framing/ContentBody.java +++ b/qpid/java/common/src/org/apache/qpid/framing/ContentBody.java @@ -63,8 +63,7 @@ public class ContentBody extends AMQBody ByteBuffer newPayload = ByteBuffer.allocate(size); newPayload.put(payload); - newPayload.position(0); - newPayload.limit(size); + newPayload.flip(); //reduce reference count on payload payload.release(); |