diff options
| author | Rafael H. Schloming <rhs@apache.org> | 2009-03-20 05:29:10 +0000 |
|---|---|---|
| committer | Rafael H. Schloming <rhs@apache.org> | 2009-03-20 05:29:10 +0000 |
| commit | c7cc1d960a6bc6f533f30c58a1b30b84927955d5 (patch) | |
| tree | 256ac7e23402319528af8e08cd5764a5e596e83e /qpid/java/common/src/main | |
| parent | c26118e71a8520d0a52b2bf9510558263626956d (diff) | |
| download | qpid-python-c7cc1d960a6bc6f533f30c58a1b30b84927955d5.tar.gz | |
Fix for QPID-1761 and QPID-1762: made BBEncoder.grow() flip the buffer before copying; added a BBEncoder test; made unrecognized mime types default to BytesMessage; added logging of exception root cause to AMQSession; fixed miscelaneous test failures
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@756328 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/common/src/main')
| -rw-r--r-- | qpid/java/common/src/main/java/org/apache/qpid/transport/codec/BBEncoder.java | 11 |
1 files changed, 11 insertions, 0 deletions
diff --git a/qpid/java/common/src/main/java/org/apache/qpid/transport/codec/BBEncoder.java b/qpid/java/common/src/main/java/org/apache/qpid/transport/codec/BBEncoder.java index 532c19ec18..d18a0f64db 100644 --- a/qpid/java/common/src/main/java/org/apache/qpid/transport/codec/BBEncoder.java +++ b/qpid/java/common/src/main/java/org/apache/qpid/transport/codec/BBEncoder.java @@ -59,12 +59,23 @@ public final class BBEncoder extends AbstractEncoder return slice; } + public ByteBuffer buffer() + { + int pos = out.position(); + out.position(segment); + ByteBuffer slice = out.slice(); + slice.limit(pos - segment); + out.position(pos); + return slice; + } + private void grow(int size) { ByteBuffer old = out; int capacity = old.capacity(); out = ByteBuffer.allocate(Math.max(capacity + size, 2*capacity)); out.order(ByteOrder.BIG_ENDIAN); + old.flip(); out.put(old); } |
