Package akka.remote.artery
Interface HeaderBuilder
-
public interface HeaderBuilderINTERNAL API
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidclearFlag(akka.remote.artery.ByteFlag byteFlag)booleanflag(akka.remote.artery.ByteFlag byteFlag)byteflags()byteinboundActorRefCompressionTableVersion()byteinboundClassManifestCompressionTableVersion()booleanisNoRecipient()booleanisNoSender()<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.voidresetMessageFields()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.intserializer()voidsetFlag(akka.remote.artery.ByteFlag byteFlag)voidsetFlags(byte v)voidsetManifest(java.lang.String manifest)voidsetNoRecipient()voidsetNoSender()voidsetOutboundActorRefCompression(<any> table)voidsetOutboundClassManifestCompression(<any> table)voidsetRecipientActorRef(ActorRef ref)voidsetRemoteInstruments(akka.remote.artery.RemoteInstruments instruments)voidsetSenderActorRef(ActorRef ref)voidsetSerializer(int serializer)voidsetUid(long u)voidsetVersion(byte v)longuid()voiduseOutboundCompression(boolean on)byteversion()
-
-
-
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. ReturnsNoneif 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. ReturnsNoneif 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. ReturnsNoneif 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. ReturnsNoneif 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.
-
-