orleans icon indicating copy to clipboard operation
orleans copied to clipboard

Orleans 7.0 About Memory stream usage help

Open wz172 opened this issue 1 year ago • 2 comments

Dear friends, I am using the example in the project to add the built-in memory stream of Orleans7.0 as Grain's message acceptance. In the test, I found that if a message is not sent for more than half an hour and the stream information is sent later, Grain cannot receive the stream information. I use the display mode to subscribe the stream information.What is the reason for this problem, is there any other related configuration when adding the memory stream?

wz172 avatar Feb 05 '24 02:02 wz172

Here is catching exception information

Orleans.Streams.QueueCacheMissException: Item not found in cache. Requested: [EventSequenceToken: SeqNum=638427006424614893, EventIndex=0], Low: [EventSequenceToken: SeqNum=638427006424623717, EventIndex=0], High: [EventSequenceToken: SeqNum=638427006424631869, EventIndex=0] at Orleans.Providers.Streams.Common.PooledQueueCache.SetCursor(Cursor cursor, StreamSequenceToken sequenceToken) in //src/Orleans.Streaming/Common/PooledCache/PooledQueueCache.cs:line 215 at Orleans.Providers.Streams.Common.PooledQueueCache.TryGetNextMessage(Object cursorObj, IBatchContainer& message) in //src/Orleans.Streaming/Common/PooledCache/PooledQueueCache.cs:line 283 at Orleans.Streams.PersistentStreamPullingAgent.RunConsumerCursor(StreamConsumerData consumerData)

wz172 avatar Feb 05 '24 05:02 wz172

experiencing the similar issue, any update on this ?

tchelidze avatar May 23 '24 10:05 tchelidze