You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
so i want to use dlx on my project, the message recieve by first subscriber but when i pass to dlx, my dlx queue not receiving any message. my code shows like this
`
@RabbitSubscribe({
exchange: "be-hub",
routingKey: "accurate-create-do",
queue: "accurate-create-do-queue",
queueOptions: {
// messageTtl: 4000,
deadLetterExchange: "be-hub", //! ini di bikin di config
deadLetterRoutingKey: "dlx-1-key", //! ini di bikin di config
},
// errorHandler: RMQErrorHandler,
})
async createLarkDeliveryOrder()
const flag = false;
console.log("firts queue");
if (!flag) {
console.log("im going to send it to dlx");
return new Nack(false);
}
}
@RabbitSubscribe({
exchange: "be-hub",
routingKey: "dlx-1-key",
queue: "dead-letter-1-queue",
errorHandler: RMQErrorHandler,
})
async createDeliveryOrdeAccurate()
console.log("there we go, popped up on dlx queue");
return new Nack();
}
`
can you guys help me, and tell me what mistakes did i do ?
reacted with thumbs up emoji reacted with thumbs down emoji reacted with laugh emoji reacted with hooray emoji reacted with confused emoji reacted with heart emoji reacted with rocket emoji reacted with eyes emoji
-
so i want to use dlx on my project, the message recieve by first subscriber but when i pass to dlx, my dlx queue not receiving any message. my code shows like this
`
@RabbitSubscribe({
exchange: "be-hub",
routingKey: "accurate-create-do",
queue: "accurate-create-do-queue",
queueOptions: {
// messageTtl: 4000,
deadLetterExchange: "be-hub", //! ini di bikin di config
deadLetterRoutingKey: "dlx-1-key", //! ini di bikin di config
},
// errorHandler: RMQErrorHandler,
})
async createLarkDeliveryOrder()
const flag = false;
console.log("firts queue");
if (!flag) {
console.log("im going to send it to dlx");
return new Nack(false);
}
}
@RabbitSubscribe({
exchange: "be-hub",
routingKey: "dlx-1-key",
queue: "dead-letter-1-queue",
errorHandler: RMQErrorHandler,
})
async createDeliveryOrdeAccurate()
console.log("there we go, popped up on dlx queue");
return new Nack();
}
`
can you guys help me, and tell me what mistakes did i do ?
Beta Was this translation helpful? Give feedback.
All reactions