GetMsg and ProcessMsg are two separate actors, which ProcessMsg is created by GetMsg
I initialize like this
container.Register<QueryDataStoreActorBase, QuerySqlDataStore>();
var system = ActorSystem.Create("ActorSystem");
system.AddDependencyResolver(new SimpleInjectorDependencyResolver(container, system));
container.RegisterSingleton(system);
Just calling
var resolver = new SimpleInjectorDependencyResolver(container, system); is enough
it registers itself with the system
the
system.AddDepedencyResolver is a public api exposed for the DI plugins to use. It should not be used directly. Although it is possible, if you know what you are doing.
Oh? thats odd.
A will receive 2 response from 2 B instances, that's what I was thinking of testing but I can't find a way to "mock" router using testkit
The tests work. So plugin integration for 1.0.8 looks good
If you upgrade, you should rebuild the plugin against the latest akka.net packages
It looks ok.
I gtg, got a meeting
also check the tests project of the plugin, for details on how to register dependencies
could be the readme is wrong
gl!
Hey guys, I have a cluster running with 6 nodes including 2 seeds (A and B), all started at the same time. According to the logs, the leader is trying to move seed node B to [Up] every 3 or 4 seconds. Node B appears as "Joining" to my monitoring node but never goes to the Up status. No dead letters, no exceptions. I've restarted the whole cluster twice but the situation persists. Any ideas ?
interesting, it's always the last node I start that the leader is trying to move to Up but remains 'Joining' to the other nodes
persistence {
journal {
redis {
# qualified type name of the Redis persistence journal actor
class = "Akka.Persistence.Redis.Journal.RedisJournal, Akka.Persistence.Redis"
# connection string, as described here: https://github.com/StackExchange/StackExchange.Redis/blob/master/Docs/Configuration.md#basic-configuration-strings
configuration-string = "localhost:6380,ssl=false"
# dispatcher used to drive journal actor
plugin-dispatcher = "akka.actor.default-dispatcher"
#Redis journals key prefixes. Leave it for default or change it to appropriate value. WARNING: don't change it on production instances.
key-prefix = "akka:persistence:journal"
}
}
snapshot-store {
redis {
# qualified type name of the Redis persistence snapshot storage actor
class = "Akka.Persistence.Redis.Snapshot.RedisSnapshotStore, Akka.Persistence.Redis"
# connection string, as described here: https://github.com/StackExchange/StackExchange.Redis/blob/master/Docs/Configuration.md#basic-configuration-strings
configuration-string = "localhost:6380,ssl=false"
# dispatcher used to drive snapshot storage actor
plugin-dispatcher = "akka.actor.default-dispatcher"
#Redis storage key prefixes. Leave it for default or change it to appropriate value. WARNING: don't change it on production instances.
key-prefix = "akka:persistence:snapshots"
}
}
}
if you want to use it as default
I was following this https://github.com/akkadotnet/Akka.Persistence.Redis - I guess it should say something there?