akka.remote.artery.compress

Interface InboundCompressions

All Known Implementing Classes:

InboundCompressionsImpl, NoInboundCompressions$

public interface InboundCompressions

INTERNAL API Decompress and cause compression advertisements.

One per inbound message stream thus must demux by originUid to use the right tables.

Method Summary

Modifier and Type	Method and Description
void	close(long originUid) Remove compression and cancel advertisement scheduling for a specific origin
void	confirmActorRefCompressionAdvertisement(long originUid, byte tableVersion)
void	confirmClassManifestCompressionAdvertisement(long originUid, byte tableVersion)
OptionVal<ActorRef>	decompressActorRef(long originUid, byte tableVersion, int idx)
OptionVal<java.lang.String>	decompressClassManifest(long originUid, byte tableVersion, int idx)
void	hitActorRef(long originUid, Address remote, ActorRef ref, int n)
void	hitClassManifest(long originUid, Address remote, java.lang.String manifest, int n)
void	runNextActorRefAdvertisement() Triggers compression advertisement via control message.
void	runNextClassManifestAdvertisement() Triggers compression advertisement via control message.

Method Detail

hitActorRef

void hitActorRef(long originUid,
                 Address remote,
                 ActorRef ref,
                 int n)

decompressActorRef

OptionVal<ActorRef> decompressActorRef(long originUid,
                                       byte tableVersion,
                                       int idx)

confirmActorRefCompressionAdvertisement

void confirmActorRefCompressionAdvertisement(long originUid,
                                             byte tableVersion)

runNextActorRefAdvertisement

void runNextActorRefAdvertisement()

Triggers compression advertisement via control message.

hitClassManifest

void hitClassManifest(long originUid,
                      Address remote,
                      java.lang.String manifest,
                      int n)

decompressClassManifest

OptionVal<java.lang.String> decompressClassManifest(long originUid,
                                                    byte tableVersion,
                                                    int idx)

confirmClassManifestCompressionAdvertisement

void confirmClassManifestCompressionAdvertisement(long originUid,
                                                  byte tableVersion)

runNextClassManifestAdvertisement

void runNextClassManifestAdvertisement()

Triggers compression advertisement via control message.

close

void close(long originUid)

Remove compression and cancel advertisement scheduling for a specific origin

Parameters:

originUid - (undocumented)