The serialized messages you see are sent between local actors and don't need efficient serialization. The only reason they are serialized is that you run with: akka.actor.serialize-messages = on
That is only intended for testing. /Patrik On Tue, Mar 18, 2014 at 4:01 AM, Daniel Wang <[email protected]> wrote: > 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]<http://[email protected]:25551/system/cluster/core/daemon%5BClusterCoreDaemon%5D>>>>> > 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]<http://[email protected]:25551/system/cluster/core/daemon%5BClusterCoreDaemon%5D>>>>> > 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. > -- Patrik Nordwall Typesafe <http://typesafe.com/> - Reactive apps on the JVM Twitter: @patriknw -- >>>>>>>>>> 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.
