Stack Overflow
Stack Overflow

Questions tagged [akka.net-persistence]

44 questions
7
votes
1 answer

Akka .NET Connection Pool Timeout Issues

We are creating a new system using Akka.NET and have a basic cluster setup with sharding and persistence. We've used the official documentation as well as some Petabridge blog posts to get sharding working correctly. However, we've hit a problem…
Aaron
  • 188
  • 1
  • 7
4
votes
1 answer

Akka.NET with persistence dropping messages when CPU in under high pressure?

I make some performance testing of my PoC. What I saw is my actor is not receiving all messages that are sent to him and the performance is very low. I sent around 150k messages to my app, and it causes a peak on my processor to reach 100%…
TjDillashaw
  • 787
  • 1
  • 12
  • 29
3
votes
2 answers

How can I ensure that mailbox messages will not be lost if the actors process is restarted - Akka.NET?

I have readed the online documentation of the Akka.NET. I see that the Persistence Plugin can storage the actor's state using Event Source pattern. But I did not find anything specific about the messages in mailbox. When one process die or restart,…
Gean Ribeiro
  • 1,025
  • 2
  • 10
  • 23
3
votes
1 answer

What is the order of Akka.Persistence recovery?

I've read the Akka.Persistence intro at the Petabridge blog, and I find this part of the code a little confusing: Recover(str => _msgs.Add(str)); // from the journal Recover(offer => { var messages =…
Gigi
  • 28,163
  • 29
  • 106
  • 188
2
votes
0 answers

Akka.net journal reader missing events

In our application we are using Akka.net, with event sourcing. The persistent actors save their events in an SQL Server database. We also have view actors, which subscribe to these events, using a journal reader/persistence query, to create…
George
  • 315
  • 3
  • 15
2
votes
1 answer

Akka.net persistence actor recovery failed with message change with new properties

Used persistence actor to persist message into SQL Server database. Initial message format is as in below. System run with this format few times and many of those messages were persisted. Currently I changed message format to include few attributes…
Amal Shalika
  • 1,077
  • 1
  • 13
  • 22
2
votes
1 answer

how to set connection string for akka.net persistence actor from C# code behind

I have used persistence actor which is configured to sql server plugin. Here is below my hocon configurations. Here data source connection string is set to my localhost. Could it be possible to set this connection string from C# code behind just…
Amal Shalika
  • 1,077
  • 1
  • 13
  • 22
2
votes
1 answer

System.Format exception when consuming Akka.Persistence configuration

I am struggling to troubleshoot a System.Format exception that results from parsing my Akka.Net config file. I know that the exception stems from the persistence block of the configuration: persistence{ journal { plugin =…
Scott Nimrod
  • 11,206
  • 11
  • 54
  • 118
1
vote
1 answer

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 stopped after 1 minute of inactivity so I am getting…
Jonas Røineslien
  • 705
  • 8
  • 18
1
vote
1 answer

Akka.net persistence delete messages from a certain sequence number

Is there a way to delete messages after a certain sequence number in Akka.net? I know that DeleteMessages(seqNumber) deletes all messages before a certain sequence number, is there a way to delete after a seqNumber? The main goal would be to revert…
Tim Trewartha
  • 364
  • 3
  • 10
1
vote
1 answer

Akka.Net SQL server persistence configuration doesn't seem to load

I'm trying to upgrade an existing (demo) project from Akka.Net 1.0.8 to something more recent (1.3.2 or whatever). I'm stuck on getting the SQL server persistence to load. I've taken the following steps: Created a blank project, and included the…
H. Lowette
  • 314
  • 1
  • 9
1
vote
1 answer

Persistence failure when replaying events... System.NotSupportedException: Generic IDictionary are not yet supported

Can you please help? When saving one or two times works fine. Three or more and I am getting this: [INFO][11/28/2017 2:57:27 PM][Thread 0005][[akka://ECHO3DEV/user/api-master/PortfolioCoordinator/TK#425630680]] Portfolio Actor: TK completely…
Learning to program
  • 69
  • 9
1
vote
2 answers

How to test akka.net persistent actors

I'am using [Akka.Net 1.3.1] a mix of ReceiveActors and ReceivePersistentActors and now I want to write tests for my actorsystem. MyPersistentActor inherits from ReceivePersistentActor and MyActor inherits from ReceiveActor. I also installed…
Richi
  • 11
  • 3
1
vote
1 answer

Akka.net cluster sharding: Unable to register coordinator

I am trying to setup akka.net cluster sharding by creating a simple project. Project layout: Actors - class library that defines one actor and message. Is reference by other projects Inbound - Starts ShardedRegion and is the only node participating…
technologyblogger
  • 93
  • 3
1
vote
2 answers

How to apply the EventBus of CQRS with Akka.net and Akka.Persistence

I'm interested how to apply CQRS and Event Sourcing with Akka.net. I already noticed Akka.Persistence which delivers the ES part. As far as I understand the Command Handlers and AggergateRoot can be represented by the ReceivePersistentActor in a…
Beachwalker
  • 7,685
  • 6
  • 52
  • 94
1
2 3