問題描述:
????????org.springframework.amqp.rabbit.support.ListenerExecutionFailedException: Failed to convert message
????????Caused by: org.springframework.amqp.AmqpException: No method found for class java.lang.String
問題分析:
1、消息生產(chǎn)者發(fā)送的消息類型為String,消息消費(fèi)者接收的消息類型為Message,導(dǎo)致接收的時(shí)候類型轉(zhuǎn)換不對(duì)。文章來源:http://www.zghlxwxcb.cn/news/detail-595504.html
@Component
public class MessageProvider {
@Autowired
private RabbitTemplate rabbitTemplate;
public void send(String exchange,String routingKey,String content){
rabbitTemplate.convertAndSend(exchange,routingKey,content);
}
}
@Component
@RabbitListener(queues = "directqueue2")
public class MessageReceiver {
@RabbitHandler
public void process(Message message) throws InterruptedException {
Thread.sleep(1000);
}
}
解決辦法:消息生產(chǎn)者發(fā)送的消息類型和消息消費(fèi)者接收的消息類型一致即可。文章來源地址http://www.zghlxwxcb.cn/news/detail-595504.html
@Component
public class MessageProvider {
@Autowired
private RabbitTemplate rabbitTemplate;
public void send(String exchange,String routingKey,String content){
rabbitTemplate.convertAndSend(exchange,routingKey,content.getBytes());
}
}
@Component
@RabbitListener(queues = "directqueue2")
public class MessageReceiver {
@RabbitHandler
public void process(byte[] message) throws InterruptedException {
Thread.sleep(1000);
}
}
到了這里,關(guān)于RabbitMQ Failed to convert message.No method found for class java.lang.String問題解決的文章就介紹完了。如果您還想了解更多內(nèi)容,請(qǐng)?jiān)谟疑辖撬阉鱐OY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章,希望大家以后多多支持TOY模板網(wǎng)!