public void confirmCallback(RabbitTemplate template,final CountDownLatch threadLatch){ template.setConfirmCallback(new RabbitTemplate.ConfirmCallback() { public void confirm(CorrelationData correlationData, boolean ack, String cause) { if(ack){
confirms.add(correlationData.getId());
modelMap.put("sendResult",ack);
logger.info("發送成功");
}else {
modelMap.put("sendResult",cause);
logger.warn("發送失敗："+cause);
}
threadLatch.countDown();
}
});
}if(!template.isConfirmListener()){
confirmAndReturnTemplate.confirmCallback(template,threadLatch);
}
template為RabbitTemplate,我是想把每次發布確認的結果返回到前臺 ，放到了modelmap中，但是一個rabbitTemplate只能有一個confirmCallback，而回調函數在最后執行，就是還沒等我放到modelmap中就返回前臺了，有沒有刪除confirmCallBack重新設置的API或者其他解決方案
1 回答
陪伴而非守候
TA貢獻1757條經驗 獲得超8個贊
template為RabbitTemplate,我是想把每次發布確認的結果返回到前臺 ，放到了modelmap中，
但是一個rabbitTemplate只能有一個confirmCallback，而回調函數在最后執行，
就是還沒等我放到modelmap中就返回前臺了，有沒有刪除confirmCallBack重新設置的API或者其他解決方案
- 1 回答
- 0 關注
- 189 瀏覽
添加回答
舉報
0/150
提交
取消