Package akka.remote.artery
Interface HeaderBuilder
-
public interface HeaderBuilder
INTERNAL API
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
clearFlag(akka.remote.artery.ByteFlag byteFlag)
boolean
flag(akka.remote.artery.ByteFlag byteFlag)
byte
flags()
byte
inboundActorRefCompressionTableVersion()
byte
inboundClassManifestCompressionTableVersion()
boolean
isNoRecipient()
boolean
isNoSender()
<any>
manifest(long originUid)
<any>
outboundActorRefCompression()
<any>
outboundClassManifestCompression()
<any>
recipientActorRef(long originUid)
Retrive the compressed ActorRef by the compressionId carried by this header.<any>
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.<any>
senderActorRef(long originUid)
Retrive the compressed ActorRef by the compressionId carried by this header.<any>
senderActorRefPath()
Retrive the raw literal actor path, instead of using the compressed value.int
serializer()
void
setFlag(akka.remote.artery.ByteFlag byteFlag)
void
setFlags(byte v)
void
setManifest(java.lang.String manifest)
void
setNoRecipient()
void
setNoSender()
void
setOutboundActorRefCompression(<any> table)
void
setOutboundClassManifestCompression(<any> table)
void
setRecipientActorRef(ActorRef ref)
void
setRemoteInstruments(akka.remote.artery.RemoteInstruments instruments)
void
setSenderActorRef(ActorRef ref)
void
setSerializer(int serializer)
void
setUid(long u)
void
setVersion(byte v)
long
uid()
void
useOutboundCompression(boolean on)
byte
version()
-
-
-
Method Detail
-
setVersion
void setVersion(byte v)
-
version
byte version()
-
setFlags
void setFlags(byte v)
-
flags
byte flags()
-
flag
boolean flag(akka.remote.artery.ByteFlag byteFlag)
-
setFlag
void setFlag(akka.remote.artery.ByteFlag byteFlag)
-
clearFlag
void clearFlag(akka.remote.artery.ByteFlag byteFlag)
-
inboundActorRefCompressionTableVersion
byte inboundActorRefCompressionTableVersion()
-
inboundClassManifestCompressionTableVersion
byte inboundClassManifestCompressionTableVersion()
-
useOutboundCompression
void useOutboundCompression(boolean on)
-
outboundActorRefCompression
<any> outboundActorRefCompression()
-
setOutboundActorRefCompression
void setOutboundActorRefCompression(<any> table)
-
outboundClassManifestCompression
<any> outboundClassManifestCompression()
-
setOutboundClassManifestCompression
void setOutboundClassManifestCompression(<any> table)
-
setUid
void setUid(long u)
-
uid
long uid()
-
setSenderActorRef
void setSenderActorRef(ActorRef ref)
-
senderActorRef
<any> senderActorRef(long originUid)
Retrive the compressed ActorRef by the compressionId carried by this header. ReturnsNone
if ActorRef was not compressed, and then the literalsenderActorRefPath()
should be used.
-
senderActorRefPath
<any> senderActorRefPath()
Retrive the raw literal actor path, instead of using the compressed value. ReturnsNone
if ActorRef was compressed (!). To obtain the path in such case callsenderActorRef(long)
and extract the path from it directly.
-
setNoSender
void setNoSender()
-
isNoSender
boolean isNoSender()
-
setNoRecipient
void setNoRecipient()
-
isNoRecipient
boolean isNoRecipient()
-
setRecipientActorRef
void setRecipientActorRef(ActorRef ref)
-
recipientActorRef
<any> recipientActorRef(long originUid)
Retrive the compressed ActorRef by the compressionId carried by this header. ReturnsNone
if ActorRef was not compressed, and then the literalrecipientActorRefPath()
should be used.
-
recipientActorRefPath
<any> recipientActorRefPath()
Retrive the raw literal actor path, instead of using the compressed value. ReturnsNone
if ActorRef was compressed (!). To obtain the path in such case callrecipientActorRefPath()
and extract the path from it directly.
-
setSerializer
void setSerializer(int serializer)
-
serializer
int serializer()
-
setManifest
void setManifest(java.lang.String manifest)
-
manifest
<any> manifest(long originUid)
-
setRemoteInstruments
void setRemoteInstruments(akka.remote.artery.RemoteInstruments instruments)
-
resetMessageFields
void resetMessageFields()
Reset all fields that are related to an outbound message, i.e. Encoder calls this as the first thing in onPush.
-
-