-
-
Notifications
You must be signed in to change notification settings - Fork 292
Open
Labels
Description
Could we please have a dedicated Exception/Error for when an RPC timeout occurs?
relevant code:
nestjs/packages/rabbitmq/src/amqp/connection.ts
Lines 440 to 447 in 52e84ad
| const timeout$ = interval(timeout).pipe( | |
| first(), | |
| map(() => { | |
| throw new Error( | |
| `Failed to receive response within timeout of ${timeout}ms for exchange "${requestOptions.exchange}" and routing key "${requestOptions.routingKey}"`, | |
| ); | |
| }), | |
| ); |
Otherwise, you are forced to check for the message :/
Thank you!