BoltProtocolUtil { public static void writeMessageBoundary( ByteBuf buf ) { buf.writeShort( 0 ); } private  BoltProtocolUtil(); static ByteBuf handshakeBuf(); static String handshakeString(); static void writeMessageBoundary( ByteBuf buf ); static void writeEmptyChunkHeader( ByteBuf buf ); static void writeChunkHeader( ByteBuf buf, int chunkStartIndex, int headerValue ); static final int BOLT_MAGIC_PREAMBLE; static final BoltProtocolVersion NO_PROTOCOL_VERSION; static final int CHUNK_HEADER_SIZE_BYTES; static final int DEFAULT_MAX_OUTBOUND_CHUNK_SIZE_BYTES; }
@Test void shouldWriteMessageBoundary() { ByteBuf buf = Unpooled.buffer(); buf.writeInt( 1 ); buf.writeInt( 2 ); buf.writeInt( 3 ); writeMessageBoundary( buf ); assertByteBufContains( buf, 1, 2, 3, (byte) 0, (byte) 0 ); }