这个错误是因为send方法需要一个Message类型的参数,而不是一个Lambda表达式。你可以将Lambda表达式替换为Message对象,然后将其传递给send方法。例如:

Message message = new Message("DemoTopic", "DemoTag", socketChannel.toString().getBytes());
DefaultMQProducer defaultMQProducer = SpringUtils.getBean("producer");
SendResult sendResult = defaultMQProducer.send(message);

这将创建一个Message对象,并使用它调用send方法。

Monojustnew MessageDemoTopic DemoTag socketChanneltoStringgetBytes thensendMsg- DefaultMQProducer defaultMQProducer = SpringUtilsgetBeanproducer;

原文地址: http://www.cveoy.top/t/topic/fe38 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录