You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Dear Sir,
I have been using RawRabbit in a production application for performing RPC to a webservice on a remote PC.Sometimes the RPC client on the remote pc may loose its internet connection so the server will be creating response queues with a consumer which will never receive any response.The queue and channel created for this will stay there as there is consumer.So can you give me any options by which i can sort this out.
This is how i am performing RPC
var result = await busClient.RequestAsync<InvocationRequest, InvocationResponse>(request, ctx => ctx
.UseDedicatedResponseConsumer()
.UseRequestConfiguration(cfg => cfg
.PublishRequest(p => p
.OnDeclaredExchange(e => e
.WithName(Exchange)
.WithAutoDelete())
.WithRoutingKey(RoutingKey)
.WithProperties(prop => prop.DeliveryMode = 1))
.ConsumeResponse(r => r
.Consume(c => c
.WithRoutingKey($"response_key_{Guid.NewGuid()}"))
.FromDeclaredQueue(q => q.WithName($"response_queue_{Guid.NewGuid()}"))
.OnDeclaredExchange(e => e
.WithName(Exchange)
.WithAutoDelete()))));
The text was updated successfully, but these errors were encountered:
Dear Sir,
I have been using RawRabbit in a production application for performing RPC to a webservice on a remote PC.Sometimes the RPC client on the remote pc may loose its internet connection so the server will be creating response queues with a consumer which will never receive any response.The queue and channel created for this will stay there as there is consumer.So can you give me any options by which i can sort this out.
This is how i am performing RPC
var result = await busClient.RequestAsync<InvocationRequest, InvocationResponse>(request, ctx => ctx
.UseDedicatedResponseConsumer()
.UseRequestConfiguration(cfg => cfg
.PublishRequest(p => p
.OnDeclaredExchange(e => e
.WithName(Exchange)
.WithAutoDelete())
.WithRoutingKey(RoutingKey)
.WithProperties(prop => prop.DeliveryMode = 1))
.ConsumeResponse(r => r
.Consume(c => c
.WithRoutingKey($"response_key_{Guid.NewGuid()}"))
.FromDeclaredQueue(q => q.WithName($"response_queue_{Guid.NewGuid()}"))
.OnDeclaredExchange(e => e
.WithName(Exchange)
.WithAutoDelete()))));
The text was updated successfully, but these errors were encountered: