I am trying to use val mediator = DistributedPubSub(context.system).mediator ClusterClientReceptionist(context.system).registerService(self)
The code is similar to the one hosted @ https://www.lightbend.com/activator/template/akka-distributed-workers When I run the code, I get this exception and don't know how to fix the issue. [ERROR] [03/02/2016 20:34:30.775] [xxx-akka.remote.default-remote-dispatcher-5] [akka.remote.Remoting] Failed to write message to the transport akka.remote.EndpointException: Failed to write message to the transport Caused by: java.lang.IllegalArgumentException: Can't serialize object of type class akka.cluster.pubsub.DistributedPubSubMediator$Internal$Status at akka.contrib.pattern.protobuf.DistributedPubSubMessageSerializer.toBinary(DistributedPubSubMessageSerializer.scala:56) Adding this configuration does not help either serializers { akka-pubsub = "akka.contrib.pattern.protobuf.DistributedPubSubMessageSerializer" akka-pubsub-cluster = "akka.cluster.pubsub.protobuf.DistributedPubSubMessageSerializer" } serialization-bindings { "akka.contrib.pattern.DistributedPubSubMessage" = akka-pubsub "akka.cluster.pubsub.DistributedPubSubMediator" = akka-pubsub-cluster } -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to [email protected]. To post to this group, send email to [email protected]. Visit this group at https://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
