@Test public void testReadUTF8() throws CharacterCodingException { String testString = "test-string-1"; byte[] asUtf8bytes = testString.getBytes(StandardCharsets.UTF_8); ByteBuf byteBuffer = Unpooled.wrappedBuffer(asUtf8bytes); AmqpReadableBuffer buffer = new AmqpReadableBuffer(byteBuffer); assertEquals(testString, buffer.readUTF8()); }
@Override public String readUTF8() throws CharacterCodingException { return buffer.toString(StandardCharsets.UTF_8); }
AmqpReadableBuffer implements ReadableBuffer { @Override public String readUTF8() throws CharacterCodingException { return buffer.toString(StandardCharsets.UTF_8); } }
AmqpReadableBuffer implements ReadableBuffer { @Override public String readUTF8() throws CharacterCodingException { return buffer.toString(StandardCharsets.UTF_8); } AmqpReadableBuffer(ByteBuf buffer); }
AmqpReadableBuffer implements ReadableBuffer { @Override public String readUTF8() throws CharacterCodingException { return buffer.toString(StandardCharsets.UTF_8); } AmqpReadableBuffer(ByteBuf buffer); ByteBuf getBuffer(); @Override int capacity(); @Override boolean hasArray(); @Override byte[] array(); @Override int arrayOffset(); @Override ReadableBuffer reclaimRead(); @Override byte get(); @Override byte get(int index); @Override int getInt(); @Override long getLong(); @Override short getShort(); @Override float getFloat(); @Override double getDouble(); @Override ReadableBuffer get(byte[] target, int offset, int length); @Override ReadableBuffer get(byte[] target); @Override ReadableBuffer get(WritableBuffer target); @Override ReadableBuffer slice(); @Override ReadableBuffer flip(); @Override ReadableBuffer limit(int limit); @Override int limit(); @Override ReadableBuffer position(int position); @Override int position(); @Override ReadableBuffer mark(); @Override ReadableBuffer reset(); @Override ReadableBuffer rewind(); @Override ReadableBuffer clear(); @Override int remaining(); @Override boolean hasRemaining(); @Override ReadableBuffer duplicate(); @Override ByteBuffer byteBuffer(); @Override String readUTF8(); @Override String readString(CharsetDecoder decoder); }
AmqpReadableBuffer implements ReadableBuffer { @Override public String readUTF8() throws CharacterCodingException { return buffer.toString(StandardCharsets.UTF_8); } AmqpReadableBuffer(ByteBuf buffer); ByteBuf getBuffer(); @Override int capacity(); @Override boolean hasArray(); @Override byte[] array(); @Override int arrayOffset(); @Override ReadableBuffer reclaimRead(); @Override byte get(); @Override byte get(int index); @Override int getInt(); @Override long getLong(); @Override short getShort(); @Override float getFloat(); @Override double getDouble(); @Override ReadableBuffer get(byte[] target, int offset, int length); @Override ReadableBuffer get(byte[] target); @Override ReadableBuffer get(WritableBuffer target); @Override ReadableBuffer slice(); @Override ReadableBuffer flip(); @Override ReadableBuffer limit(int limit); @Override int limit(); @Override ReadableBuffer position(int position); @Override int position(); @Override ReadableBuffer mark(); @Override ReadableBuffer reset(); @Override ReadableBuffer rewind(); @Override ReadableBuffer clear(); @Override int remaining(); @Override boolean hasRemaining(); @Override ReadableBuffer duplicate(); @Override ByteBuffer byteBuffer(); @Override String readUTF8(); @Override String readString(CharsetDecoder decoder);  }