Package akka.remote.artery.compress

Interface InboundCompressions

All Known Implementing Classes:

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	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)
scala.collection.immutable.Set<java.lang.Object>	currentOriginUids()
<any>	decompressActorRef(long originUid, byte tableVersion, int idx)
<any>	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

close

void close(long originUid)

Remove compression and cancel advertisement scheduling for a specific origin

confirmActorRefCompressionAdvertisement

void confirmActorRefCompressionAdvertisement(long originUid,
                                             byte tableVersion)

confirmClassManifestCompressionAdvertisement

void confirmClassManifestCompressionAdvertisement(long originUid,
                                                  byte tableVersion)

currentOriginUids

scala.collection.immutable.Set<java.lang.Object> currentOriginUids()

decompressActorRef

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

decompressClassManifest

<any> decompressClassManifest(long originUid,
                              byte tableVersion,
                              int idx)

hitActorRef

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

hitClassManifest

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

runNextActorRefAdvertisement

void runNextActorRefAdvertisement()

Triggers compression advertisement via control message.

runNextClassManifestAdvertisement

void runNextClassManifestAdvertisement()

Triggers compression advertisement via control message.