These are chat archives for akkadotnet/akka.net
If your using that. There is a DSL like syntax available. That allows you to define the actor type inline
Func<IUntypedActorContext, IActorRef> maker = (ctx) => ctx.ActorOf(Props.Create<Child>())
ctx.ActorOf( DSL HERE )
base.ActorOfAsTestActorRef<CustomTestProbe> (supervisor: s.GetArgument<IActorContext>(1).Self, name: s.GetArgument<string>(0));
By the way for that code :
var parent = Sys.ActorOf(Props.Create(() => new Act(actor)));
What is Act ? It is not documented any where?
03.02.2018 02:51:28.308 ERROR [Akka.Cluster.Discovery.Consul.ConsulDiscoveryService, 944] - Couldn't retrieve collection of nodes from external service. Is current node unreachable? Shutting down... Consul.ConsulRequestException: Unexpected response, status code InternalServerError: rpc error making call: EOF at Consul.GetRequest`1.<Execute>d__5.MoveNext() --- End of stack trace from previous location where exception was thrown --- at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw() at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task) at Akka.Cluster.Discovery.Consul.ConsulDiscoveryService.<GetNodesAsync>d__9.MoveNext() --- End of stack trace from previous location where exception was thrown --- at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw() at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task) at Akka.Cluster.Discovery.DiscoveryService.<ReconcileClusterStateAsync>d__19.MoveNext()
replay-dispatcherseems so helpless right now.
Hey guys, what would be the best way to get all previous messages from a persisted actor without storing a list of all events in the actor as well. I am trying to make a pub/sub, but I would like the sub to retrieve all previous events as well (using a bool). Is it possible? Or should the sub use the PersistenceQuery instead, I am afraid I could miss messages, or get duplicates. Missing messages because getting all persisted events, read them and subscribe to actual events, with possible misses. And subscribing, and keeping events in a list before using PersistentQuery, ideally I would like somthing like the recovery method, but redirecting to the subscriber.
I hope I make some sense.