diff --git a/packages/rabbitmq/src/amqp/connection.ts b/packages/rabbitmq/src/amqp/connection.ts index ff0fcab21..f9acbc60f 100644 --- a/packages/rabbitmq/src/amqp/connection.ts +++ b/packages/rabbitmq/src/amqp/connection.ts @@ -702,7 +702,7 @@ export class AmqpConnection { if ( !matchesRoutingKey(msg.fields.routingKey, rpcOptions.routingKey) ) { - channel.nack(msg, false, false); + channel.nack(msg, false, true); this.logger.error( 'Received message with invalid routing key: ' + msg.fields.routingKey,