Fix broken tag query message replay logic

petabridge / Akka.Persistence.Azure

Azure-powered Akka.Persistence for Akka.NET actors

Apache License 2.0

13 stars 11 forks source link

Closed Arkatufus closed 4 months ago

Arkatufus commented 4 months ago

Fixes #385

Change AzureTableStorageReadJournal.CurrentEventsByTag toOffset to DateTime.UtcNow.Ticks to enable query limiting
Change how AzureTableStorageReadJournal.ReplayTaggedMessagesAsync() signals if it reaches the end of records
Limit the number of record fetch to limit network bandwidth waste
Fix CurrentEventsByTagPublisher logic to determine completion from the read journal return status.

Aaronontheweb commented 4 months ago

What's with the sharding specs failing? Unrelated?

Arkatufus commented 4 months ago

I'm not sure, let me check