I upped the logging levels, a little more info...it seems as though this is
happening when attempting to send messages through cluster sharding.
In the following log snippet, I see this "endpointWriter - received local
message RemoteMessage: [null]"
In this interaction, 172.17.0.27 is the "node" and 172.17.0.26...the
interaction is that the seed is sending a message to the node via cluster
sharding.
Other notes:
- I am using a Cluster Singleton here, all messages go to the cluster
singleton
- I am using Cluster Sharding, the Cluster Singleton forwards messages to
actors in the shard
Code snippet of the cluster setup:
val zoneRegion:ActorRef = ClusterSharding(system).start(
ZoneActor.shardName,
Some(ZoneActor.props),
ZoneActor.idExtractor,
ZoneActor.shardResolver)
system.actorOf(ClusterSingletonManager.props(
singletonProps = Props(classOf[ZoneManager]),
singletonName = "zoneManager",
terminationMessage = PoisonPill,
role = None),
name = "zoneManagerSingleton")
// Get access to the cluster singleton via the proxy, you must access it
through the proxy
val zoneManager:ActorRef = system.actorOf(ClusterSingletonProxy.props(
singletonPath = "/user/zoneManagerSingleton/zoneManager",
role = None),
name = "zoneManagerProxy")
Code snippet of how I send messages from the cluster singleton to the
shard, this code lives inside the cluster singleton itself:
ClusterSharding(context.system).shardRegion(ZoneActor.shardName) ! xxx
13:21:29.127UTC [test] DEBUG akka.contrib.pattern.ShardRegion
akka.tcp://[email protected]:2551/user/sharding/Zone - Request shard [-11]
home
13:21:29.128UTC [test] DEBUG akka.remote.EndpointWriter
akka.tcp://[email protected]:2551/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2FDenis%40172.17.0.26%3A2551-0/endpointWriter
- sending message RemoteMessage: [GetShardHome(-11)] to
[Actor[akka.tcp://[email protected]:2551/user/sharding/ZoneCoordinator/singleton/coordinator#-557815390]]<+[akka.tcp://[email protected]:2551/user/sharding/ZoneCoordinator/singleton/coordinator]
from [Actor[akka://Denis/user/sharding/Zone#-1740607218]]
13:21:29.128UTC [test] DEBUG a.s.Serialization(akka://Denis)
akka.serialization.Serialization(akka://Denis) - Using
serializer[akka.serialization.JavaSerializer] for message
[akka.contrib.pattern.ShardCoordinator$Internal$GetShardHome]
13:21:29.147UTC [test] DEBUG akka.remote.EndpointWriter
akka.tcp://[email protected]:2551/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2FDenis%40172.17.0.26%3A2551-0/endpointWriter
- received local message RemoteMessage: [null] to
[Actor[akka://Denis/user/sharding/Zone#-1740607218]]<+[akka://Denis/user/sharding/Zone]
from [Actor[akka.tcp://[email protected]:2551/temp/$W]()]
13:21:29.151UTC [test] ERROR akka.remote.EndpointWriter
akka.tcp://[email protected]:2551/system/endpointManager/reliableEndpointWriter-akka.tcp%3A%2F%2FDenis%40172.17.0.26%3A2551-0/endpointWriter
- AssociationError [akka.tcp://[email protected]:2551] ->
[akka.tcp://[email protected]:2551]: Error [Message is null] [
akka.actor.InvalidMessageException: Message is null
at akka.dispatch.Envelope$.apply(AbstractDispatcher.scala:27)
>
>
--
>>>>>>>>>> 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 http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
