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
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
close(long originUid)
Remove compression and cancel advertisement scheduling for a specific originvoid
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)
-
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.
-
-