У меня настроена очередь SQS вместе с потребителем и производителем, поэтому я использовал очередь FIFO, и как только мой потребитель получает сообщение, он удаляет сообщение из очереди, а затем мой код выполняет некоторые операции, если какая-либо вещь не удалась, тогда я потерял сообщение, так что я просто хочу сохранить это сообщение в очереди, и как только я дам подтверждение, только затем удалите его. Пожалуйста, помогите мне, как сделать подтверждение и удалить на основе подтверждения. Вот мой потребительский код
@SqsListener(value = "${queueName}")
public void receiveMessage(final msgDTO msgDTO,
@Header("SenderId") final String senderId,¸ v) {
log.info("Received message: {}, having SenderId: {}", msgDTO, senderId);
// do some operation
if (operationSuccess) {
// TODO ACKNOWLEDGEMENT
}
}```