Questions tagged [akka.net]
A toolkit and runtime for building highly concurrent, distributed and fault tolerant event-driven applications on .NET & Mono.
669
questions
0
votes
1
answer
18
views
Akka.net readJournal plugin for inmem journal plugin
Which readJournal plugin should I use with inmem journal plugin?
let readJournal = mailbox.System.ReadJournalFor<????>(SqlReadJournal.Identifier)
I know for Akka, there is ...
0
votes
0
answers
44
views
Is there a framework for distributed job/workers in .net core
I'm working on project that require distributing worker services framework in .net core
description example:
I have a .netcore prime server web app mvc that has a millions of work item to done for ...
0
votes
1
answer
25
views
Akka.Net Stream Ordering (Stream Ordering Over the Network)
Does Akka.net Streams preserve input order of elements? If so, does this hold true when working with reactive streams over the network (when using stream refs)?
Current Version of Akka.Streams being ...
0
votes
0
answers
28
views
How to handle mutiple calls at OnReceive method in Actor class in AKKA.NET using C#
I have an C#.net core 3.1 console application. I have developed Actor model in my application using Akka.Net
How to handle multiple calls at OnReceive method (below example: Method_A() invoked ...
1
vote
1
answer
63
views
How to asynchronously await an Akka.Actor event?
I am using akka.NET. In most cases we use akka like this:
class ActorA : UntypedActor
{
public delegate void EventHandler(object arg1, object arg2, ...);
public static event EventHandler Event;...
1
vote
1
answer
28
views
How can I force Akka.net Postgres persistence to reconnect
I am having some issues with persistent actors which use the Postgres plugin where it seems the actors never manage to reconnect to the database after a database outage.
The persistent actors are ...
0
votes
0
answers
81
views
How to fix System.ArgumentNullException when deploying Remote actor on Local Host
I am new to Akka.Net and tried to follow a simple procedure from "Remotely Deploying Actors" tutorial on the getakka.net site.
I however get a System.ArgumentNullException which says 'Value ...
0
votes
1
answer
26
views
Trouble Connecting to Custom Akka.NET Transport
I am trying to implement a custom Akka.NET Transport. Currently I have the following:
Client program (based on https://getakka.net/articles/remoting/messaging.html):
using Akka.Actor;
using Akka....
0
votes
2
answers
95
views
How to merge events from 2 Event Sourcing systems
I need to merge events coming from 2 different event sourcing systems handled by Akka.Net Persistence module. The merge must sort events based on their timestamp, and I found the MergeSorted operator ...
0
votes
1
answer
26
views
What is the best way for exiting a loop inside an actor?
A rendering actor is drawing a large amount of shapes onto a bitmap. I'd like to stop this process from a supervisor actor
object. Neither Kill, nor Stop do the job as they wait for the message being ...
1
vote
1
answer
82
views
How to implement PersistenceQuery of ReadJournalFor in Akka.Net Hosting Model
I've worked through the documentation on Akka.Net PersistenceQuery here, but I'm struggling to figure out how I would hook up any of those queries inside an ASP.Net6 Blazor Server startup pipeline ...
0
votes
0
answers
28
views
List all snapshots of a certain Akka.Net actor in a Web UI
I need help trying to figure out Akka.Net for a Event-Source PoC that I am building.
Say I have an Order Entry system, in which the Orders are modelled as ReceivePersistentActor. I have figured out ...
0
votes
0
answers
52
views
Akka messages wait in mailbox even when no messages are currently being processed by the actor
I'm having an issue where every so often Akka messages are being held in an actor's mailbox for longer than necessary, sometimes for up to around 3 seconds.
This is only happening when I run the app (...
1
vote
1
answer
116
views
Guarantee message delivery over the websocket protocol
I'm pulling open positions data off an exchange API. Their websocket server is quite unstable and we often miss websocket updates. It's quite important to me to not miss anything. The problem is that ...
0
votes
1
answer
69
views
Akka.net Persistence Query -Events by Tag- stream order guarantee
I am working on building a solution with Akka.net that will allow for a persistence query that queries multiple tags. One of the ways i thought of doing this was to simply materialize 1 stream for ...
0
votes
0
answers
90
views
Low latency and consistent position websocket client subscription service, running a few instances
There is a hosted service which subscribes to FTX websocket positions. I want to have multiple instances running of that service at the same time (something like load balancing them). They should ...
0
votes
0
answers
50
views
How can i get active shards in actor cluster sharding?
Is that any way to get no of entity actors running and no of shards running in cluster sharding with java code?
I'm Using actor-cluster-sharding v 2.6.14
Inspecting Cluster Sharding State in Akka ...
0
votes
2
answers
241
views
Using Akka.net with Asp.net on a Modular Monolith architecture
Iwould like to implement a rest service using Akka and Asp.net.
Following the example here
I create my AkkaService containing the FooActor ref and a controller who transform the http request to a ...
0
votes
2
answers
152
views
Akka cluster slave can't join seeds
I'm trying to build a small AKka.NET Cluster Application but I'm having problems since I keep getting the following error:
[WARNING][7/14/2022 10:42:06 AM][Thread 0011][akka.tcp://accountsystem@...
0
votes
0
answers
83
views
How to define a custom dispatcher for entity actors in Akka Cluster Sharding
How can i define custom dispatcher for entity actors.
In Shard Region creation i passed .withDispatcher() along with props.create(), But it using default dispatcher for entity actors.
How can i ...
0
votes
0
answers
90
views
Two different type Entity actors in AKKA Cluster Sharding
How to create two different type actors in a single Akka Cluster.
ActorRef ShardRegion=ClusterSharding.get(ClusterSys).start("Test", Props.create(ShardActor.class), settings,new ...
0
votes
2
answers
242
views
How can we send a message from an actor system outside the Akka Cluster
I want to know how can we send a message to a particular actor in cluster without knowing the actual path..
For Example...
I have 5 nodes all have same actorsytem and formed a cluster.
Each node will ...
-1
votes
1
answer
114
views
Akka Cluster basic clarifications about creating actors dynamically
In Akka remote we crate actor by defining in actor system configuration,or programmatically saying the other actor system location.
We send messages to the actor by the references we created or we can ...
0
votes
1
answer
108
views
Akka.net restart actor system termination on node quarentined
We are developing a cluster with Akka.net v1.4.38 on we have seed nodes that communicate with a external system using Akka.IO.TCP, and multiple client nodes that receive and send messages to seed ...
0
votes
1
answer
185
views
How to create an actor in Akka cluster dynamically
How can i create an actor in akka cluster Sharding dynamically with Cluster Client which will pass message from out side the cluster with akka remoting.
0
votes
1
answer
36
views
Any blogs,articals or docs to learn AKKA Remote internals? [closed]
Any blogs,articals or docs to learn AKKA Remote internals,indepth working how actor created how all connected how messages shared?
Endpoint Reader,Writer,Endpoint Manager
Association handler,
...
0
votes
1
answer
159
views
How to use Cluster singlton or Cluster sharding in Akka-Cluster for million individual Actors?
I have a use case where a million individual actors will be created across the cluster.
The tasks will be received from outside cluster and i have to identify and send the task to assigned single ...
0
votes
1
answer
133
views
How to handle million individual actors with AKKA Cluster setup?
I have a use case which is million clients data processed by individual actor.And all the actors created on across multiple nodes and formed as a cluster.
When i receive a message i have to send it to ...
0
votes
0
answers
271
views
How to create child actors in Akka.NET with Dependency Injecton
I want to use akka for concurrent message processing. I am working with objects called Fixture. My design is to have a supervisor actor that gets all the messages and then routes them to another actor ...
2
votes
0
answers
204
views
AKKA.NET Problems when multiple child actors tell a message to their parent
I'm trying to create a gerarchy of actors like this:
public class Actor1 : UntypedActor
{
private int _numberOfChildActive;
protected override void OnReceive(object message)
...
0
votes
0
answers
360
views
Integrating OpenTelemetry into my .netCore (with akka.net) framework: ActivitySource or Tracer?
I'm completely new to OTel and tracing and have been learning a bit the past few days.
I've figured out, that Otel and .net have different names for the same things. ActivitySource in .Net is Tracer ...
0
votes
0
answers
37
views
How to make sure only "trusted" Actor Systems can communicate in Akka.NET?
I am trying to secure communication between Akka.NET Actor Systems with TLS and I could manage to make two Actor Systems communicate with each other while each use their own certificate.
In addition, ...
0
votes
2
answers
87
views
Akka.DependencyInjection doesn't throw error when can't resolve dependencies
I'm using the DI in the following way:
_actorSystem.ActorOf(
Supervise(PropsWithDI<MessagePublisherActor>()), MessagePublisher.ActorName);
private Props PropsWithDI<T>(params object[]...
1
vote
2
answers
65
views
Akka.NET cluster intermittent dead letters
We have our cluster running locally (for now) and everything seems to be configured correctly. Our prime calculation messages are distributed over our seednodes. However, we are intermittently losing ...
0
votes
1
answer
100
views
Handling a received not covered in become
I am using Akka.NET to develop a logistics simulation.
Having tried various patterns, it seems to me that FSM-type behaviour using become will substantially simplify development.
The system has a ...
0
votes
1
answer
117
views
Cannot add Actor in Cluster as Singleton Akka.NET
I have an interesting issue with AKKA.NET making 'SampleActor' to singleton in 'CustomCluster'. No exceptions or warnings are thrown.
During debugging on I am unable to get SampleActor initialized as ...
0
votes
1
answer
230
views
Akka.Streams.Kafka - can't load a consumer
I'm studying Akka.Streams.Kafka (see examples on the page https://github.com/akkadotnet/Akka.Streams.Kafka) and I've a problem with creating a Consumer configuration
public class TestService : ...
0
votes
1
answer
106
views
Akka.Net - how to properly analyse occasionally and remedy some rogue messages taking too long to be acted upon
We have code sending 2 duplicate tell messages ( a integer differences) one after directly the other no processing in between. These normally processed in a few milli seconds, but we are hitting ...
0
votes
1
answer
196
views
Akka.Net not executing await continuation in PostStop
My actor interacts with a non-Akka thing that has an async disposal. This disposal can take 5-10 seconds. I do this in PostStop() like so:
protected override void PostStop()
{
async Task ...
0
votes
1
answer
127
views
Exception of Shard 0 already allocated
we are getting an exception after every re-start of service 3 POD [3 shard]inside AWS cluster, we are using Nuget Akka1.4.16 for our .net service using AWS Document DB, attaching the code for your ...
0
votes
1
answer
85
views
Docker image with a single file Akka.net app and the Petabridge command line?
I'm writing an Akka.net hosted application that I intend to host in docker. I want to minimize the footprint so I'm making this a single file executable. But I also want to include the Petabridge ...
0
votes
2
answers
121
views
Nested, Remote, Round-Robin Pool in Akka.NET
I have started working with Akka.NET and was able an application with did self deployment on a remote system with multiple instances (deployment using a round-robin pool router with 5 instances). ...
1
vote
0
answers
187
views
Akka.NET Cluster Sharding - Control shard rebalancing to stop the entity only when it reaches a specific state
In Akka.NET cluster sharding I have an entity that can spawn between two behavior states (Idle, Processing). When the entity is in the processing state I don't want the rebalancing mechanism to stop ...
4
votes
2
answers
636
views
Akka.net - How to wait child actor to process all pending messages prior to stop
We have a clustered sharded actor named A and it has multiple child actors created with the child per entity pattern as shown below.
When we Tell 100 messages from actor B to D and actor D takes say, ...
1
vote
1
answer
207
views
SerializationException while sending Record between remote actors using Akka.FSharp
I am trying to send a Record message between remote actors in Akka.FSharp, but I am getting the following serialization exception.
[WARNING][27-11-2021 16:37:25][Thread 0025][akka.tcp://Server@...
1
vote
1
answer
157
views
Akka.NET .NET Framework - Akka.Remote config always errors on start (then works fine)
I am trying to configure a remote Actor, but I am having some trouble.
Every time I start up my console app, I am greeted with an error:
(I cannot catch it for some reason, but here is all the ...
1
vote
0
answers
66
views
Akka.NET FSM - Testing OnTermination transition
Let's say I would like to test OnTermination logic in my FSM.
What would be the proper way to do that? Em I doing it right in my second test?
Why is my first test failing, even though entering ...
0
votes
1
answer
59
views
Best practice for cleaning up EntityStoppedManifest journal entries for permanently terminated actors?
In our actor system, using sharding and persistence, the concrete instances of one of our ReceivePersistentActor implementations are not re-used once they are terminated (passivated), as they ...
0
votes
1
answer
160
views
Akka.Net in-memory persistence calls `Recover` after app restart
I'am trying to test persistence actor, but behavior is wierd.
My tested actor:
public class PredictionManager : ReceivePersistentActor
{
public override string PersistenceId => _persistanceId;
...
1
vote
0
answers
60
views
Akka.net 1.4 dead letter handler EventStream.Subscribe
Just because it cost me a few hours, I'd like to share the following insight, may it be interesting for someone: If we want to handle dead letters by ourselves, the akka.net documentation (https://...