Class DistributedPubSubMediator.Internal$

  • Enclosing class:

    public static class DistributedPubSubMediator.Internal$
    extends java.lang.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.