spring rabbitmq jsf互操作问题

Question

我有一个JSF支持bean和spring+RabbitMQ应用程序。我打电话给那里

rabbitTemplate.convertAndSend(<send to the main queue - not first which I mentioned below>)

我不能在那里使用convertSendAndReceive，因为复杂的逻辑、队列链等等。问题是我有一个输出队列和它的侦听器。这个侦听器充当路由器，在队列、调用函数等之间调度请求

但我需要返回到客户“OK”字符串，以防它已经在第一个队列中被处理。该消息将进一步进入下一个队列，但在第一个队列之后，我需要用“OK”消息通知我的客户。换句话说，某事

rabbitTemplate.convertAndSend
while(<wait for sth>){
    if(message comes){
      //send "OK" to customer back
      //I would listen here for my output queue, but I already have     a listener, how I can be sure that my message will come to my listener here, not there?

    } 
}

所以问题是--如何对我的JSF bean进行确认，确认我的消息已经通过了第一个队列，并发送回响应？

Answer 1

RabbitTemplate具有类似于SetConfirmCallback的选项。这样，您应该为convertandsend和correlationdata以及correlate从

void confirm(CorrelationData correlationData, boolean ack, String cause);

在发送OK响应之前等待的实现。