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

INTERNAL API

Constructor Summary

Constructors

Constructor and Description
HeaderBuilderImpl(InboundCompressions inboundCompression, CompressionTable<ActorRef> _outboundActorRefCompression, CompressionTable<java.lang.String> _outboundClassManifestCompression)

Method Summary

Modifier and Type	Method and Description
byte	_flags()
byte	_inboundActorRefCompressionTableVersion()
byte	_inboundClassManifestCompressionTableVersion()
java.lang.String	_manifest()
int	_manifestIdx()
CompressionTable<ActorRef>	_outboundActorRefCompression()
CompressionTable<java.lang.String>	_outboundClassManifestCompression()
java.lang.String	_recipientActorRef()
int	_recipientActorRefIdx()
OptionVal<RemoteInstruments>	_remoteInstruments()
java.lang.String	_senderActorRef()
int	_senderActorRefIdx()
int	_serializer()
long	_uid()
boolean	_useOutboundCompression()
byte	_version()
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, boolean value)
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)
void	setRemoteInstruments(RemoteInstruments instruments)
void	setSenderActorRef(ActorRef ref)
void	setSerializer(int serializer)
void	setUid(long uid)
void	setVersion(byte v)
java.lang.String	toString()
long	uid()
void	useOutboundCompression(boolean on)
byte	version()

Methods inherited from class java.lang.Object

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

Constructor Detail

HeaderBuilderImpl

public HeaderBuilderImpl(InboundCompressions inboundCompression,
                         CompressionTable<ActorRef> _outboundActorRefCompression,
                         CompressionTable<java.lang.String> _outboundClassManifestCompression)

Method Detail

_outboundActorRefCompression

public CompressionTable<ActorRef> _outboundActorRefCompression()

_outboundClassManifestCompression

public CompressionTable<java.lang.String> _outboundClassManifestCompression()

_version

public byte _version()

_flags

public byte _flags()

_uid

public long _uid()

_inboundActorRefCompressionTableVersion

public byte _inboundActorRefCompressionTableVersion()

_inboundClassManifestCompressionTableVersion

public byte _inboundClassManifestCompressionTableVersion()

_useOutboundCompression

public boolean _useOutboundCompression()

_senderActorRef

public java.lang.String _senderActorRef()

_senderActorRefIdx

public int _senderActorRefIdx()

_recipientActorRef

public java.lang.String _recipientActorRef()

_recipientActorRefIdx

public int _recipientActorRefIdx()

_serializer

public int _serializer()

_manifest

public java.lang.String _manifest()

_manifestIdx

public int _manifestIdx()

_remoteInstruments

public OptionVal<RemoteInstruments> _remoteInstruments()

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 interface HeaderBuilder

setVersion

public void setVersion(byte v)

Specified by:

setVersion in interface HeaderBuilder

version

public byte version()

Specified by:

version in interface HeaderBuilder

setFlags

public void setFlags(byte v)

Specified by:

setFlags in interface HeaderBuilder

flags

public byte flags()

Specified by:

flags in interface HeaderBuilder

flag

public boolean flag(ByteFlag byteFlag)

Specified by:

flag in interface HeaderBuilder

setFlag

public void setFlag(ByteFlag byteFlag,
                    boolean value)

Specified by:

setFlag in interface HeaderBuilder

setUid

public void setUid(long uid)

Specified by:

setUid in interface HeaderBuilder

uid

public long uid()

Specified by:

uid in interface HeaderBuilder

inboundActorRefCompressionTableVersion

public byte inboundActorRefCompressionTableVersion()

Specified by:

inboundActorRefCompressionTableVersion in interface HeaderBuilder

inboundClassManifestCompressionTableVersion

public byte inboundClassManifestCompressionTableVersion()

Specified by:

inboundClassManifestCompressionTableVersion in interface HeaderBuilder

useOutboundCompression

public void useOutboundCompression(boolean on)

Specified by:

useOutboundCompression in interface HeaderBuilder

setOutboundActorRefCompression

public void setOutboundActorRefCompression(CompressionTable<ActorRef> table)

Specified by:

setOutboundActorRefCompression in interface HeaderBuilder

outboundActorRefCompression

public CompressionTable<ActorRef> outboundActorRefCompression()

Specified by:

outboundActorRefCompression in interface HeaderBuilder

setOutboundClassManifestCompression

public void setOutboundClassManifestCompression(CompressionTable<java.lang.String> table)

Specified by:

setOutboundClassManifestCompression in interface HeaderBuilder

outboundClassManifestCompression

public CompressionTable<java.lang.String> outboundClassManifestCompression()

Specified by:

outboundClassManifestCompression in interface HeaderBuilder

setSenderActorRef

public void setSenderActorRef(ActorRef ref)

Specified by:

setSenderActorRef in interface HeaderBuilder

setNoSender

public void setNoSender()

Specified by:

setNoSender in interface HeaderBuilder

isNoSender

public boolean isNoSender()

Specified by:

isNoSender in interface HeaderBuilder

senderActorRef

public OptionVal<ActorRef> senderActorRef(long originUid)

Description copied from interface: HeaderBuilder

Retrive the compressed ActorRef by the compressionId carried by this header. Returns None if ActorRef was not compressed, and then the literal senderActorRefPath should be used.

Specified by:

senderActorRef in interface HeaderBuilder

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. Returns None if ActorRef was compressed (!). To obtain the path in such case call senderActorRef and extract the path from it directly.

Specified by:

senderActorRefPath in interface HeaderBuilder

Returns:

(undocumented)

setNoRecipient

public void setNoRecipient()

Specified by:

setNoRecipient in interface HeaderBuilder

isNoRecipient

public boolean isNoRecipient()

Specified by:

isNoRecipient in interface HeaderBuilder

setRecipientActorRef

public void setRecipientActorRef(ActorRef ref)

Specified by:

setRecipientActorRef in interface HeaderBuilder

recipientActorRef

public OptionVal<ActorRef> recipientActorRef(long originUid)

Description copied from interface: HeaderBuilder

Retrive the compressed ActorRef by the compressionId carried by this header. Returns None if ActorRef was not compressed, and then the literal recipientActorRefPath should be used.

Specified by:

recipientActorRef in interface HeaderBuilder

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. Returns None if ActorRef was compressed (!). To obtain the path in such case call recipientActorRefPath and extract the path from it directly.

Specified by:

recipientActorRefPath in interface HeaderBuilder

Returns:

(undocumented)

setSerializer

public void setSerializer(int serializer)

Specified by:

setSerializer in interface HeaderBuilder

serializer

public int serializer()

Specified by:

serializer in interface HeaderBuilder

setManifest

public void setManifest(java.lang.String manifest)

Specified by:

setManifest in interface HeaderBuilder

manifest

public OptionVal<java.lang.String> manifest(long originUid)

Specified by:

manifest in interface HeaderBuilder

setRemoteInstruments

public void setRemoteInstruments(RemoteInstruments instruments)

Specified by:

setRemoteInstruments in interface HeaderBuilder

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object