Module org.neo4j.bolt.connection.netty

Package org.neo4j.bolt.connection.netty.impl.async.connection

Class BoltProtocolUtil

java.lang.Object

org.neo4j.bolt.connection.netty.impl.async.connection.BoltProtocolUtil

public final class BoltProtocolUtil
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final int	BOLT_MAGIC_PREAMBLE
static final int	CHUNK_HEADER_SIZE_BYTES
static final int	DEFAULT_MAX_OUTBOUND_CHUNK_SIZE_BYTES
static final BoltProtocolVersion	NO_PROTOCOL_VERSION
static final SortedMap<BoltProtocolVersion,BoltProtocol>	versionToProtocol

Method Summary

Modifier and Type	Method	Description
static io.netty.buffer.ByteBuf	handshakeBuf()
static String	handshakeString()
static void	writeChunkHeader(io.netty.buffer.ByteBuf buf, int chunkStartIndex, int headerValue)
static void	writeEmptyChunkHeader(io.netty.buffer.ByteBuf buf)
static void	writeMessageBoundary(io.netty.buffer.ByteBuf buf)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

BOLT_MAGIC_PREAMBLE

public static final int BOLT_MAGIC_PREAMBLE

See Also:

• Constant Field Values

NO_PROTOCOL_VERSION

public static final BoltProtocolVersion NO_PROTOCOL_VERSION

CHUNK_HEADER_SIZE_BYTES

public static final int CHUNK_HEADER_SIZE_BYTES

See Also:

• Constant Field Values

DEFAULT_MAX_OUTBOUND_CHUNK_SIZE_BYTES

public static final int DEFAULT_MAX_OUTBOUND_CHUNK_SIZE_BYTES

See Also:

• Constant Field Values

versionToProtocol

public static final SortedMap<BoltProtocolVersion,BoltProtocol> versionToProtocol

Method Details

handshakeBuf

public static io.netty.buffer.ByteBuf handshakeBuf()

handshakeString

public static String handshakeString()

writeMessageBoundary

public static void writeMessageBoundary(io.netty.buffer.ByteBuf buf)

writeEmptyChunkHeader

public static void writeEmptyChunkHeader(io.netty.buffer.ByteBuf buf)

writeChunkHeader

public static void writeChunkHeader(io.netty.buffer.ByteBuf buf,
 int chunkStartIndex,
 int headerValue)