File tree Expand file tree Collapse file tree 1 file changed +2
-1
lines changed Expand file tree Collapse file tree 1 file changed +2
-1
lines changed Original file line number Diff line number Diff line change @@ -26,6 +26,7 @@ export class RabbitmqMessagingConsumer implements IMessagingConsumer<AmqpChannel
2626 channel . connection . createConsumer ( {
2727 queue : channel . config . queue ,
2828 queueOptions : { durable : true } ,
29+ requeue : false ,
2930 } , async ( msg ) : Promise < void > => {
3031 const rabbitMqMessage = msg as RabbitMQMessage ;
3132
@@ -50,7 +51,7 @@ export class RabbitmqMessagingConsumer implements IMessagingConsumer<AmqpChannel
5051 const envelope = {
5152 headers : { 'messaging-routing-key' : errored . dispatchedConsumerMessage . routingKey } ,
5253 exchange : 'dead_letter.exchange' ,
53- routingKey : `${ channel . config . queue } _dead_letter`
54+ routingKey : `${ channel . config . queue } _dead_letter` ,
5455 } ;
5556 await publisher . send ( envelope , errored . dispatchedConsumerMessage . message ) ;
5657 await publisher . close ( ) ;
You can’t perform that action at this time.
0 commit comments