Mailing-List: contact commits-help@qpid.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@qpid.apache.org
Content-Type: text/plain; charset="us-ascii"
MIME-Version: 1.0
Content-Transfer-Encoding: 7bit
From: lquack@apache.org
To: commits@qpid.apache.org
Date: Fri, 10 Nov 2017 15:50:48 -0000
Message-Id: <75b7e977e7d74253819ddad4c8b43656@git.apache.org>
Subject: [1/4] qpid-jms-amqp-0-x git commit: QPID-7725: [Java Client,
 AMQP 0-x] Remove QpidByteBuffer
archived-at: Fri, 10 Nov 2017 15:50:50 -0000

Repository: qpid-jms-amqp-0-x
Updated Branches:
  refs/heads/master 8443f85a5 -> 95203e5d1


http://git-wip-us.apache.org/repos/asf/qpid-jms-amqp-0-x/blob/95203e5d/client/src/test/java/org/apache/qpid/bytebuffer/QpidByteBufferOutputStreamTest.java
----------------------------------------------------------------------
diff --git a/client/src/test/java/org/apache/qpid/bytebuffer/QpidByteBufferOutputStreamTest.java b/client/src/test/java/org/apache/qpid/bytebuffer/QpidByteBufferOutputStreamTest.java
deleted file mode 100644
index c7b421e..0000000
--- a/client/src/test/java/org/apache/qpid/bytebuffer/QpidByteBufferOutputStreamTest.java
+++ /dev/null
@@ -1,114 +0,0 @@
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
- *
- *   http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied.  See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-
-package org.apache.qpid.bytebuffer;
-
-import java.util.Collection;
-import java.util.Iterator;
-
-import junit.framework.TestCase;
-import org.junit.Assert;
-
-public class QpidByteBufferOutputStreamTest extends TestCase
-{
-    public void testWriteByteByByte() throws Exception
-    {
-        boolean direct = false;
-        QpidByteBufferOutputStream stream = new QpidByteBufferOutputStream(direct, 3);
-        stream.write('a');
-        stream.write('b');
-
-        Collection<QpidByteBuffer> bufs = stream.fetchAccumulatedBuffers();
-        assertEquals("Unexpected number of buffers", 2, bufs.size());
-        Iterator<QpidByteBuffer> bufItr = bufs.iterator();
-
-        QpidByteBuffer buf1 = bufItr.next();
-        assertBufferContent("1st buffer", buf1, "a".getBytes(), direct);
-
-
-        QpidByteBuffer buf2 = bufItr.next();
-        assertBufferContent("2nd buffer", buf2, "b".getBytes(), direct);
-    }
-
-    public void testWriteByteArrays() throws Exception
-    {
-        boolean direct = false;
-        QpidByteBufferOutputStream stream = new QpidByteBufferOutputStream(direct, 8);
-        stream.write("abcd".getBytes(), 0, 4);
-        stream.write("_ef_".getBytes(), 1, 2);
-
-        Collection<QpidByteBuffer> bufs = stream.fetchAccumulatedBuffers();
-        assertEquals("Unexpected number of buffers", 2, bufs.size());
-        Iterator<QpidByteBuffer> bufItr = bufs.iterator();
-
-        QpidByteBuffer buf1 = bufItr.next();
-        assertBufferContent("1st buffer", buf1, "abcd".getBytes(), direct);
-
-        QpidByteBuffer buf2 = bufItr.next();
-        assertBufferContent("2nd buffer", buf2, "ef".getBytes(), direct);
-    }
-
-    public void testWriteMixed() throws Exception
-    {
-        boolean direct = true;
-        QpidByteBufferOutputStream stream = new QpidByteBufferOutputStream(direct, 3);
-        stream.write('a');
-        stream.write("bcd".getBytes());
-
-        Collection<QpidByteBuffer> bufs = stream.fetchAccumulatedBuffers();
-        assertEquals("Unexpected number of buffers", 2, bufs.size());
-        Iterator<QpidByteBuffer> bufItr = bufs.iterator();
-
-        QpidByteBuffer buf1 = bufItr.next();
-        assertBufferContent("1st buffer", buf1, "a".getBytes(), direct);
-
-        QpidByteBuffer buf2 = bufItr.next();
-        assertBufferContent("2nd buffer", buf2, "bcd".getBytes(), direct);
-    }
-
-
-    public void testWriteByteArrays_ArrayTooLargeForSingleBuffer() throws Exception
-    {
-        boolean direct = false;
-        QpidByteBufferOutputStream stream = new QpidByteBufferOutputStream(direct, 8);
-        stream.write("abcdefghi".getBytes());
-
-        Collection<QpidByteBuffer> bufs = stream.fetchAccumulatedBuffers();
-        assertEquals("Unexpected number of buffers", 2, bufs.size());
-        Iterator<QpidByteBuffer> bufItr = bufs.iterator();
-
-        QpidByteBuffer buf1 = bufItr.next();
-        assertBufferContent("1st buffer", buf1, "abcdefgh".getBytes(), direct);
-
-        QpidByteBuffer buf2 = bufItr.next();
-        assertBufferContent("2nd buffer", buf2, "i".getBytes(), direct);
-    }
-
-    private void assertBufferContent(String bufName, QpidByteBuffer buf, byte[] expectedBytes, final boolean direct)
-    {
-        assertEquals(bufName + " has unexpected number of bytes", expectedBytes.length, buf.remaining());
-        byte[] copy = new byte[buf.remaining()];
-        buf.get(copy);
-        Assert.assertArrayEquals(bufName + " has unexpected content", expectedBytes, copy);
-        assertEquals(bufName + " has unexpected type", direct, buf.isDirect());
-    }
-
-}
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/qpid-jms-amqp-0-x/blob/95203e5d/client/src/test/java/org/apache/qpid/bytebuffer/QpidByteBufferTest.java
----------------------------------------------------------------------
diff --git a/client/src/test/java/org/apache/qpid/bytebuffer/QpidByteBufferTest.java b/client/src/test/java/org/apache/qpid/bytebuffer/QpidByteBufferTest.java
deleted file mode 100644
index 67f5634..0000000
--- a/client/src/test/java/org/apache/qpid/bytebuffer/QpidByteBufferTest.java
+++ /dev/null
@@ -1,917 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
- *
- *   http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied.  See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-
-package org.apache.qpid.bytebuffer;
-
-import java.io.ByteArrayOutputStream;
-import java.io.IOException;
-import java.io.InputStream;
-import java.lang.reflect.InvocationTargetException;
-import java.lang.reflect.Method;
-import java.nio.BufferOverflowException;
-import java.nio.BufferUnderflowException;
-import java.nio.ByteBuffer;
-import java.nio.CharBuffer;
-import java.nio.charset.StandardCharsets;
-import java.util.Arrays;
-import java.util.Collection;
-import java.util.Collections;
-
-import com.google.common.io.ByteStreams;
-import org.junit.Assert;
-import org.mockito.internal.util.Primitives;
-
-import org.apache.qpid.test.utils.QpidTestCase;
-import org.apache.qpid.util.ByteBufferUtils;
-
-public class QpidByteBufferTest extends QpidTestCase
-{
-    private static final int BUFFER_SIZE = 10;
-    private static final int POOL_SIZE = 20;
-
-
-    private QpidByteBuffer _slicedBuffer;
-    private QpidByteBuffer _parent;
-
-    @Override
-    protected void setUp() throws Exception
-    {
-        super.setUp();
-        QpidByteBuffer.initialisePool(BUFFER_SIZE, POOL_SIZE);
-        _parent = QpidByteBuffer.allocateDirect(BUFFER_SIZE);
-    }
-
-    @Override
-    public void tearDown() throws Exception
-    {
-        super.tearDown();
-        _parent.dispose();
-        if (_slicedBuffer != null)
-        {
-            _slicedBuffer.dispose();
-        }
-    }
-
-    public void testPutGetByIndex() throws Exception
-    {
-        testPutGetByIndex(double.class, 1.0);
-        testPutGetByIndex(float.class, 1.0f);
-        testPutGetByIndex(long.class, 1L);
-        testPutGetByIndex(int.class, 1);
-        testPutGetByIndex(char.class, 'A');
-        testPutGetByIndex(short.class, (short)1);
-        testPutGetByIndex(byte.class, (byte)1);
-    }
-
-    public void testPutGet() throws Exception
-    {
-        testPutGet(double.class, false, 1.0);
-        testPutGet(float.class, false, 1.0f);
-        testPutGet(long.class, false, 1L);
-        testPutGet(int.class, false, 1);
-        testPutGet(char.class, false, 'A');
-        testPutGet(short.class, false, (short)1);
-        testPutGet(byte.class, false, (byte)1);
-
-        testPutGet(int.class, true, 1L);
-        testPutGet(short.class, true, 1);
-        testPutGet(byte.class, true, (short)1);
-    }
-
-    public void testMarkReset() throws Exception
-    {
-        _slicedBuffer = createSlice();
-
-        _slicedBuffer.mark();
-        _slicedBuffer.position(_slicedBuffer.position() + 1);
-        assertEquals("Unexpected position after move", 1, _slicedBuffer.position());
-
-        _slicedBuffer.reset();
-        assertEquals("Unexpected position after reset", 0, _slicedBuffer.position());
-    }
-
-    public void testPosition() throws Exception
-    {
-        _slicedBuffer = createSlice();
-
-        assertEquals("Unexpected position for new slice", 0, _slicedBuffer.position());
-
-        _slicedBuffer.position(1);
-        assertEquals("Unexpected position after advance", 1, _slicedBuffer.position());
-
-        final int oldLimit = _slicedBuffer.limit();
-        _slicedBuffer.limit(oldLimit - 1);
-        try
-        {
-            _slicedBuffer.position(oldLimit);
-            fail("Exception not thrown");
-        }
-        catch (IllegalArgumentException e)
-        {
-            // pass
-        }
-    }
-
-    public void testBulkPutGet() throws Exception
-    {
-        _slicedBuffer = createSlice();
-
-        final byte[] source = getTestBytes(_slicedBuffer.remaining());
-
-        QpidByteBuffer rv = _slicedBuffer.put(source, 0, source.length);
-        assertEquals("Unexpected builder return value", _slicedBuffer, rv);
-
-        _slicedBuffer.flip();
-        byte[] target = new byte[_slicedBuffer.remaining()];
-        rv = _slicedBuffer.get(target, 0, target.length);
-        assertEquals("Unexpected builder return value", _slicedBuffer, rv);
-
-        Assert.assertArrayEquals("Unexpected bulk put/get result", source, target);
-
-
-        _slicedBuffer.clear();
-        _slicedBuffer.position(1);
-
-        try
-        {
-            _slicedBuffer.put(source, 0, source.length);
-            fail("Exception not thrown");
-        }
-        catch (BufferOverflowException e)
-        {
-            // pass
-        }
-
-        assertEquals("Position should be unchanged after failed put", 1, _slicedBuffer.position());
-
-        try
-        {
-            _slicedBuffer.get(target, 0, target.length);
-            fail("Exception not thrown");
-        }
-        catch (BufferUnderflowException e)
-        {
-            // pass
-        }
-
-        assertEquals("Position should be unchanged after failed get", 1, _slicedBuffer.position());
-
-
-    }
-
-    public void testByteBufferPutGet()
-    {
-        _slicedBuffer = createSlice();
-        final byte[] source = getTestBytes(_slicedBuffer.remaining());
-
-        ByteBuffer sourceByteBuffer = ByteBuffer.wrap(source);
-
-        QpidByteBuffer rv = _slicedBuffer.put(sourceByteBuffer);
-        assertEquals("Unexpected builder return value", _slicedBuffer, rv);
-
-        assertEquals("Unexpected position", _slicedBuffer.capacity(), _slicedBuffer.position());
-        assertEquals("Unexpected remaining", 0, _slicedBuffer.remaining());
-
-        assertEquals("Unexpected remaining in source ByteBuffer", 0, sourceByteBuffer.remaining());
-
-        _slicedBuffer.flip();
-
-        ByteBuffer destinationByteBuffer =  ByteBuffer.allocate(source.length);
-        _slicedBuffer.get(destinationByteBuffer);
-
-
-        assertEquals("Unexpected remaining", 0, _slicedBuffer.remaining());
-
-        assertEquals("Unexpected remaining in destination ByteBuffer", 0, destinationByteBuffer.remaining());
-        assertEquals("Unexpected position in destination ByteBuffer", source.length, destinationByteBuffer.position());
-
-        Assert.assertArrayEquals("Unexpected ByteBuffer put/get result", source, destinationByteBuffer.array());
-
-        _slicedBuffer.clear();
-        _slicedBuffer.position(1);
-
-        sourceByteBuffer.clear();
-        try
-        {
-            _slicedBuffer.put(sourceByteBuffer);
-            fail("Exception should be thrown");
-        }
-        catch(BufferOverflowException e)
-        {
-            // pass
-        }
-
-        assertEquals("Position should not be changed after failed put", 1, _slicedBuffer.position());
-        assertEquals("Source position should not changed after failed put", source.length, sourceByteBuffer.remaining());
-
-        _slicedBuffer.clear();
-        destinationByteBuffer.position(1);
-
-        try
-        {
-            _slicedBuffer.get(destinationByteBuffer);
-            fail("Exception should be thrown");
-        }
-        catch(BufferUnderflowException e )
-        {
-            // pass
-        }
-    }
-
-    public void testQpidByteBufferPutGet()
-    {
-        _slicedBuffer = createSlice();
-        final byte[] source = getTestBytes(_slicedBuffer.remaining());
-
-        QpidByteBuffer sourceQpidByteBuffer = QpidByteBuffer.wrap(source);
-
-        QpidByteBuffer rv = _slicedBuffer.put(sourceQpidByteBuffer);
-        assertEquals("Unexpected builder return value", _slicedBuffer, rv);
-
-        assertEquals("Unexpected position", _slicedBuffer.capacity(), _slicedBuffer.position());
-        assertEquals("Unexpected remaining", 0, _slicedBuffer.remaining());
-
-        assertEquals("Unexpected remaining in source QpidByteBuffer", 0, sourceQpidByteBuffer.remaining());
-
-        _slicedBuffer.flip();
-
-        ByteBuffer destinationByteBuffer =  ByteBuffer.allocate(source.length);
-        _slicedBuffer.get(destinationByteBuffer);
-
-        assertEquals("Unexpected remaining", 0, _slicedBuffer.remaining());
-
-        assertEquals("Unexpected remaining in destination ByteBuffer", 0, destinationByteBuffer.remaining());
-        assertEquals("Unexpected position in destination ByteBuffer", source.length, destinationByteBuffer.position());
-
-        Assert.assertArrayEquals("Unexpected ByteBuffer put/get result", source, destinationByteBuffer.array());
-
-        _slicedBuffer.clear();
-        _slicedBuffer.position(1);
-
-        sourceQpidByteBuffer.clear();
-        try
-        {
-            _slicedBuffer.put(sourceQpidByteBuffer);
-            fail("Exception should be thrown");
-        }
-        catch(BufferOverflowException e)
-        {
-            // pass
-        }
-
-        assertEquals("Position should not be changed after failed put", 1, _slicedBuffer.position());
-        assertEquals("Source position should not changed after failed put", source.length, sourceQpidByteBuffer.remaining());
-    }
-
-    public void testDuplicate()
-    {
-        _slicedBuffer = createSlice();
-        _slicedBuffer.position(1);
-        int originalLimit = _slicedBuffer.limit();
-        _slicedBuffer.limit(originalLimit - 1);
-
-        QpidByteBuffer duplicate = _slicedBuffer.duplicate();
-        try
-        {
-            assertEquals("Unexpected position", _slicedBuffer.position(), duplicate.position() );
-            assertEquals("Unexpected limit", _slicedBuffer.limit(), duplicate.limit() );
-            assertEquals("Unexpected capacity", _slicedBuffer.capacity(), duplicate.capacity() );
-
-            duplicate.position(2);
-            duplicate.limit(originalLimit - 2);
-
-            assertEquals("Unexpected position in the original", 1, _slicedBuffer.position());
-            assertEquals("Unexpected limit in the original", originalLimit -1, _slicedBuffer.limit());
-        }
-        finally
-        {
-            duplicate.dispose();
-        }
-    }
-
-    public void testCopyToByteBuffer()
-    {
-        _slicedBuffer = createSlice();
-        byte[] source = getTestBytes(_slicedBuffer.remaining());
-        _slicedBuffer.put(source);
-        _slicedBuffer.flip();
-
-        int originalRemaining = _slicedBuffer.remaining();
-        ByteBuffer destination =  ByteBuffer.allocate(source.length);
-        _slicedBuffer.copyTo(destination);
-
-        assertEquals("Unexpected remaining in original QBB", originalRemaining, _slicedBuffer.remaining());
-        assertEquals("Unexpected remaining in destination", 0, destination.remaining());
-
-        Assert.assertArrayEquals("Unexpected copyTo result", source, destination.array());
-    }
-
-    public void testCopyToArray()
-    {
-        _slicedBuffer = createSlice();
-        byte[] source = getTestBytes(_slicedBuffer.remaining());
-        _slicedBuffer.put(source);
-        _slicedBuffer.flip();
-
-        int originalRemaining = _slicedBuffer.remaining();
-        byte[] destination = new byte[source.length];
-        _slicedBuffer.copyTo(destination);
-
-        assertEquals("Unexpected remaining in original QBB", originalRemaining, _slicedBuffer.remaining());
-
-        Assert.assertArrayEquals("Unexpected copyTo result", source, destination);
-    }
-
-    public void testPutCopyOf()
-    {
-        _slicedBuffer = createSlice();
-        byte[] source = getTestBytes(_slicedBuffer.remaining());
-
-        QpidByteBuffer sourceQpidByteBuffer =  QpidByteBuffer.wrap(source);
-        _slicedBuffer.putCopyOf(sourceQpidByteBuffer);
-
-        assertEquals("Copied buffer should not be changed", source.length, sourceQpidByteBuffer.remaining());
-        assertEquals("Buffer should be full", 0, _slicedBuffer.remaining());
-        _slicedBuffer.flip();
-
-        byte[] destination = new byte[source.length];
-        _slicedBuffer.get(destination);
-
-        Assert.assertArrayEquals("Unexpected putCopyOf result", source, destination);
-    }
-
-    public void testCompact()
-    {
-        _slicedBuffer = createSlice();
-        byte[] source = getTestBytes(_slicedBuffer.remaining());
-        _slicedBuffer.put(source);
-
-        _slicedBuffer.position(1);
-        _slicedBuffer.limit(_slicedBuffer.limit() - 1);
-
-        int remaining =  _slicedBuffer.remaining();
-        _slicedBuffer.compact();
-
-        assertEquals("Unexpected position", remaining, _slicedBuffer.position());
-        assertEquals("Unexpected limit", _slicedBuffer.capacity(), _slicedBuffer.limit());
-
-        _slicedBuffer.flip();
-
-
-        byte[] destination =  new byte[_slicedBuffer.remaining()];
-        _slicedBuffer.get(destination);
-
-        byte[] expected =  new byte[source.length - 2];
-        System.arraycopy(source, 1, expected, 0, expected.length);
-
-        Assert.assertArrayEquals("Unexpected compact result", expected, destination);
-    }
-
-    public void testSliceOfSlice()
-    {
-        _slicedBuffer = createSlice();
-        byte[] source = getTestBytes(_slicedBuffer.remaining());
-        _slicedBuffer.put(source);
-
-        _slicedBuffer.position(1);
-        _slicedBuffer.limit(_slicedBuffer.limit() - 1);
-
-        int remaining = _slicedBuffer.remaining();
-        QpidByteBuffer newSlice = _slicedBuffer.slice();
-        try
-        {
-            assertEquals("Unexpected position in original", 1, _slicedBuffer.position());
-            assertEquals("Unexpected limit in original", source.length - 1, _slicedBuffer.limit());
-            assertEquals("Unexpected position", 0, newSlice.position());
-            assertEquals("Unexpected limit", remaining, newSlice.limit());
-            assertEquals("Unexpected capacity", remaining, newSlice.capacity());
-
-            byte[] destination =  new byte[newSlice.remaining()];
-            newSlice.get(destination);
-
-            byte[] expected =  new byte[source.length - 2];
-            System.arraycopy(source, 1, expected, 0, expected.length);
-            Assert.assertArrayEquals("Unexpected slice result", expected, destination);
-        }
-        finally
-        {
-            newSlice.dispose();
-        }
-    }
-
-    public void testViewOfSlice()
-    {
-        _slicedBuffer = createSlice();
-        byte[] source = getTestBytes(_slicedBuffer.remaining());
-        _slicedBuffer.put(source);
-
-        _slicedBuffer.position(1);
-        _slicedBuffer.limit(_slicedBuffer.limit() - 1);
-
-        QpidByteBuffer view = _slicedBuffer.view(0, _slicedBuffer.remaining());
-        try
-        {
-            assertEquals("Unexpected position in original", 1, _slicedBuffer.position());
-            assertEquals("Unexpected limit in original", source.length - 1, _slicedBuffer.limit());
-
-            assertEquals("Unexpected position", 0, view.position());
-            assertEquals("Unexpected limit", _slicedBuffer.remaining(), view.limit());
-            assertEquals("Unexpected capacity", _slicedBuffer.remaining(), view.capacity());
-
-            byte[] destination =  new byte[view.remaining()];
-            view.get(destination);
-
-            byte[] expected =  new byte[source.length - 2];
-            System.arraycopy(source, 1, expected, 0, expected.length);
-            Assert.assertArrayEquals("Unexpected view result", expected, destination);
-        }
-        finally
-        {
-            view.dispose();
-        }
-
-        view = _slicedBuffer.view(1, _slicedBuffer.remaining() - 2);
-        try
-        {
-            assertEquals("Unexpected position in original", 1, _slicedBuffer.position());
-            assertEquals("Unexpected limit in original", source.length - 1, _slicedBuffer.limit());
-
-            assertEquals("Unexpected position", 0, view.position());
-            assertEquals("Unexpected limit", _slicedBuffer.remaining() - 2, view.limit());
-            assertEquals("Unexpected capacity", _slicedBuffer.remaining() - 2, view.capacity());
-
-            byte[] destination =  new byte[view.remaining()];
-            view.get(destination);
-
-            byte[] expected =  new byte[source.length - 4];
-            System.arraycopy(source, 2, expected, 0, expected.length);
-            Assert.assertArrayEquals("Unexpected view result", expected, destination);
-        }
-        finally
-        {
-            view.dispose();
-        }
-    }
-
-    public void testAsInputStream() throws Exception
-    {
-        _slicedBuffer = createSlice();
-        byte[] source = getTestBytes(_slicedBuffer.remaining());
-        _slicedBuffer.put(source);
-
-        _slicedBuffer.position(1);
-        _slicedBuffer.limit(_slicedBuffer.limit() - 1);
-
-        ByteArrayOutputStream destination = new ByteArrayOutputStream();
-        try(InputStream is = _slicedBuffer.asInputStream())
-        {
-            ByteStreams.copy(is, destination);
-        }
-
-        byte[] expected =  new byte[source.length - 2];
-        System.arraycopy(source, 1, expected, 0, expected.length);
-        Assert.assertArrayEquals("Unexpected view result", expected, destination.toByteArray());
-    }
-
-    public void testAsByteBuffer() throws Exception
-    {
-        _slicedBuffer = createSlice();
-
-        _slicedBuffer.position(1);
-        _slicedBuffer.limit(_slicedBuffer.limit() - 1);
-
-        _slicedBuffer.mark();
-        int remaining = _slicedBuffer.remaining();
-        byte[] source = getTestBytes(remaining);
-        _slicedBuffer.put(source);
-        _slicedBuffer.reset();
-
-        ByteBuffer buffer = _slicedBuffer.asByteBuffer();
-        assertEquals("Unexpected remaining", remaining, buffer.remaining());
-
-        byte[] target = new byte[remaining];
-        buffer.get(target);
-        Assert.assertArrayEquals("Unexpected asByteBuffer result", source, target);
-    }
-
-    public void testDecode()
-    {
-        _slicedBuffer = createSlice();
-        final String input = "ABC";
-        _slicedBuffer.put(input.getBytes());
-        _slicedBuffer.flip();
-
-        final CharBuffer charBuffer = _slicedBuffer.decode(StandardCharsets.US_ASCII);
-        final char[] destination = new char[charBuffer.remaining()];
-        charBuffer.get(destination);
-        Assert.assertArrayEquals("Unexpected char buffer", input.toCharArray(), destination);
-    }
-
-    private byte[] getTestBytes(final int length)
-    {
-        final byte[] source = new byte[length];
-        for (int i = 0; i < source.length; i++)
-        {
-            source[i] = (byte) ('A' + i);
-        }
-        return source;
-    }
-
-    private QpidByteBuffer createSlice()
-    {
-        _parent.position(1);
-        _parent.limit(_parent.capacity() - 1);
-
-        return _parent.slice();
-    }
-
-    private void testPutGet(final Class<?> primitiveTargetClass, final boolean unsigned, final Object value) throws Exception
-    {
-        int size = sizeof(primitiveTargetClass);
-
-        _parent.position(1);
-        _parent.limit(size + 1);
-
-        _slicedBuffer = _parent.slice();
-        _parent.limit(_parent.capacity());
-
-        assertEquals("Unexpected position ", 0, _slicedBuffer.position());
-        assertEquals("Unexpected limit ", size, _slicedBuffer.limit());
-        assertEquals("Unexpected capacity ", size, _slicedBuffer.capacity());
-
-        String methodSuffix = getMethodSuffix(primitiveTargetClass, unsigned);
-        Method put = _slicedBuffer.getClass().getMethod("put" + methodSuffix, Primitives.primitiveTypeOf(value.getClass()));
-        Method get = _slicedBuffer.getClass().getMethod("get" + methodSuffix);
-
-
-        _slicedBuffer.mark();
-        QpidByteBuffer rv = (QpidByteBuffer) put.invoke(_slicedBuffer, value);
-        assertEquals("Unexpected builder return value for type " + methodSuffix, _slicedBuffer, rv);
-
-        assertEquals("Unexpected position for type " + methodSuffix, size, _slicedBuffer.position());
-
-        try
-        {
-            invokeMethod(put, value);
-            fail("BufferOverflowException should be thrown for put with insufficient room for " + methodSuffix);
-        }
-        catch (BufferOverflowException e)
-        {
-            // pass
-        }
-
-        _slicedBuffer.reset();
-
-        assertEquals("Unexpected position after reset", 0, _slicedBuffer.position());
-
-        Object retrievedValue = get.invoke(_slicedBuffer);
-        assertEquals("Unexpected value retrieved from get method for " + methodSuffix, value, retrievedValue);
-        try
-        {
-            invokeMethod(get);
-            fail("BufferUnderflowException not thrown for get with insufficient room for " + methodSuffix);
-        }
-        catch (BufferUnderflowException ite)
-        {
-            // pass
-        }
-    }
-
-    private void testPutGetByIndex(final Class<?> primitiveTargetClass, Object value) throws Exception
-    {
-        int size = sizeof(primitiveTargetClass);
-
-        _parent.position(1);
-        _parent.limit(size + 1);
-
-        _slicedBuffer = _parent.slice();
-        _parent.limit(_parent.capacity());
-
-        String methodSuffix = getMethodSuffix(primitiveTargetClass, false);
-        Method put = _slicedBuffer.getClass().getMethod("put" + methodSuffix, int.class, primitiveTargetClass);
-        Method get = _slicedBuffer.getClass().getMethod("get" + methodSuffix, int.class);
-
-        QpidByteBuffer rv = (QpidByteBuffer) put.invoke(_slicedBuffer, 0, value);
-        assertEquals("Unexpected builder return value for type " + methodSuffix, _slicedBuffer, rv);
-
-        Object retrievedValue = get.invoke(_slicedBuffer, 0);
-        assertEquals("Unexpected value retrieved from index get method for " + methodSuffix, value, retrievedValue);
-
-        try
-        {
-            invokeMethod(put, 1, value);
-            fail("IndexOutOfBoundsException not thrown for  indexed " + methodSuffix + " put");
-        }
-        catch (IndexOutOfBoundsException ite)
-        {
-            // pass
-        }
-
-        try
-        {
-            invokeMethod(put, -1, value);
-            fail("IndexOutOfBoundsException not thrown for indexed " + methodSuffix + " put with negative index");
-        }
-        catch (IndexOutOfBoundsException ite)
-        {
-            // pass
-        }
-
-        try
-        {
-            invokeMethod(get, 1);
-            fail("IndexOutOfBoundsException not thrown for indexed " + methodSuffix + " get");
-        }
-        catch (IndexOutOfBoundsException ite)
-        {
-            // pass
-        }
-
-        try
-        {
-            invokeMethod(get, -1);
-            fail("IndexOutOfBoundsException not thrown for indexed " + methodSuffix + " get with negative index");
-        }
-        catch (IndexOutOfBoundsException ite)
-        {
-            // pass
-        }
-    }
-
-    private void invokeMethod(final Method method, final Object... value)
-            throws Exception
-    {
-        try
-        {
-            method.invoke(_slicedBuffer, value);
-        }
-        catch (InvocationTargetException e)
-        {
-            Throwable cause = e.getCause();
-            if (cause instanceof Exception)
-            {
-                throw (Exception)cause;
-            }
-            fail(String.format("Unexpected throwable on method %s invocation: %s", method.getName(), cause));
-        }
-    }
-
-
-    private String getMethodSuffix(final Class<?> target, final boolean unsigned)
-    {
-        StringBuilder name = new StringBuilder();
-        if (unsigned)
-        {
-            name.append("Unsigned");
-        }
-        if ((!target.isAssignableFrom(byte.class) || unsigned))
-        {
-            String simpleName = target.getSimpleName();
-            name.append(simpleName.substring(0, 1).toUpperCase()).append(simpleName.substring(1));
-        }
-
-        return name.toString();
-    }
-
-    private int sizeof(final Class<?> type)
-    {
-        if (type.isAssignableFrom(double.class))
-        {
-            return 8;
-        }
-        else if (type.isAssignableFrom(float.class))
-        {
-            return 4;
-        }
-        else if (type.isAssignableFrom(long.class))
-        {
-            return 8;
-        }
-        else if (type.isAssignableFrom(int.class))
-        {
-            return 4;
-        }
-        else if (type.isAssignableFrom(short.class))
-        {
-            return 2;
-        }
-        else if (type.isAssignableFrom(char.class))
-        {
-            return 2;
-        }
-        else if (type.isAssignableFrom(byte.class))
-        {
-            return 1;
-        }
-        else
-        {
-            throw new UnsupportedOperationException("Unexpected type " + type);
-        }
-    }
-
-    public void testPooledBufferIsZeroedLoan() throws Exception
-    {
-        QpidByteBuffer buffer = QpidByteBuffer.allocateDirect(BUFFER_SIZE);
-
-        buffer.put((byte) 0xFF);
-        buffer.dispose();
-
-        buffer = QpidByteBuffer.allocateDirect(BUFFER_SIZE);
-        buffer.limit(1);
-        assertEquals("Pooled QpidByteBuffer is not zeroed.", (byte) 0x0, buffer.get());
-    }
-
-    public void testAllocateDirectOfSameSize() throws Exception
-    {
-        int bufferSize = BUFFER_SIZE;
-        QpidByteBuffer buffer = QpidByteBuffer.allocateDirect(bufferSize);
-        assertEquals("Unexpected buffer size", bufferSize, buffer.capacity());
-        assertEquals("Unexpected position on newly created buffer", 0, buffer.position());
-        assertEquals("Unexpected limit on newly created buffer", bufferSize, buffer.limit());
-    }
-
-    public void testAllocateDirectOfSmallerSize() throws Exception
-    {
-        int bufferSize = BUFFER_SIZE - 1;
-        QpidByteBuffer buffer = QpidByteBuffer.allocateDirect(bufferSize);
-        assertEquals("Unexpected buffer size", bufferSize, buffer.capacity());
-        assertEquals("Unexpected position on newly created buffer", 0, buffer.position());
-        assertEquals("Unexpected limit on newly created buffer", bufferSize, buffer.limit());
-    }
-
-    public void testAllocateDirectOfLargerSize() throws Exception
-    {
-        int bufferSize = BUFFER_SIZE + 1;
-        QpidByteBuffer buffer = QpidByteBuffer.allocateDirect(bufferSize);
-        assertEquals("Unexpected buffer size", bufferSize, buffer.capacity());
-        assertEquals("Unexpected position on newly created buffer", 0, buffer.position());
-        assertEquals("Unexpected limit on newly created buffer", bufferSize, buffer.limit());
-    }
-
-    public void testAllocateDirectWithNegativeSize() throws Exception
-    {
-        try
-        {
-            QpidByteBuffer.allocateDirect(-1);
-            fail("It is not legal to create buffer with negative size.");
-        }
-        catch (IllegalArgumentException e)
-        {
-            // pass
-        }
-    }
-
-    public void testSettingUpPoolTwice() throws Exception
-    {
-        try
-        {
-            QpidByteBuffer.initialisePool(BUFFER_SIZE + 1, POOL_SIZE + 1);
-            fail("It is not legal to initialize buffer twice with different settings.");
-        }
-        catch (IllegalStateException e)
-        {
-            // pass
-        }
-    }
-
-    public void testDeflateInflateDirect() throws Exception
-    {
-        byte[] input = "aaabbbcccddddeeeffff".getBytes();
-        Collection<QpidByteBuffer> inputBufs = QpidByteBuffer.allocateDirectCollection(input.length);
-
-        int offset = 0;
-        for (QpidByteBuffer buf : inputBufs)
-        {
-            int len = buf.remaining();
-            buf.put(input, offset, len);
-            buf.flip();
-            offset += len;
-        }
-        assertEquals(input.length, ByteBufferUtils.remaining(inputBufs));
-
-        doDeflateInflate(input, inputBufs, true);
-    }
-
-    public void testDeflateInflateHeap() throws Exception
-    {
-        byte[] input = "aaabbbcccddddeeeffff".getBytes();
-        Collection<QpidByteBuffer> inputBufs = Collections.singleton(QpidByteBuffer.wrap(input));
-
-        doDeflateInflate(input, inputBufs, false);
-    }
-
-    public void testInflatingUncompressedBytes_ThrowsZipException() throws Exception
-    {
-        byte[] input = "not_a_compressed_stream".getBytes();
-        QpidByteBuffer original = QpidByteBuffer.wrap(input);
-
-        try
-        {
-            QpidByteBuffer.inflate(Collections.singleton(original));
-            fail("Exception not thrown");
-        }
-        catch(java.util.zip.ZipException ze)
-        {
-            // PASS
-        }
-    }
-
-    public void testSlice() throws Exception
-    {
-        QpidByteBuffer directBuffer = QpidByteBuffer.allocate(true, 6);
-        directBuffer.position(2);
-        directBuffer.limit(5);
-        QpidByteBuffer directSlice = directBuffer.slice();
-
-        assertTrue("Direct slice should be direct too", directSlice.isDirect());
-        assertEquals("Unexpected capacity", 3, directSlice.capacity());
-        assertEquals("Unexpected limit", 3, directSlice.limit());
-        assertEquals("Unexpected position", 0, directSlice.position());
-
-        directBuffer.dispose();
-        directSlice.dispose();
-    }
-
-    public void testView() throws Exception
-    {
-        byte[] content = "ABCDEF".getBytes();
-        QpidByteBuffer buffer = QpidByteBuffer.allocate(true, content.length);
-        buffer.put(content);
-        buffer.position(2);
-        buffer.limit(5);
-
-        QpidByteBuffer view = buffer.view(0, buffer.remaining());
-
-        assertTrue("Unexpected view direct", view.isDirect());
-
-        assertEquals("Unexpected capacity", 3, view.capacity());
-        assertEquals("Unexpected limit", 3, view.limit());
-        assertEquals("Unexpected position", 0, view.position());
-
-        byte[] destination = new byte[view.remaining()];
-        view.get(destination);
-
-        Assert.assertArrayEquals("CDE".getBytes(), destination);
-
-        QpidByteBuffer viewWithOffset = buffer.view(1, 1);
-        destination = new byte[viewWithOffset.remaining()];
-        viewWithOffset.get(destination);
-
-        Assert.assertArrayEquals("D".getBytes(), destination);
-
-        buffer.dispose();
-        view.dispose();
-        viewWithOffset.dispose();
-    }
-
-    private void doDeflateInflate(byte[] input,
-                                  Collection<QpidByteBuffer> inputBufs,
-                                  boolean direct) throws IOException
-    {
-        Collection<QpidByteBuffer> deflatedBufs = QpidByteBuffer.deflate(inputBufs);
-        assertNotNull(deflatedBufs);
-
-        Collection<QpidByteBuffer> inflatedBufs = QpidByteBuffer.inflate(deflatedBufs);
-        assertNotNull(inflatedBufs);
-        assertTrue("Expected at least on buffer", inflatedBufs.size() >= 1);
-
-        int bufNum = 1;
-        int inputOffset = 0;
-        int inflatedBytesTotal = 0;
-        for(QpidByteBuffer inflatedBuf : inflatedBufs)
-        {
-            assertEquals("Inflated buf " + bufNum + " is of wrong type", direct, inflatedBuf.isDirect());
-
-            int inflatedBytesCount = inflatedBuf.remaining();
-            inflatedBytesTotal += inflatedBytesCount;
-
-            byte[] inflatedBytes = new byte[inflatedBytesCount];
-            inflatedBuf.get(inflatedBytes);
-            byte[] expectedBytes = Arrays.copyOfRange(input, inputOffset, inputOffset + inflatedBytes.length);
-            Assert.assertArrayEquals("Inflated buf" + bufNum + " has unexpected content", expectedBytes, inflatedBytes);
-
-            inputOffset += inflatedBytes.length;
-            bufNum++;
-        }
-
-        assertEquals("Unexpected number of inflated bytes", input.length, inflatedBytesTotal);
-    }
-
-}

http://git-wip-us.apache.org/repos/asf/qpid-jms-amqp-0-x/blob/95203e5d/client/src/test/java/org/apache/qpid/client/message/Encrypted091MessageFactoryTest.java
----------------------------------------------------------------------
diff --git a/client/src/test/java/org/apache/qpid/client/message/Encrypted091MessageFactoryTest.java b/client/src/test/java/org/apache/qpid/client/message/Encrypted091MessageFactoryTest.java
index 2062900..bbdc3d1 100644
--- a/client/src/test/java/org/apache/qpid/client/message/Encrypted091MessageFactoryTest.java
+++ b/client/src/test/java/org/apache/qpid/client/message/Encrypted091MessageFactoryTest.java
@@ -38,7 +38,6 @@ import javax.crypto.spec.IvParameterSpec;
 import javax.crypto.spec.SecretKeySpec;
 import javax.security.auth.x500.X500Principal;
 
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
 import org.apache.qpid.client.AMQConnection;
 import org.apache.qpid.client.AMQSession;
 import org.apache.qpid.framing.BasicContentHeaderProperties;
@@ -78,7 +77,7 @@ public class Encrypted091MessageFactoryTest extends QpidTestCase
 
             final int headerLength = _props.getPropertyListSize() + 2;
             _unencrypted = new byte[headerLength + _data.length];
-            QpidByteBuffer output = QpidByteBuffer.wrap(_unencrypted);
+            ByteBuffer output = ByteBuffer.wrap(_unencrypted);
             output.putShort((short) (_props.getPropertyFlags() & 0xffff));
             _props.writePropertyListPayload(output);
 

http://git-wip-us.apache.org/repos/asf/qpid-jms-amqp-0-x/blob/95203e5d/client/src/test/java/org/apache/qpid/codec/AMQDecoderTest.java
----------------------------------------------------------------------
diff --git a/client/src/test/java/org/apache/qpid/codec/AMQDecoderTest.java b/client/src/test/java/org/apache/qpid/codec/AMQDecoderTest.java
index 49505b4..282d3fb 100644
--- a/client/src/test/java/org/apache/qpid/codec/AMQDecoderTest.java
+++ b/client/src/test/java/org/apache/qpid/codec/AMQDecoderTest.java
@@ -29,7 +29,6 @@ import java.util.Collection;
 import java.util.List;
 import java.util.Random;
 
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
 import org.apache.qpid.framing.AMQBody;
 import org.apache.qpid.framing.AMQDataBlock;
 import org.apache.qpid.framing.AMQFrame;
@@ -138,7 +137,7 @@ public class AMQDecoderTest extends QpidTestCase
         {
             assertEquals(ContentBody.TYPE, ((AMQFrame) frames.get(0)).getBodyFrame().getFrameType());
             ContentBody decodedBody = (ContentBody) ((AMQFrame) frames.get(0)).getBodyFrame();
-            final ByteBuffer byteBuffer = decodedBody.getPayload().asByteBuffer().duplicate();
+            final ByteBuffer byteBuffer = decodedBody.getPayload().duplicate();
             byte[] bodyBytes = new byte[byteBuffer.remaining()];
             byteBuffer.get(bodyBytes);
             assertTrue("Body was corrupted", Arrays.equals(payload, bodyBytes));
@@ -246,16 +245,10 @@ public class AMQDecoderTest extends QpidTestCase
 
     private static class TestSender implements ByteBufferSender
     {
-        private final Collection<QpidByteBuffer> _sentBuffers = new ArrayList<>();
+        private final Collection<ByteBuffer> _sentBuffers = new ArrayList<>();
 
         @Override
-        public boolean isDirectBufferPreferred()
-        {
-            return false;
-        }
-
-        @Override
-        public void send(final QpidByteBuffer msg)
+        public void send(final ByteBuffer msg)
         {
             _sentBuffers.add(msg.duplicate());
             msg.position(msg.limit());
@@ -273,7 +266,7 @@ public class AMQDecoderTest extends QpidTestCase
 
         }
 
-        public Collection<QpidByteBuffer> getSentBuffers()
+        public Collection<ByteBuffer> getSentBuffers()
         {
             return _sentBuffers;
         }

http://git-wip-us.apache.org/repos/asf/qpid-jms-amqp-0-x/blob/95203e5d/client/src/test/java/org/apache/qpid/framing/BasicContentHeaderPropertiesTest.java
----------------------------------------------------------------------
diff --git a/client/src/test/java/org/apache/qpid/framing/BasicContentHeaderPropertiesTest.java b/client/src/test/java/org/apache/qpid/framing/BasicContentHeaderPropertiesTest.java
index c6c870a..2a46dcf 100644
--- a/client/src/test/java/org/apache/qpid/framing/BasicContentHeaderPropertiesTest.java
+++ b/client/src/test/java/org/apache/qpid/framing/BasicContentHeaderPropertiesTest.java
@@ -20,7 +20,8 @@
  */
 package org.apache.qpid.framing;
 
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import java.nio.ByteBuffer;
+
 import org.apache.qpid.test.utils.QpidTestCase;
 
 
@@ -78,7 +79,7 @@ public class BasicContentHeaderPropertiesTest extends QpidTestCase
 
     public void testPopulatePropertiesFromBuffer() throws Exception
     {
-        QpidByteBuffer buf = QpidByteBuffer.wrap(new byte[300]);
+        ByteBuffer buf = ByteBuffer.wrap(new byte[300]);
         _testProperties.populatePropertiesFromBuffer(buf, 99, 99);
     }
 

http://git-wip-us.apache.org/repos/asf/qpid-jms-amqp-0-x/blob/95203e5d/client/src/test/java/org/apache/qpid/framing/EncodingUtilsTest.java
----------------------------------------------------------------------
diff --git a/client/src/test/java/org/apache/qpid/framing/EncodingUtilsTest.java b/client/src/test/java/org/apache/qpid/framing/EncodingUtilsTest.java
index dd81e25..e55f000 100644
--- a/client/src/test/java/org/apache/qpid/framing/EncodingUtilsTest.java
+++ b/client/src/test/java/org/apache/qpid/framing/EncodingUtilsTest.java
@@ -20,41 +20,27 @@
 
 package org.apache.qpid.framing;
 
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
+import java.nio.ByteBuffer;
+
 import org.apache.qpid.test.utils.QpidTestCase;
 
 
 public class EncodingUtilsTest extends QpidTestCase
 {
     private static final int BUFFER_SIZE = 10;
-    private static final int POOL_SIZE = 20;
 
-    private QpidByteBuffer _buffer;
+    private ByteBuffer _buffer;
 
     @Override
     protected void setUp() throws Exception
     {
         super.setUp();
-        QpidByteBuffer.initialisePool(BUFFER_SIZE, POOL_SIZE);
-        _buffer = QpidByteBuffer.allocateDirect(BUFFER_SIZE);
-    }
-
-    @Override
-    public void tearDown() throws Exception
-    {
-        try
-        {
-            _buffer.dispose();
-        }
-        finally
-        {
-            super.tearDown();
-        }
+        _buffer = ByteBuffer.allocate(BUFFER_SIZE);
     }
 
     public void testReadLongAsShortStringWhenDigitsAreSpecified() throws Exception
     {
-        _buffer.putUnsignedByte((short)3);
+        _buffer.put((byte)3);
         _buffer.put((byte)'9');
         _buffer.put((byte)'2');
         _buffer.put((byte)'0');
@@ -64,7 +50,7 @@ public class EncodingUtilsTest extends QpidTestCase
 
     public void testReadLongAsShortStringWhenNonDigitCharacterIsSpecified() throws Exception
     {
-        _buffer.putUnsignedByte((short)2);
+        _buffer.put((byte)2);
         _buffer.put((byte)'1');
         _buffer.put((byte)'a');
         _buffer.flip();

http://git-wip-us.apache.org/repos/asf/qpid-jms-amqp-0-x/blob/95203e5d/client/src/test/java/org/apache/qpid/framing/FieldTableTest.java
----------------------------------------------------------------------
diff --git a/client/src/test/java/org/apache/qpid/framing/FieldTableTest.java b/client/src/test/java/org/apache/qpid/framing/FieldTableTest.java
index 508617b..f759ddc 100644
--- a/client/src/test/java/org/apache/qpid/framing/FieldTableTest.java
+++ b/client/src/test/java/org/apache/qpid/framing/FieldTableTest.java
@@ -21,16 +21,16 @@
 package org.apache.qpid.framing;
 
 import java.io.IOException;
+import java.nio.ByteBuffer;
 import java.util.Arrays;
 import java.util.Collection;
 import java.util.Collections;
 import java.util.Iterator;
 
-import org.apache.qpid.bytebuffer.QpidByteBuffer;
-import org.apache.qpid.test.utils.QpidTestCase;
 import org.junit.Assert;
 
 import org.apache.qpid.AMQPInvalidClassException;
+import org.apache.qpid.test.utils.QpidTestCase;
 
 public class FieldTableTest extends QpidTestCase
 {
@@ -465,7 +465,7 @@ public class FieldTableTest extends QpidTestCase
         outerTable.setFieldTable("innerTable", innerTable);
 
         // Write the outer table into the buffer.
-        QpidByteBuffer buf = QpidByteBuffer.allocate(EncodingUtils.encodedFieldTableLength(outerTable));
+        ByteBuffer buf = ByteBuffer.allocate(EncodingUtils.encodedFieldTableLength(outerTable));
 
         outerTable.writeToBuffer(buf);
 
@@ -594,7 +594,7 @@ public class FieldTableTest extends QpidTestCase
         table.setString("null-string", null);
 
 
-        QpidByteBuffer buf = QpidByteBuffer.allocate((int) table.getEncodedSize() + 4);
+        ByteBuffer buf = ByteBuffer.allocate((int) table.getEncodedSize() + 4);
         table.writeToBuffer(buf);
 
         buf.flip();
@@ -916,7 +916,7 @@ public class FieldTableTest extends QpidTestCase
         assertEquals("unexpected data length", 24, length);
 
         //Create a second FieldTable from the encoded bytes
-        FieldTable tableFromBytes = new FieldTable(QpidByteBuffer.wrap(data));
+        FieldTable tableFromBytes = new FieldTable(ByteBuffer.wrap(data));
 
         //Create a final FieldTable and addAll() from the table created with encoded bytes
         FieldTable destinationTable = new FieldTable();


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org