diff --git a/src/main/java/com/modoospace/alarm/consumer/AlarmDLQConsumer.java b/src/main/java/com/modoospace/alarm/consumer/AlarmDLQConsumer.java index ce2a2a3..dc12d63 100644 --- a/src/main/java/com/modoospace/alarm/consumer/AlarmDLQConsumer.java +++ b/src/main/java/com/modoospace/alarm/consumer/AlarmDLQConsumer.java @@ -33,7 +33,7 @@ public void processFailedMessagesRequeue(Message failedMessage) { } log.info("Retrying message for the {} time", retriesCnt); failedMessage.getMessageProperties().getHeaders().put(RETRY_COUNT_HEADER, ++retriesCnt); - rabbitTemplate.send("x.reservation", + rabbitTemplate.send("x.alarm.work", failedMessage.getMessageProperties().getReceivedRoutingKey(), failedMessage); } }