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("發(fā)送成功");
}else {
modelMap.put("sendResult",cause);
logger.warn("發(fā)送失?。?quot;+cause);
}
threadLatch.countDown();
}
});
}if(!template.isConfirmListener()){
confirmAndReturnTemplate.confirmCallback(template,threadLatch);
}
template為RabbitTemplate,我是想把每次發(fā)布確認(rèn)的結(jié)果返回到前臺 ，放到了modelmap中，但是一個rabbitTemplate只能有一個confirmCallback，而回調(diào)函數(shù)在最后執(zhí)行，就是還沒等我放到modelmap中就返回前臺了，有沒有刪除confirmCallBack重新設(shè)置的API或者其他解決方案
1 回答
陪伴而非守候
TA貢獻(xiàn)1757條經(jīng)驗(yàn) 獲得超8個贊
template為RabbitTemplate,我是想把每次發(fā)布確認(rèn)的結(jié)果返回到前臺 ，放到了modelmap中，
但是一個rabbitTemplate只能有一個confirmCallback，而回調(diào)函數(shù)在最后執(zhí)行，
就是還沒等我放到modelmap中就返回前臺了，有沒有刪除confirmCallBack重新設(shè)置的API或者其他解決方案
- 1 回答
- 0 關(guān)注
- 204 瀏覽
添加回答
舉報
0/150
提交
取消