akka.remote.artery.compress

Class NoInboundCompressions$

java.lang.Object

akka.remote.artery.compress.NoInboundCompressions$

All Implemented Interfaces:

InboundCompressions, java.io.Serializable, scala.Equals, scala.Product

public class NoInboundCompressions$
extends java.lang.Object
implements InboundCompressions, scala.Product, scala.Serializable

INTERNAL API

Literarily, no compression!

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static NoInboundCompressions$	MODULE$ Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor and Description
NoInboundCompressions$()

Method Summary

Modifier and Type	Method and 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)
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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface scala.Product

$init$, productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Field Detail

MODULE$

public static final NoInboundCompressions$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

NoInboundCompressions$

public NoInboundCompressions$()

Method Detail

hitActorRef

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

Specified by:

hitActorRef in interface InboundCompressions

decompressActorRef

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

Specified by:

decompressActorRef in interface InboundCompressions

confirmActorRefCompressionAdvertisement

public void confirmActorRefCompressionAdvertisement(long originUid,
                                                    byte tableVersion)

Specified by:

confirmActorRefCompressionAdvertisement in interface InboundCompressions

runNextActorRefAdvertisement

public void runNextActorRefAdvertisement()

Description copied from interface: InboundCompressions

Triggers compression advertisement via control message.

Specified by:

runNextActorRefAdvertisement in interface InboundCompressions

hitClassManifest

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

Specified by:

hitClassManifest in interface InboundCompressions

decompressClassManifest

public OptionVal<java.lang.String> decompressClassManifest(long originUid,
                                                           byte tableVersion,
                                                           int idx)

Specified by:

decompressClassManifest in interface InboundCompressions

confirmClassManifestCompressionAdvertisement

public void confirmClassManifestCompressionAdvertisement(long originUid,
                                                         byte tableVersion)

Specified by:

confirmClassManifestCompressionAdvertisement in interface InboundCompressions

runNextClassManifestAdvertisement

public void runNextClassManifestAdvertisement()

Description copied from interface: InboundCompressions

Triggers compression advertisement via control message.

Specified by:

runNextClassManifestAdvertisement in interface InboundCompressions

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 interface InboundCompressions

Parameters:

originUid - (undocumented)