Package akka.remote.artery.compress

Interface InboundCompressions

All Known Implementing Classes:

InboundCompressionsImpl, NoInboundCompressions$

public interface InboundCompressions

Triggers compression advertisement via control message.

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()
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

close

void close(long originUid)

Remove compression and cancel advertisement scheduling for a specific origin

Parameters:

originUid - (undocumented)

confirmActorRefCompressionAdvertisement

void confirmActorRefCompressionAdvertisement(long originUid,
                                             byte tableVersion)

confirmClassManifestCompressionAdvertisement

void confirmClassManifestCompressionAdvertisement(long originUid,
                                                  byte tableVersion)

currentOriginUids

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

decompressActorRef

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

decompressClassManifest

OptionVal<java.lang.String> 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.