Interface IResponderBuilder

Namespace

RabbitMQ.AMQP.Client

Assembly

RabbitMQ.AMQP.Client.dll

IRpcServerBuilder is the interface for creating an RPC server. The RPC server consumes requests from a queue and sends replies to a reply queue. See also IResponder and IRequesterBuilder

public interface IResponderBuilder

Methods

BuildAsync()

Build and return the RPC server.

Task<IResponder> BuildAsync()

Returns

Task<IResponder>

CorrelationIdExtractor(Func<IMessage, object>?)

Extracts the correlation id from the request message. each message has a correlation id that is used to match the request with the response. There are default implementations for the correlation id extractor. With this method, you can provide a custom implementation.

IResponderBuilder CorrelationIdExtractor(Func<IMessage, object>? correlationIdExtractor)

Parameters

correlationIdExtractor Func<IMessage, object>

Returns

IResponderBuilder

Handler(ResponderHandler)

Handle the request message and return the reply message.

IResponderBuilder Handler(ResponderHandler handler)

Parameters

handler ResponderHandler

Returns

IResponderBuilder

ReplyPostProcessor(Func<IMessage, object, IMessage>?)

Post processes the reply message before sending it to the client. The object parameter is the correlation id extracted from the request message. There are default implementations for the reply post processor that use the correlationId() field to set the correlation id of the reply message. With this method, you can provide a custom implementation.

IResponderBuilder ReplyPostProcessor(Func<IMessage, object, IMessage>? replyPostProcessor)

Parameters

replyPostProcessor Func<IMessage, object, IMessage>

Returns

IResponderBuilder

RequestQueue(IQueueSpecification)

IResponderBuilder RequestQueue(IQueueSpecification requestQueue)

Parameters

requestQueue IQueueSpecification

Returns

IResponderBuilder

RequestQueue(string)

The queue from which requests are consumed. The client sends requests to this queue and the server consumes them.

IResponderBuilder RequestQueue(string requestQueue)

Parameters

requestQueue string

Returns

IResponderBuilder