Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Fix PersistenceIdsPublisher hung on failure messages #6374

Conversation

Arkatufus
Copy link
Contributor

Fixes #6365

Changes

  • Change Tell to Ask
  • Handle failures to maintain consistent actor receive state

@Aaronontheweb
Copy link
Member

@Arkatufus looks like a compilation failure

@Arkatufus
Copy link
Contributor Author

Ah, API Verify problem

@Arkatufus
Copy link
Contributor Author

Fixed

Copy link
Member

@Aaronontheweb Aaronontheweb left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM

case Cancel _:
Context.Stop(Self);
return true;

case Status.Failure msg:
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM

@@ -77,14 +101,20 @@ private bool Active(object message)
{
switch (message)
{
case CurrentPersistenceIds _:
// Ignore duplicate CurrentPersistenceIds response
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM

@@ -26,7 +25,7 @@ public class SqlReadJournal :
IAllEventsQuery,
ICurrentAllEventsQuery
{
public static string Identifier = "akka.persistence.query.journal.sql";
public const string Identifier = "akka.persistence.query.journal.sql";
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM

@Aaronontheweb Aaronontheweb enabled auto-merge (squash) January 30, 2023 16:55
@Aaronontheweb Aaronontheweb added this to the 1.5.0 milestone Jan 30, 2023
@Aaronontheweb
Copy link
Member

@Arkatufus this will need backport to v1.4

@Arkatufus
Copy link
Contributor Author

Will do

@Aaronontheweb Aaronontheweb merged commit d3b89da into akkadotnet:dev Jan 30, 2023
Arkatufus added a commit to Arkatufus/akka.net that referenced this pull request Jan 30, 2023
…e messages

* Fix PersistenceIdsPublisher hung on failure messages
* Downgrade failure messages from Warning to Info
* Update API Verify list

(Cherry-picked from d3b89da)
Aaronontheweb pushed a commit that referenced this pull request Jan 30, 2023
…#6375)

* Fix PersistenceIdsPublisher hung on failure messages
* Downgrade failure messages from Warning to Info
* Update API Verify list

(Cherry-picked from d3b89da)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

Successfully merging this pull request may close these issues.

Akka.Persistence.Query.Sql: PersistenceIds hangs after about 2 hours
2 participants