ET
Один метод
@Scheduled
getTasks() {
task = taskService.receiveTask(timeout = 1000)
sendToQueue(task)
taskService.increaseTaskTimeout(task.id, 600_000)
}
Второй
@RabbitListener
receieveResponse(Response resp){
taskService.commit(resp.correlationId)
}
(некоторые вещи на котлине объяснять лучше, чем по-русски :))