Skip to content

Type Alias: RpcSubscriberHandler<T, U>

ts
type RpcSubscriberHandler<T, U> = (msg, rawMessage?, headers?) => Promise<RpcResponse<U>>;

Defined in: packages/rabbitmq/src/amqp/connection.ts:57

Type Parameters

Type ParameterDefault type
Tunknown
Uunknown

Parameters

ParameterType
msgT | undefined
rawMessage?ConsumeMessage
headers?unknown

Returns

Promise<RpcResponse<U>>

Released under the MIT License.