akka.contrib.pattern
Class DistributedPubSubMediator.Internal$

java.lang.Object
  akka.contrib.pattern.DistributedPubSubMediator.Internal$

Enclosing class:

DistributedPubSubMediator

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

INTERNAL API

Nested Class Summary

class	DistributedPubSubMediator.Internal$.Bucket
class	DistributedPubSubMediator.Internal$.Delta
class	DistributedPubSubMediator.Internal$.GossipTick
class	DistributedPubSubMediator.Internal$.Group
class	DistributedPubSubMediator.Internal$.MediatorRouterEnvelope
class	DistributedPubSubMediator.Internal$.Prune
class	DistributedPubSubMediator.Internal$.RegisterTopic
class	DistributedPubSubMediator.Internal$.SendToOneSubscriber
class	DistributedPubSubMediator.Internal$.Status
class	DistributedPubSubMediator.Internal$.Subscribed
class	DistributedPubSubMediator.Internal$.Topic
static interface	DistributedPubSubMediator.Internal$.TopicLike
class	DistributedPubSubMediator.Internal$.Unsubscribed
class	DistributedPubSubMediator.Internal$.ValueHolder

Field Summary

static DistributedPubSubMediator.Internal$

MODULE$ Static reference to the singleton instance of this Scala object.

Constructor Summary

DistributedPubSubMediator.Internal$()

Method Summary

java.lang.String	encName(java.lang.String s)
scala.Option<java.lang.String>	roleOption(java.lang.String role)
scala.Function1<java.lang.Object,java.lang.Object>	wrapIfNeeded() Mediator uses Router to send messages to multiple destinations, Router in general unwraps messages from DistributedPubSubMediator.Internal$.MediatorRouterEnvelope 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

DistributedPubSubMediator.Internal$

public DistributedPubSubMediator.Internal$()

Method Detail

roleOption

public scala.Option<java.lang.String> roleOption(java.lang.String role)

encName

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

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 DistributedPubSubMediator.Internal$.MediatorRouterEnvelope and sends the contents to Routees.

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

Returns:

(undocumented)