Type Alias RPCHandler<P, KP>

RPCHandler: (
msg: AMQPMessage<P>,
) => ResolveBody<P, KP> | Promise<ResolveBody<P, KP>>

Callback invoked for each incoming RPC request. Receives a decoded AMQPMessage and returns the response body.

Type Parameters

P extends ParserMap = {}
KP extends keyof P & string = never

Type declaration

- (msg: AMQPMessage<P>): ResolveBody<P, KP> | Promise<ResolveBody<P, KP>>
- Parameters
  - msg: AMQPMessage<P>
  Returns ResolveBody<P, KP> | Promise<ResolveBody<P, KP>>