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 using Serialization.serializedActorPath

Constructor Summary

Constructors

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

Method Summary

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 using Serialization.serializedActorPath
void	setRemoteInstruments(RemoteInstruments instruments)
void	setSenderActorRef(ActorRef ref)	Note that Serialization.currentTransportInformation must be set when calling this method, because it's using Serialization.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()

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

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

flag

public boolean flag(ByteFlag byteFlag)

Specified by:

flag in interface HeaderBuilder

flags

public byte flags()

Specified by:

flags in interface HeaderBuilder

inboundActorRefCompressionTableVersion

public byte inboundActorRefCompressionTableVersion()

Specified by:

inboundActorRefCompressionTableVersion in interface HeaderBuilder

inboundClassManifestCompressionTableVersion

public byte inboundClassManifestCompressionTableVersion()

Specified by:

inboundClassManifestCompressionTableVersion in interface HeaderBuilder

isNoRecipient

public boolean isNoRecipient()

Specified by:

isNoRecipient in interface HeaderBuilder

isNoSender

public boolean isNoSender()

Specified by:

isNoSender in interface HeaderBuilder

manifest

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

Specified by:

manifest in interface HeaderBuilder

outboundActorRefCompression

public CompressionTable<ActorRef> outboundActorRefCompression()

Specified by:

outboundActorRefCompression in interface HeaderBuilder

outboundClassManifestCompression

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

Specified by:

outboundClassManifestCompression 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 HeaderBuilder.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 HeaderBuilder.recipientActorRefPath() and extract the path from it directly.

Specified by:

recipientActorRefPath in interface HeaderBuilder

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 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 HeaderBuilder.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 HeaderBuilder.senderActorRef(long) and extract the path from it directly.

Specified by:

senderActorRefPath in interface HeaderBuilder

Returns:

(undocumented)

serializer

public int serializer()

Specified by:

serializer in interface HeaderBuilder

setFlag

public void setFlag(ByteFlag byteFlag)

Specified by:

setFlag in interface HeaderBuilder

setFlags

public void setFlags(byte v)

Specified by:

setFlags in interface HeaderBuilder

setManifest

public void setManifest(java.lang.String manifest)

Specified by:

setManifest in interface HeaderBuilder

setNoRecipient

public void setNoRecipient()

Specified by:

setNoRecipient in interface HeaderBuilder

setNoSender

public void setNoSender()

Specified by:

setNoSender in interface HeaderBuilder

setOutboundActorRefCompression

public void setOutboundActorRefCompression(CompressionTable<ActorRef> table)

Specified by:

setOutboundActorRefCompression in interface HeaderBuilder

setOutboundClassManifestCompression

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

Specified by:

setOutboundClassManifestCompression in interface HeaderBuilder

setRecipientActorRef

public void setRecipientActorRef(ActorRef ref)

Note that Serialization.currentTransportInformation must be set when calling this method, because it's using Serialization.serializedActorPath

Specified by:

setRecipientActorRef in interface HeaderBuilder

Parameters:

ref - (undocumented)

setRemoteInstruments

public void setRemoteInstruments(RemoteInstruments instruments)

Specified by:

setRemoteInstruments in interface HeaderBuilder

setSenderActorRef

public void setSenderActorRef(ActorRef ref)

Note that Serialization.currentTransportInformation must be set when calling this method, because it's using Serialization.serializedActorPath

Specified by:

setSenderActorRef in interface HeaderBuilder

Parameters:

ref - (undocumented)

setSerializer

public void setSerializer(int serializer)

Specified by:

setSerializer in interface HeaderBuilder

setUid

public void setUid(long uid)

Specified by:

setUid in interface HeaderBuilder

setVersion

public void setVersion(byte v)

Specified by:

setVersion in interface HeaderBuilder

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

uid

public long uid()

Specified by:

uid in interface HeaderBuilder

useOutboundCompression

public void useOutboundCompression(boolean on)

Specified by:

useOutboundCompression in interface HeaderBuilder

version

public byte version()

Specified by:

version in interface HeaderBuilder