以下是我的rabbitmq配置代碼
@Slf4j
@Configuration
public class RabbitConfig {
@Autowired
private RabbitTemplate rabbitTemplate;
/**
* 定義rabbitMq序列化為JSON
*
* @return Jackson2JsonMessageConverter
*/
@Bean
public MessageConverter messageConverter() {
return new Jackson2JsonMessageConverter();
}
/**
* 定制rabbitMqTemplate
*/
@PostConstruct
public void initRabbitTemplate() {
//收到訊息回呼
rabbitTemplate.setConfirmCallback(new RabbitTemplate.ConfirmCallback() {
@Override
public void confirm(CorrelationData correlationData, boolean ack, String cause) {
log.info("訊息確認：" + ack);
}
});
}
}
關鍵是配置MessageConverter這里，只要配置了這個，在其他任意地方使用
@Autowired
private RabbitTemplate rabbitTemplate;
都會拋出
錯誤，求助！！
uj5u.com熱心網友回復：
@Autowired
private RabbitTemplate rabbitTemplate;
/**
* 定制rabbitMqTemplate
*/
@PostConstruct
public void initRabbitTemplate() {
//收到訊息回呼
rabbitTemplate.setConfirmCallback(new RabbitTemplate.ConfirmCallback() {
@Override
public void confirm(CorrelationData correlationData, boolean ack, String cause) {
log.info("訊息確認：" + ack);
}
});
}
找到原因了，是這里的問題，但是，我要自定義回呼就需要使用這個，現在又該怎么辦
uj5u.com熱心網友回復：
已解決，不能寫一個類里面，我也不知道為啥，坑！
轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/238158.html
標籤：Web 開發
上一篇：java 代碼連接 mysql的時候報錯access denied for user 'aaa' @ '%，但是通過mysql客戶端可以連接'