akka.remote.artery.compress

Class InboundActorRefCompression

java.lang.Object

akka.remote.artery.compress.InboundCompression<ActorRef>

akka.remote.artery.compress.InboundActorRefCompression

public final class InboundActorRefCompression
extends InboundCompression<ActorRef>

INTERNAL API Dedicated per remote system inbound compression table.

The outbound context is available by looking it up in the association. It can be used to advertise a compression table. If the association is not complete - we simply dont advertise the table, which is fine (handshake not yet complete).

Nested Class Summary

Nested classes/interfaces inherited from class akka.remote.artery.compress.InboundCompression

InboundCompression.State<T>, InboundCompression.State$

Constructor Summary

Constructors

Constructor and Description
InboundActorRefCompression(LoggingAdapter log, ArterySettings.Compression settings, long originUid, InboundContext inboundContext, TopHeavyHitters<ActorRef> heavyHitters)

Method Summary

Modifier and Type	Method and Description
void	advertiseCompressionTable(OutboundContext outboundContext, CompressionTable<ActorRef> table) Must be implemented by extending classes in order to send a ControlMessage of appropriate type to the remote system in order to advertise the compression table to it.
OptionVal<ActorRef>	decompress(byte tableVersion, int idx) Override and specialize if needed, for default compression logic delegate to 3-param overload

Methods inherited from class akka.remote.artery.compress.InboundCompression

confirmAdvertisement, decompressInternal, heavyHitters, increment, log, runNextTableAdvertisement, settings, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

InboundActorRefCompression

public InboundActorRefCompression(LoggingAdapter log,
                                  ArterySettings.Compression settings,
                                  long originUid,
                                  InboundContext inboundContext,
                                  TopHeavyHitters<ActorRef> heavyHitters)

Method Detail

decompress

public OptionVal<ActorRef> decompress(byte tableVersion,
                                      int idx)

Description copied from class: InboundCompression

Override and specialize if needed, for default compression logic delegate to 3-param overload

Specified by:

decompress in class InboundCompression<ActorRef>

advertiseCompressionTable

public void advertiseCompressionTable(OutboundContext outboundContext,
                                      CompressionTable<ActorRef> table)

Description copied from class: InboundCompression

Must be implemented by extending classes in order to send a ControlMessage of appropriate type to the remote system in order to advertise the compression table to it.

Specified by:

advertiseCompressionTable in class InboundCompression<ActorRef>

Parameters:

outboundContext - (undocumented)

table - (undocumented)