Package akka.remote.artery
Class EnvelopeBuffer
- java.lang.Object
-
- akka.remote.artery.EnvelopeBuffer
-
public final class EnvelopeBuffer extends java.lang.Object
INTERNAL API
-
-
Constructor Summary
Constructors Constructor Description EnvelopeBuffer(java.nio.ByteBuffer byteBuffer)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static int
ActorRefCompressionTableVersionOffset()
org.agrona.concurrent.UnsafeBuffer
aeronBuffer()
java.nio.ByteBuffer
byteBuffer()
static int
ClassManifestCompressionTableVersionOffset()
static int
ClassManifestTagOffset()
EnvelopeBuffer
copy()
static int
FlagsOffset()
static int
MetadataContainerAndLiteralSectionOffset()
static ByteFlag
MetadataPresentFlag()
void
parseHeader(HeaderBuilder h)
static int
RecipientActorRefTagOffset()
static int
SenderActorRefTagOffset()
static int
SerializerOffset()
void
setStreamId(int newStreamId)
int
streamId()
static int
TagTypeMask()
static int
TagValueMask()
void
tryCleanDirectByteBuffer()
static int
UidOffset()
static int
VersionOffset()
void
writeHeader(HeaderBuilder h)
void
writeHeader(HeaderBuilder h, OutboundEnvelope oe)
-
-
-
Method Detail
-
TagTypeMask
public static int TagTypeMask()
-
TagValueMask
public static int TagValueMask()
-
MetadataPresentFlag
public static ByteFlag MetadataPresentFlag()
-
VersionOffset
public static int VersionOffset()
-
FlagsOffset
public static int FlagsOffset()
-
ActorRefCompressionTableVersionOffset
public static int ActorRefCompressionTableVersionOffset()
-
ClassManifestCompressionTableVersionOffset
public static int ClassManifestCompressionTableVersionOffset()
-
UidOffset
public static int UidOffset()
-
SerializerOffset
public static int SerializerOffset()
-
SenderActorRefTagOffset
public static int SenderActorRefTagOffset()
-
RecipientActorRefTagOffset
public static int RecipientActorRefTagOffset()
-
ClassManifestTagOffset
public static int ClassManifestTagOffset()
-
MetadataContainerAndLiteralSectionOffset
public static int MetadataContainerAndLiteralSectionOffset()
-
byteBuffer
public java.nio.ByteBuffer byteBuffer()
-
aeronBuffer
public org.agrona.concurrent.UnsafeBuffer aeronBuffer()
-
streamId
public int streamId()
-
setStreamId
public void setStreamId(int newStreamId)
-
writeHeader
public void writeHeader(HeaderBuilder h)
-
writeHeader
public void writeHeader(HeaderBuilder h, OutboundEnvelope oe)
-
parseHeader
public void parseHeader(HeaderBuilder h)
-
tryCleanDirectByteBuffer
public void tryCleanDirectByteBuffer()
-
copy
public EnvelopeBuffer copy()
-
-