Rpc Server pattern
Recommended argument to add when declaring the rpc server queue. This will set the dead letter exchange to the header exchange to help clients to be notified if a request has timed out
val start :
?async:bool ->
?discard_redelivered:bool ->
[< `Failed | `Ok ] as 'a Channel.t ->
Queue.t ->
(Message.message -> Message.message Thread.Deferred.t) ->
'a t Thread.Deferred.tStart an rpc server producing replies for requests coming in on the given queue.
If true, multiple requests can be handled concurrently. If false, message are handled synchronously (default)
It is recommended to create the queue with the header_exchange as dead letter exchange. This will allow messages to be routed back the the sender at timeout. E.g: Queue.declare ~arguments:[Rpc.queue_argument] "rpcservice"
val stop : _ t -> unit Thread.Deferred.tStop the server