Package akka.remote.artery.compress
Class InboundCompressionsImpl
- java.lang.Object
-
- akka.remote.artery.compress.InboundCompressionsImpl
-
- All Implemented Interfaces:
InboundCompressions
public final class InboundCompressionsImpl extends java.lang.Object implements InboundCompressions
Send compression table advertisement over control stream. Should be called from Decoder.
-
-
Constructor Summary
Constructors Constructor Description InboundCompressionsImpl(ActorSystem system, InboundContext inboundContext, ArterySettings.Compression settings, EventSink eventSink)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static EventSink
$lessinit$greater$default$4()
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()
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 address, ActorRef ref, int n)
void
hitClassManifest(long originUid, Address address, java.lang.String manifest, int n)
void
runNextActorRefAdvertisement()
Send compression table advertisement over control stream.void
runNextClassManifestAdvertisement()
Send compression table advertisement over control stream.
-
-
-
Constructor Detail
-
InboundCompressionsImpl
public InboundCompressionsImpl(ActorSystem system, InboundContext inboundContext, ArterySettings.Compression settings, EventSink eventSink)
-
-
Method Detail
-
$lessinit$greater$default$4
public static EventSink $lessinit$greater$default$4()
-
decompressActorRef
public OptionVal<ActorRef> decompressActorRef(long originUid, byte tableVersion, int idx)
- Specified by:
decompressActorRef
in interfaceInboundCompressions
-
hitActorRef
public void hitActorRef(long originUid, Address address, ActorRef ref, int n)
- Specified by:
hitActorRef
in interfaceInboundCompressions
-
confirmActorRefCompressionAdvertisement
public void confirmActorRefCompressionAdvertisement(long originUid, byte tableVersion)
- Specified by:
confirmActorRefCompressionAdvertisement
in interfaceInboundCompressions
-
runNextActorRefAdvertisement
public void runNextActorRefAdvertisement()
Send compression table advertisement over control stream. Should be called from Decoder.- Specified by:
runNextActorRefAdvertisement
in interfaceInboundCompressions
-
decompressClassManifest
public OptionVal<java.lang.String> decompressClassManifest(long originUid, byte tableVersion, int idx)
- Specified by:
decompressClassManifest
in interfaceInboundCompressions
-
hitClassManifest
public void hitClassManifest(long originUid, Address address, java.lang.String manifest, int n)
- Specified by:
hitClassManifest
in interfaceInboundCompressions
-
confirmClassManifestCompressionAdvertisement
public void confirmClassManifestCompressionAdvertisement(long originUid, byte tableVersion)
- Specified by:
confirmClassManifestCompressionAdvertisement
in interfaceInboundCompressions
-
runNextClassManifestAdvertisement
public void runNextClassManifestAdvertisement()
Send compression table advertisement over control stream. Should be called from Decoder.- Specified by:
runNextClassManifestAdvertisement
in interfaceInboundCompressions
-
currentOriginUids
public scala.collection.immutable.Set<java.lang.Object> currentOriginUids()
- Specified by:
currentOriginUids
in interfaceInboundCompressions
-
close
public void close(long originUid)
Description copied from interface:InboundCompressions
Remove compression and cancel advertisement scheduling for a specific origin- Specified by:
close
in interfaceInboundCompressions
- Parameters:
originUid
- (undocumented)
-
-