public final class InboundActorRefCompression extends InboundCompression<ActorRef>
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).
InboundCompression.State<T>, InboundCompression.State$
Constructor and Description |
---|
InboundActorRefCompression(LoggingAdapter log,
ArterySettings.Compression settings,
long originUid,
InboundContext inboundContext,
TopHeavyHitters<ActorRef> heavyHitters) |
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
|
confirmAdvertisement, decompressInternal, heavyHitters, increment, log, runNextTableAdvertisement, settings, toString
public InboundActorRefCompression(LoggingAdapter log, ArterySettings.Compression settings, long originUid, InboundContext inboundContext, TopHeavyHitters<ActorRef> heavyHitters)
public OptionVal<ActorRef> decompress(byte tableVersion, int idx)
InboundCompression
decompress
in class InboundCompression<ActorRef>
public void advertiseCompressionTable(OutboundContext outboundContext, CompressionTable<ActorRef> table)
InboundCompression
ControlMessage
of appropriate type to the remote system in order to advertise the compression table to it.advertiseCompressionTable
in class InboundCompression<ActorRef>
outboundContext
- (undocumented)table
- (undocumented)