Сериализируем сообщения из Akka.NET Cluster Sharding в Akka.Persistence.MongoDB #1

ClusterShardingPersistenseConfig.cs

    internal class ClusterShardingPersistenseConfig
    {
        public static void Initialize(ActorSystem system)
        {
            MongoDbPersistence.Get(system);
            var serializer = new ClusterShardingMongoSerializer(system as ExtendedActorSystem);
            BsonClassMap.RegisterClassMap<JournalEntry>(e => {
                e.AutoMap();
                e.MapField(a => a.Payload).SetSerializer(serializer);
            });
        }
    }