Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- public interface WritableBuffer
- {
- void put(CharSequence chars);
- }
- /**
- * Writable Buffer implementation based on a Netty ByteBuf
- */
- public class AmqpWritableBuffer implements WritableBuffer {
- @Override
- public void put(CharSequence chars) {
- final int bytes = ByteBufUtil.utf8Bytes(chars);
- ByteBufUtil.reserveAndWriteUtf8(nettyBuffer, chars, bytes);
- }
- }
Add Comment
Please, Sign In to add comment