hi, when I start up my akka cluster, I configure found these java serializer related log entries:
DEBUG akka.serialization.Serialization(akka://coinex)[Serialization(akka://coinex)] >>>> Using serializer[akka.serialization.JavaSerializer] for message [akka.cluster.InternalClusterAction$ReapUnreachableTick$] DEBUG akka.serialization.Serialization(akka://coinex)[Serialization(akka://coinex)] >>>> Using serializer[akka.serialization.JavaSerializer] for message [akka.cluster.InternalClusterAction$GossipTick$] DEBUG akka.serialization.Serialization(akka://coinex)[Serialization(akka://coinex)] >>>> Using serializer[akka.serialization.JavaSerializer] for message [akka.cluster.InternalClusterAction$LeaderActionsTick$] DEBUG akka.serialization.Serialization(akka://coinex)[RegisterConversionHelpers$] >>>> Registering Scala Conversions. DEBUG akka.serialization.Serialization(akka://coinex)[RegisterConversionHelpers$] >>>> Deserializers for Scala Conversions registering DEBUG akka.serialization.Serialization(akka://coinex)[RegisterConversionHelpers$] >>>> Serializers for Scala Conversions registering DEBUG akka.serialization.Serialization(akka://coinex)[RegisterConversionHelpers$] >>>> Setting up OptionSerializer DEBUG akka.serialization.Serialization(akka://coinex)[RegisterConversionHelpers$] >>>> Setting up ScalaCollectionSerializer DEBUG akka.serialization.Serialization(akka://coinex)[RegisterConversionHelpers$] >>>> Setting up ScalaRegexSerializers DEBUG akka.serialization.Serialization(akka://coinex)[RegisterConversionHelpers$] >>>> Hooking up scala.util.matching.Regex serializer DEBUG akka.serialization.Serialization(akka://coinex)[RegisterConversionHelpers$] >>>> Reached base registration method on MongoConversionHelper. DEBUG akka.serialization.Serialization(akka://coinex)[Serialization(akka://coinex)] >>>> Using serializer[akka.serialization.JavaSerializer] for message [akka.persistence.SnapshotProtocol$LoadSnapshotResult] DEBUG akka.serialization.Serialization(akka://coinex)[Serialization(akka://coinex)] >>>> Using serializer[akka.serialization.JavaSerializer] for message [akka.persistence.JournalProtocol$ReplayMessages] DEBUG akka.serialization.Serialization(akka://coinex)[Serialization(akka://coinex)] >>>> Using serializer[akka.serialization.JavaSerializer] for message [akka.remote.RemoteWatcher$HeartbeatTick$] DEBUG akka.serialization.Serialization(akka://coinex)[Serialization(akka://coinex)] >>>> Using serializer[akka.serialization.JavaSerializer] for message [akka.remote.RemoteWatcher$ReapUnreachableTick$] DEBUG akka.serialization.Serialization(akka://coinex)[Serialization(akka://coinex)] >>>> Using serializer[akka.serialization.JavaSerializer] for message [akka.cluster.ClusterHeartbeatSender$HeartbeatTick$] DEBUG akka.serialization.Serialization(akka://coinex)[Serialization(akka://coinex)] >>>> Using serializer[akka.serialization.JavaSerializer] for message [akka.contrib.pattern.DistributedPubSubMediator$Internal$GossipTick$] DEBUG akka.serialization.Serialization(akka://coinex)[Serialization(akka://coinex)] >>>> Using serializer[akka.serialization.JavaSerializer] for message [akka.persistence.JournalProtocol$ReplayMessagesSuccess$] DEBUG akka.serialization.Serialization(akka://coinex)[Serialization(akka://coinex)] >>>> Using serializer[akka.serialization.JavaSerializer] for message [akka.persistence.Update] DEBUG akka.serialization.Serialization(akka://coinex)[Serialization(akka://coinex)] >>>> Using serializer[akka.serialization.JavaSerializer] for message [akka.cluster.InternalClusterAction$MetricsTick$] DEBUG akka.serialization.Serialization(akka://coinex)[Serialization(akka://coinex)] >>>> Using serializer[akka.serialization.JavaSerializer] for message [akka.cluster.InternalClusterAction$PublishEvent] DEBUG akka.serialization.Serialization(akka://coinex)[Serialization(akka://coinex)] >>>> Using serializer[akka.serialization.JavaSerializer] for message [akka.cluster.ClusterEvent$ClusterMetricsChanged] DEBUG Remoting[Remoting] >>>> Associated [akka.tcp://[email protected]:25551] <- [akka.tcp://[email protected]:49368] DEBUG akka.serialization.Serialization(akka://coinex)[Serialization(akka://coinex)] >>>> Using serializer[akka.cluster.protobuf.ClusterMessageSerializer] for message [akka.cluster.InternalClusterAction$InitJoin$] DEBUG akka.serialization.Serialization(akka://coinex)[Serialization(akka://coinex)] >>>> Using serializer[akka.cluster.protobuf.ClusterMessageSerializer] for message [akka.cluster.InternalClusterAction$InitJoinAck] DEBUG akka.serialization.Serialization(akka://coinex)[Serialization(akka://coinex)] >>>> Using serializer[akka.cluster.protobuf.ClusterMessageSerializer] for message [akka.cluster.InternalClusterAction$Join] INFO Cluster(akka://coinex)[Cluster(akka://coinex)] >>>> Cluster Node [akka.tcp://[email protected]:25551] - Node [akka.tcp://[email protected]:49368] is JOINING, roles [test_processor] DEBUG akka.serialization.Serialization(akka://coinex)[Serialization(akka://coinex)] >>>> Using serializer[akka.cluster.protobuf.ClusterMessageSerializer] for message [akka.cluster.InternalClusterAction$Welcome] DEBUG akka.serialization.Serialization(akka://coinex)[Serialization(akka://coinex)] >>>> Using serializer[akka.cluster.protobuf.ClusterMessageSerializer] for message [akka.cluster.GossipEnvelope] DEBUG akka.tcp://[email protected]:25551/system/cluster/core/daemon[ClusterCoreDaemon] >>>> Cluster Node [akka.tcp://[email protected]:25551] - Receiving gossip from [UniqueAddress(akka.tcp://[email protected]:49368,411125130)] DEBUG akka.tcp://[email protected]:25551/system/cluster/core/daemon[ClusterCoreDaemon] >>>> Cluster Node [akka.tcp://[email protected]:25551] - Receiving gossip from [UniqueAddress(akka.tcp://[email protected]:49368,411125130)] DEBUG akka.serialization.Serialization(akka://coinex)[Serialization(akka://coinex)] >>>> Using serializer[akka.serialization.JavaSerializer] for message [akka.cluster.ClusterEvent$ReachabilityChanged] DEBUG akka.serialization.Serialization(akka://coinex)[Serialization(akka://coinex)] >>>> Using serializer[akka.cluster.protobuf.ClusterMessageSerializer] for message [akka.cluster.GossipStatus] DEBUG akka.serialization.Serialization(akka://coinex)[Serialization(akka://coinex)] >>>> Using serializer[akka.serialization.JavaSerializer] for message [akka.contrib.pattern.DistributedPubSubMediator$Internal$Prune$] What else do I have to do in order to change them to some better serializers, I've done: akka { actor { serializers { bytes = "akka.serialization.ByteArraySerializer" proto = "akka.remote.serialization.ProtobufSerializer" akka-containers = "akka.remote.serialization.MessageContainerSerializer" daemon-create = "akka.remote.serialization.DaemonMsgCreateSerializer" akka-cluster = "akka.cluster.protobuf.ClusterMessageSerializer" akka-pubsub = "akka.contrib.pattern.protobuf.DistributedPubSubMessageSerializer" akka-persistence-snapshot = "akka.persistence.serialization.SnapshotSerializer" akka-persistence-message = "akka.persistence.serialization.MessageSerializer" } serialization-bindings { "[B" = bytes "akka.event.Logging$LogEvent" = bytes "com.google.protobuf.GeneratedMessage" = proto "com.google.protobuf.Message" = proto "akka.actor.ActorSelectionMessage" = akka-containers "akka.remote.DaemonMsgCreate" = daemon-create "akka.cluster.ClusterMessage" = akka-cluster "akka.contrib.pattern.DistributedPubSubMessage" = akka-pubsub "akka.persistence.serialization.Snapshot" = akka-persistence-snapshot "akka.persistence.serialization.Message" = akka-persistence-message }} -- >>>>>>>>>> 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.
