Package org.apache.pekko.cluster.pubsub

Class DistributedPubSubMediator.Internal$

java.lang.Object

org.apache.pekko.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	Description
class	DistributedPubSubMediator.Internal$.Bucket
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$.Delta$
class	DistributedPubSubMediator.Internal$.DeltaCount
class	DistributedPubSubMediator.Internal$.DeltaCount$
class	DistributedPubSubMediator.Internal$.GossipTick
class	DistributedPubSubMediator.Internal$.GossipTick$
class	DistributedPubSubMediator.Internal$.Group
class	DistributedPubSubMediator.Internal$.MediatorRouterEnvelope
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$.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$.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$.Prune$
class	DistributedPubSubMediator.Internal$.RegisterTopic
class	DistributedPubSubMediator.Internal$.RegisterTopic$
class	DistributedPubSubMediator.Internal$.SendToOneSubscriber
class	DistributedPubSubMediator.Internal$.SendToOneSubscriber$
class	DistributedPubSubMediator.Internal$.Status
class	DistributedPubSubMediator.Internal$.Status$
class	DistributedPubSubMediator.Internal$.Subscribed
class	DistributedPubSubMediator.Internal$.Subscribed$
class	DistributedPubSubMediator.Internal$.TerminateRequest	Sent from parent to child actor to signalize that messages are being buffered.
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$.Unsubscribed$
class	DistributedPubSubMediator.Internal$.ValueHolder
class	DistributedPubSubMediator.Internal$.ValueHolder$

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
Internal$()

Method Summary

Modifier and Type	Method	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 pekko.routing.Router to send messages to multiple destinations, Router in general unwraps messages from pekko.routing.RouterEnvelope and sends the contents to pekko.routing.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 pekko.routing.Router to send messages to multiple destinations, Router in general unwraps messages from pekko.routing.RouterEnvelope and sends the contents to pekko.routing.Routees.

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