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 关注
- 149 浏览
添加回答
举报
0/150
提交
取消