diff --git a/redaction-report-service-v1/redaction-report-service-server-v1/src/main/java/com/iqser/red/service/redaction/report/v1/server/service/ReportMessageReceiver.java b/redaction-report-service-v1/redaction-report-service-server-v1/src/main/java/com/iqser/red/service/redaction/report/v1/server/service/ReportMessageReceiver.java index d1b7731..71c40b6 100644 --- a/redaction-report-service-v1/redaction-report-service-server-v1/src/main/java/com/iqser/red/service/redaction/report/v1/server/service/ReportMessageReceiver.java +++ b/redaction-report-service-v1/redaction-report-service-server-v1/src/main/java/com/iqser/red/service/redaction/report/v1/server/service/ReportMessageReceiver.java @@ -22,7 +22,6 @@ import lombok.extern.slf4j.Slf4j; @Slf4j @Service @RequiredArgsConstructor -@RabbitListener(queues = REPORT_QUEUE) public class ReportMessageReceiver { private final ObjectMapper objectMapper; @@ -32,6 +31,7 @@ public class ReportMessageReceiver { @SneakyThrows @RabbitHandler + @RabbitListener(queues = REPORT_QUEUE) public void receive(Message message) { ReportRequestMessage reportMessage = objectMapper.readValue(message.getBody(), ReportRequestMessage.class);