rabbitmq basic.ack ,在不同的通道对象上
rabbitmq basic.ack , on a different channel object
这是我的实现
消费:
GetResponse resp = channel.basicGet(qName, false);
确认:
channel.basicAck(dTag, false);
或
channel.basicNack(dTag, false,true);
我面临的问题是,如果我创建不同的通道对象,则不会发生确认。
如果我从同一个 jvm(tomcat 或任何其他应用程序服务器)执行这两项操作(消费、确认),我只能实现这一点。
因此,如果我的应用程序 运行 处于集群模式(多个应用程序服务器),我就有麻烦了。
任何人都可以帮助我如何从另一台机器确认消息已被使用,即使用不同的通道对象。
谢谢!!
Can anyone please help me how can I acknowledge from a different machine the message was consumed, i.e. using a different channelobject .
你不能。
确认必须发生在同一个频道上。
这是我的实现
消费:
GetResponse resp = channel.basicGet(qName, false);
确认:
channel.basicAck(dTag, false);
或
channel.basicNack(dTag, false,true);
我面临的问题是,如果我创建不同的通道对象,则不会发生确认。 如果我从同一个 jvm(tomcat 或任何其他应用程序服务器)执行这两项操作(消费、确认),我只能实现这一点。
因此,如果我的应用程序 运行 处于集群模式(多个应用程序服务器),我就有麻烦了。
任何人都可以帮助我如何从另一台机器确认消息已被使用,即使用不同的通道对象。
谢谢!!
Can anyone please help me how can I acknowledge from a different machine the message was consumed, i.e. using a different channelobject .
你不能。
确认必须发生在同一个频道上。