summaryrefslogtreecommitdiff
path: root/java/common/src
diff options
context:
space:
mode:
authorMartin Ritchie <ritchiem@apache.org>2006-10-24 11:50:09 +0000
committerMartin Ritchie <ritchiem@apache.org>2006-10-24 11:50:09 +0000
commit74dbde147951a10f7d9d817eb86046845087a00f (patch)
treebea7a633e6bffd21f4a749f3adaa972f54f708e9 /java/common/src
parentc58c6dedd5f681f9b06b7bdd3a50dc671f995d93 (diff)
downloadqpid-python-74dbde147951a10f7d9d817eb86046845087a00f.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/qpid@467313 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/common/src')
-rw-r--r--java/common/src/org/apache/qpid/framing/ContentBody.java3
1 files changed, 1 insertions, 2 deletions
diff --git a/java/common/src/org/apache/qpid/framing/ContentBody.java b/java/common/src/org/apache/qpid/framing/ContentBody.java
index d7b668534c..14344a3870 100644
--- a/java/common/src/org/apache/qpid/framing/ContentBody.java
+++ b/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();