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 Object

INTERNAL API

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
final 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.
final 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
final 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$
final class	DistributedPubSubMediator.Internal$.RegisterTopic
class	DistributedPubSubMediator.Internal$.RegisterTopic$
final class	DistributedPubSubMediator.Internal$.SendToOneSubscriber
class	DistributedPubSubMediator.Internal$.SendToOneSubscriber$
final class	DistributedPubSubMediator.Internal$.Status
class	DistributedPubSubMediator.Internal$.Status$
final 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
final class	DistributedPubSubMediator.Internal$.Unsubscribed
class	DistributedPubSubMediator.Internal$.Unsubscribed$
final class	DistributedPubSubMediator.Internal$.ValueHolder
class	DistributedPubSubMediator.Internal$.ValueHolder$

Field Summary

Fields

Modifier and Type	Field	Description
static final 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
String	encName(String s)
String	mkKey(ActorPath path)
String	mkKey(ActorRef ref)
scala.Function1<Object,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 Details

MODULE$

public static final DistributedPubSubMediator.Internal$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Details

Internal$

public Internal$()

Method Details

encName

public String encName(String s)

mkKey

public String mkKey(ActorRef ref)

mkKey

public String mkKey(ActorPath path)

wrapIfNeeded

public scala.Function1<Object,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.