akka.cluster.pubsub

Class DistributedPubSubMediator.Internal$

java.lang.Object

akka.cluster.pubsub.DistributedPubSubMediator.Internal$

Enclosing class:

DistributedPubSubMediator

public static class DistributedPubSubMediator.Internal$
extends java.lang.Object

INTERNAL API

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	DistributedPubSubMediator.Internal$.Bucket
static interface	DistributedPubSubMediator.Internal$.ChildActorTerminationProtocol Messages used to encode protocol to make sure that we do not send Subscribe/Unsubscribe message to child (mediator -> topic, topic -> group) during a period of transition.
class	DistributedPubSubMediator.Internal$.Delta
class	DistributedPubSubMediator.Internal$.DeltaCount
class	DistributedPubSubMediator.Internal$.GossipTick
class	DistributedPubSubMediator.Internal$.Group
class	DistributedPubSubMediator.Internal$.MediatorRouterEnvelope
class	DistributedPubSubMediator.Internal$.NewSubscriberArrived Sent from child to parent actor as response to DistributedPubSubMediator.Internal$.TerminateRequest in case DistributedPubSubMediator.Subscribe message arrived after sending DistributedPubSubMediator.Internal$.NoMoreSubscribers but before receiving DistributedPubSubMediator.Internal$.TerminateRequest.
class	DistributedPubSubMediator.Internal$.NoMoreSubscribers Passivate-like message sent from child to parent, used to signal that sender has no subscribers and no child actors.
class	DistributedPubSubMediator.Internal$.Prune
class	DistributedPubSubMediator.Internal$.RegisterTopic
class	DistributedPubSubMediator.Internal$.SendToOneSubscriber
class	DistributedPubSubMediator.Internal$.Status
class	DistributedPubSubMediator.Internal$.Subscribed
class	DistributedPubSubMediator.Internal$.TerminateRequest Sent from parent to child actor to signalize that messages are being buffered.
class	DistributedPubSubMediator.Internal$.Topic
static interface	DistributedPubSubMediator.Internal$.TopicLike
class	DistributedPubSubMediator.Internal$.Unsubscribed
class	DistributedPubSubMediator.Internal$.ValueHolder

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
Internal$()

Method Summary

Modifier and Type	Method and Description
java.lang.String	encName(java.lang.String s)
java.lang.String	mkKey(ActorPath path)
java.lang.String	mkKey(ActorRef ref)
scala.Function1<java.lang.Object,java.lang.Object>	wrapIfNeeded() Mediator uses Router to send messages to multiple destinations, Router in general unwraps messages from RouterEnvelope and sends the contents to Routees.

Methods inherited from class java.lang.Object

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

Field Detail

MODULE$

public static final DistributedPubSubMediator.Internal$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

Internal$

public Internal$()

Method Detail

encName

public java.lang.String encName(java.lang.String s)

mkKey

public java.lang.String mkKey(ActorRef ref)

mkKey

public java.lang.String mkKey(ActorPath path)

wrapIfNeeded

public scala.Function1<java.lang.Object,java.lang.Object> wrapIfNeeded()

Mediator uses Router to send messages to multiple destinations, Router in general unwraps messages from RouterEnvelope and sends the contents to Routees.

Using mediator services should not have an undesired effect of unwrapping messages out of RouterEnvelope. For this reason user messages are wrapped in DistributedPubSubMediator.Internal$.MediatorRouterEnvelope which will be unwrapped by the Router leaving original user message.

Returns:

(undocumented)