orleans icon indicating copy to clipboard operation
orleans copied to clipboard

client cannot sometimes receive message from stream

Open baekhyunee7 opened this issue 1 year ago • 1 comments

  • orleans: 3.6.4 client can sometimes receive stream message , but sometimes not; "PubSubStore: is in Memory; silo seems succeed to send message to stream; but client cannot receive; Is there any way for client to keep alive for stream? silo producer:
var stream = GetStreamProvider( "SimpleMessageStreamProvider" ).GetStream<SomeMessage>( serverId, "SomeMessage" );
await stream.OnNextAsync( new SomeMessage());

client consumer:

var stream = client.GetStreamProvider( "SimpleMessageStreamProvider").GetStream<SomeMessage>( serverId, "SomeMessage" );
await _stream.SubscribeAsync(
                                                           ( data, token ) =>
                                                           {
                                                                // do something
                                                           });

baekhyunee7 avatar Sep 21 '22 06:09 baekhyunee7

I have 2 silos. And 1 client server;

baekhyunee7 avatar Sep 21 '22 06:09 baekhyunee7

I use persistent storange for PubSubStore and solve this problem.

baekhyunee7 avatar Sep 24 '22 12:09 baekhyunee7