здесь реализация яRabbitMQ basic.ack, на другом объекте канала
Потребляйте:
GetResponse resp = channel.basicGet(qName, false);
квитирования:
channel.basicAck(dTag, false);
или
channel.basicNack(dTag, false,true);
проблема, перед которой я столкнулся, если я создавать разные объекты канала, подтверждения не происходит. И я могу реализовать это только в том случае, если я выполняю оба действия (потребляю, признаю) из одного jvm (tomcat или любого другого сервера приложений).
поэтому, если мое приложение работает в кластерном режиме (несколько серверов приложений), у меня проблемы.
Может кто-нибудь, пожалуйста, помогите мне, как я могу подтвердить с другой машины, что сообщение было уничтожено, то есть с использованием другого канального объекта.
Спасибо!
Acking должно происходить на одном канале. Вы не можете получить сообщение с другого компьютера. – Gabriele