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é)果返回到前臺(tái) ，放到了modelmap中，但是一個(gè)rabbitTemplate只能有一個(gè)confirmCallback，而回調(diào)函數(shù)在最后執(zhí)行，就是還沒等我放到modelmap中就返回前臺(tái)了，有沒有刪除confirmCallBack重新設(shè)置的API或者其他解決方案
1 回答
陪伴而非守候
TA貢獻(xiàn)1757條經(jīng)驗(yàn) 獲得超8個(gè)贊
template為RabbitTemplate,我是想把每次發(fā)布確認(rèn)的結(jié)果返回到前臺(tái) ，放到了modelmap中，
但是一個(gè)rabbitTemplate只能有一個(gè)confirmCallback，而回調(diào)函數(shù)在最后執(zhí)行，
就是還沒等我放到modelmap中就返回前臺(tái)了，有沒有刪除confirmCallBack重新設(shè)置的API或者其他解決方案
- 1 回答
- 0 關(guān)注
- 218 瀏覽
添加回答
舉報(bào)
0/150
提交
取消