orleans
orleans copied to clipboard
client cannot sometimes receive message from stream
- 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
});
I have 2 silos. And 1 client server;
I use persistent storange for PubSubStore
and solve this problem.