Package akka.remote.artery
Class HeaderBuilderImpl
- java.lang.Object
-
- akka.remote.artery.HeaderBuilderImpl
-
- All Implemented Interfaces:
HeaderBuilder
public final class HeaderBuilderImpl extends java.lang.Object implements HeaderBuilder
Note that Serialization.currentTransportInformation must be set when calling this method, because it's usingSerialization.serializedActorPath
-
-
Constructor Summary
Constructors Constructor Description HeaderBuilderImpl(InboundCompressions inboundCompression, CompressionTable<ActorRef> _outboundActorRefCompression, CompressionTable<java.lang.String> _outboundClassManifestCompression)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description byte
_flags()
void
_flags_$eq(byte x$1)
byte
_inboundActorRefCompressionTableVersion()
void
_inboundActorRefCompressionTableVersion_$eq(byte x$1)
byte
_inboundClassManifestCompressionTableVersion()
void
_inboundClassManifestCompressionTableVersion_$eq(byte x$1)
java.lang.String
_manifest()
void
_manifest_$eq(java.lang.String x$1)
int
_manifestIdx()
void
_manifestIdx_$eq(int x$1)
CompressionTable<ActorRef>
_outboundActorRefCompression()
void
_outboundActorRefCompression_$eq(CompressionTable<ActorRef> x$1)
CompressionTable<java.lang.String>
_outboundClassManifestCompression()
void
_outboundClassManifestCompression_$eq(CompressionTable<java.lang.String> x$1)
java.lang.String
_recipientActorRef()
void
_recipientActorRef_$eq(java.lang.String x$1)
int
_recipientActorRefIdx()
void
_recipientActorRefIdx_$eq(int x$1)
OptionVal<RemoteInstruments>
_remoteInstruments()
void
_remoteInstruments_$eq(OptionVal<RemoteInstruments> x$1)
java.lang.String
_senderActorRef()
void
_senderActorRef_$eq(java.lang.String x$1)
int
_senderActorRefIdx()
void
_senderActorRefIdx_$eq(int x$1)
int
_serializer()
void
_serializer_$eq(int x$1)
long
_uid()
void
_uid_$eq(long x$1)
boolean
_useOutboundCompression()
void
_useOutboundCompression_$eq(boolean x$1)
byte
_version()
void
_version_$eq(byte x$1)
void
clearFlag(ByteFlag byteFlag)
boolean
flag(ByteFlag byteFlag)
byte
flags()
byte
inboundActorRefCompressionTableVersion()
byte
inboundClassManifestCompressionTableVersion()
boolean
isNoRecipient()
boolean
isNoSender()
OptionVal<java.lang.String>
manifest(long originUid)
CompressionTable<ActorRef>
outboundActorRefCompression()
CompressionTable<java.lang.String>
outboundClassManifestCompression()
OptionVal<ActorRef>
recipientActorRef(long originUid)
Retrive the compressed ActorRef by the compressionId carried by this header.OptionVal<java.lang.String>
recipientActorRefPath()
Retrive the raw literal actor path, instead of using the compressed value.void
resetMessageFields()
Reset all fields that are related to an outbound message, i.e.OptionVal<ActorRef>
senderActorRef(long originUid)
Retrive the compressed ActorRef by the compressionId carried by this header.OptionVal<java.lang.String>
senderActorRefPath()
Retrive the raw literal actor path, instead of using the compressed value.int
serializer()
void
setFlag(ByteFlag byteFlag)
void
setFlags(byte v)
void
setManifest(java.lang.String manifest)
void
setNoRecipient()
void
setNoSender()
void
setOutboundActorRefCompression(CompressionTable<ActorRef> table)
void
setOutboundClassManifestCompression(CompressionTable<java.lang.String> table)
void
setRecipientActorRef(ActorRef ref)
Note that Serialization.currentTransportInformation must be set when calling this method, because it's usingSerialization.serializedActorPath
void
setRemoteInstruments(RemoteInstruments instruments)
void
setSenderActorRef(ActorRef ref)
Note that Serialization.currentTransportInformation must be set when calling this method, because it's usingSerialization.serializedActorPath
void
setSerializer(int serializer)
void
setUid(long uid)
void
setVersion(byte v)
java.lang.String
toString()
long
uid()
void
useOutboundCompression(boolean on)
byte
version()
-
-
-
Constructor Detail
-
HeaderBuilderImpl
public HeaderBuilderImpl(InboundCompressions inboundCompression, CompressionTable<ActorRef> _outboundActorRefCompression, CompressionTable<java.lang.String> _outboundClassManifestCompression)
-
-
Method Detail
-
_flags
public byte _flags()
-
_flags_$eq
public void _flags_$eq(byte x$1)
-
_inboundActorRefCompressionTableVersion
public byte _inboundActorRefCompressionTableVersion()
-
_inboundActorRefCompressionTableVersion_$eq
public void _inboundActorRefCompressionTableVersion_$eq(byte x$1)
-
_inboundClassManifestCompressionTableVersion
public byte _inboundClassManifestCompressionTableVersion()
-
_inboundClassManifestCompressionTableVersion_$eq
public void _inboundClassManifestCompressionTableVersion_$eq(byte x$1)
-
_manifest
public java.lang.String _manifest()
-
_manifestIdx
public int _manifestIdx()
-
_manifestIdx_$eq
public void _manifestIdx_$eq(int x$1)
-
_manifest_$eq
public void _manifest_$eq(java.lang.String x$1)
-
_outboundActorRefCompression
public CompressionTable<ActorRef> _outboundActorRefCompression()
-
_outboundActorRefCompression_$eq
public void _outboundActorRefCompression_$eq(CompressionTable<ActorRef> x$1)
-
_outboundClassManifestCompression
public CompressionTable<java.lang.String> _outboundClassManifestCompression()
-
_outboundClassManifestCompression_$eq
public void _outboundClassManifestCompression_$eq(CompressionTable<java.lang.String> x$1)
-
_recipientActorRef
public java.lang.String _recipientActorRef()
-
_recipientActorRefIdx
public int _recipientActorRefIdx()
-
_recipientActorRefIdx_$eq
public void _recipientActorRefIdx_$eq(int x$1)
-
_recipientActorRef_$eq
public void _recipientActorRef_$eq(java.lang.String x$1)
-
_remoteInstruments
public OptionVal<RemoteInstruments> _remoteInstruments()
-
_remoteInstruments_$eq
public void _remoteInstruments_$eq(OptionVal<RemoteInstruments> x$1)
-
_senderActorRef
public java.lang.String _senderActorRef()
-
_senderActorRefIdx
public int _senderActorRefIdx()
-
_senderActorRefIdx_$eq
public void _senderActorRefIdx_$eq(int x$1)
-
_senderActorRef_$eq
public void _senderActorRef_$eq(java.lang.String x$1)
-
_serializer
public int _serializer()
-
_serializer_$eq
public void _serializer_$eq(int x$1)
-
_uid
public long _uid()
-
_uid_$eq
public void _uid_$eq(long x$1)
-
_useOutboundCompression
public boolean _useOutboundCompression()
-
_useOutboundCompression_$eq
public void _useOutboundCompression_$eq(boolean x$1)
-
_version
public byte _version()
-
_version_$eq
public void _version_$eq(byte x$1)
-
clearFlag
public void clearFlag(ByteFlag byteFlag)
- Specified by:
clearFlag
in interfaceHeaderBuilder
-
flag
public boolean flag(ByteFlag byteFlag)
- Specified by:
flag
in interfaceHeaderBuilder
-
flags
public byte flags()
- Specified by:
flags
in interfaceHeaderBuilder
-
inboundActorRefCompressionTableVersion
public byte inboundActorRefCompressionTableVersion()
- Specified by:
inboundActorRefCompressionTableVersion
in interfaceHeaderBuilder
-
inboundClassManifestCompressionTableVersion
public byte inboundClassManifestCompressionTableVersion()
- Specified by:
inboundClassManifestCompressionTableVersion
in interfaceHeaderBuilder
-
isNoRecipient
public boolean isNoRecipient()
- Specified by:
isNoRecipient
in interfaceHeaderBuilder
-
isNoSender
public boolean isNoSender()
- Specified by:
isNoSender
in interfaceHeaderBuilder
-
manifest
public OptionVal<java.lang.String> manifest(long originUid)
- Specified by:
manifest
in interfaceHeaderBuilder
-
outboundActorRefCompression
public CompressionTable<ActorRef> outboundActorRefCompression()
- Specified by:
outboundActorRefCompression
in interfaceHeaderBuilder
-
outboundClassManifestCompression
public CompressionTable<java.lang.String> outboundClassManifestCompression()
- Specified by:
outboundClassManifestCompression
in interfaceHeaderBuilder
-
recipientActorRef
public OptionVal<ActorRef> recipientActorRef(long originUid)
Description copied from interface:HeaderBuilder
Retrive the compressed ActorRef by the compressionId carried by this header. ReturnsNone
if ActorRef was not compressed, and then the literalHeaderBuilder.recipientActorRefPath()
should be used.- Specified by:
recipientActorRef
in interfaceHeaderBuilder
- Parameters:
originUid
- (undocumented)- Returns:
- (undocumented)
-
recipientActorRefPath
public OptionVal<java.lang.String> recipientActorRefPath()
Description copied from interface:HeaderBuilder
Retrive the raw literal actor path, instead of using the compressed value. ReturnsNone
if ActorRef was compressed (!). To obtain the path in such case callHeaderBuilder.recipientActorRefPath()
and extract the path from it directly.- Specified by:
recipientActorRefPath
in interfaceHeaderBuilder
- Returns:
- (undocumented)
-
resetMessageFields
public void resetMessageFields()
Description copied from interface:HeaderBuilder
Reset all fields that are related to an outbound message, i.e. Encoder calls this as the first thing in onPush.- Specified by:
resetMessageFields
in interfaceHeaderBuilder
-
senderActorRef
public OptionVal<ActorRef> senderActorRef(long originUid)
Description copied from interface:HeaderBuilder
Retrive the compressed ActorRef by the compressionId carried by this header. ReturnsNone
if ActorRef was not compressed, and then the literalHeaderBuilder.senderActorRefPath()
should be used.- Specified by:
senderActorRef
in interfaceHeaderBuilder
- Parameters:
originUid
- (undocumented)- Returns:
- (undocumented)
-
senderActorRefPath
public OptionVal<java.lang.String> senderActorRefPath()
Description copied from interface:HeaderBuilder
Retrive the raw literal actor path, instead of using the compressed value. ReturnsNone
if ActorRef was compressed (!). To obtain the path in such case callHeaderBuilder.senderActorRef(long)
and extract the path from it directly.- Specified by:
senderActorRefPath
in interfaceHeaderBuilder
- Returns:
- (undocumented)
-
serializer
public int serializer()
- Specified by:
serializer
in interfaceHeaderBuilder
-
setFlag
public void setFlag(ByteFlag byteFlag)
- Specified by:
setFlag
in interfaceHeaderBuilder
-
setFlags
public void setFlags(byte v)
- Specified by:
setFlags
in interfaceHeaderBuilder
-
setManifest
public void setManifest(java.lang.String manifest)
- Specified by:
setManifest
in interfaceHeaderBuilder
-
setNoRecipient
public void setNoRecipient()
- Specified by:
setNoRecipient
in interfaceHeaderBuilder
-
setNoSender
public void setNoSender()
- Specified by:
setNoSender
in interfaceHeaderBuilder
-
setOutboundActorRefCompression
public void setOutboundActorRefCompression(CompressionTable<ActorRef> table)
- Specified by:
setOutboundActorRefCompression
in interfaceHeaderBuilder
-
setOutboundClassManifestCompression
public void setOutboundClassManifestCompression(CompressionTable<java.lang.String> table)
- Specified by:
setOutboundClassManifestCompression
in interfaceHeaderBuilder
-
setRecipientActorRef
public void setRecipientActorRef(ActorRef ref)
Note that Serialization.currentTransportInformation must be set when calling this method, because it's usingSerialization.serializedActorPath
- Specified by:
setRecipientActorRef
in interfaceHeaderBuilder
- Parameters:
ref
- (undocumented)
-
setRemoteInstruments
public void setRemoteInstruments(RemoteInstruments instruments)
- Specified by:
setRemoteInstruments
in interfaceHeaderBuilder
-
setSenderActorRef
public void setSenderActorRef(ActorRef ref)
Note that Serialization.currentTransportInformation must be set when calling this method, because it's usingSerialization.serializedActorPath
- Specified by:
setSenderActorRef
in interfaceHeaderBuilder
- Parameters:
ref
- (undocumented)
-
setSerializer
public void setSerializer(int serializer)
- Specified by:
setSerializer
in interfaceHeaderBuilder
-
setUid
public void setUid(long uid)
- Specified by:
setUid
in interfaceHeaderBuilder
-
setVersion
public void setVersion(byte v)
- Specified by:
setVersion
in interfaceHeaderBuilder
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
uid
public long uid()
- Specified by:
uid
in interfaceHeaderBuilder
-
useOutboundCompression
public void useOutboundCompression(boolean on)
- Specified by:
useOutboundCompression
in interfaceHeaderBuilder
-
version
public byte version()
- Specified by:
version
in interfaceHeaderBuilder
-
-