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 Details

    • 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<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, String manifest, int n)
    • runNextActorRefAdvertisement

      void runNextActorRefAdvertisement()
      Triggers compression advertisement via control message.
    • runNextClassManifestAdvertisement

      void runNextClassManifestAdvertisement()
      Triggers compression advertisement via control message.