RabbitMQ MessageConverter在运行Spring Boot应用程序时出现错误

我试图运行一个弹出式启动应用程序（1.4.7.RELEASE），它会将消息吐出到RabbitMQ队列中。我的建筑工作顺利，但是当我试图通过mvn clean spring-boot:run运行应用程序，我收到以下错误在文件ProduceMessage.javaRabbitMQ MessageConverter在运行Spring Boot应用程序时出现错误

@PropertySource("classpath:application.properties") 
@Component 
@ContextConfiguration("classpath:META-INF/spring/rabbitmq-producer.xml") 
public class ProduceMessage { 

    private static final Logger logger = LoggerFactory.getLogger(ProduceMessage.class.getName()); 

    @Autowired 
    private RabbitTemplate myEventTemplate; 

    @Autowired 
    private MessageConverter ctdMessageConverter; 

    @Value("${fieldChangedEvent.MainQueue}") 
    private String mainQ; 

    /* 
    * (non-Javadoc) 
    * 
    * @see com.ge.predix.dispatcherqproducer.api.produceFieldChangedEvent# 
    * produceFieldChangedEvent(com.ge.dsp.pm.solution.service.fieldchanged. 
    * FieldChangedEvent) 
    */ 
    public boolean produceStringMessage(String data) { 

     logger.debug("In produceStringMessage......"); 

     MessageProperties prop = new MessageProperties(); 
     prop.setContentType(MessageProperties.CONTENT_TYPE_TEXT_PLAIN); 

     Message msg = ctdMessageConverter.toMessage(data, prop); 

     logger.debug("publishing string to ......= " + mainQ); 
     myEventTemplate.convertAndSend(mainQ, msg); 

     return true; 
    } 
}

错误：

2017-10 -04 11：06：08.830 [0; 39m [32m INFO [0; 39m [35m62162 [0; 39m [2m --- [0; 39m [2m [main] [0; 39m [36mo.apache.catalina.core .StandardService [0; 39m [2m：[0; 39m停止服务[Tomcat] [2m2017-10-04 11:06:08.849 [0; 39m [32m INFO [0; 39m [35m62162 [0; 39m [2m- - [0; 39m [2m [main] [0; 39m [36mutoConfigurationReportLog gingInitializer [0; 39m [2m：[0; 39m

启动ApplicationContext时出错。要显示自动配置报告，请启用'debug'重新运行您的应用程序。

[2m2017-10-04 11：06：08.944 [0; 39m [31mERROR [0; 39m [2m --- [0; 39m [2m [main] [0; 39m [ 36mo.sbdLoggingFailureAnalysisReporter [0; 39m [2m：[0; 39m

***************************应用程序启动失败*************************** 描述： com.ge.power.tcs.producer.ProduceMessage中的字段ctdMessageConverter需要一个类型的bean 'org.springframework.amqp.support.converter.MessageConverter'找不到。

操作：

考虑您的配置中定义型 'org.springframework.amqp.support.converter.MessageConverter' 的豆。

的RabbitMQ-producer.xml

<beans xmlns="http://www.springframework.org/schema/beans" 
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:rabbit="http://www.springframework.org/schema/rabbit" 
    xmlns:context="http://www.springframework.org/schema/context" 
    xmlns:oxm="http://www.springframework.org/schema/oxm" 
    xsi:schemaLocation="http://www.springframework.org/schema/rabbit 
      http://www.springframework.org/schema/rabbit/spring-rabbit.xsd 
      http://www.springframework.org/schema/beans 
      http://www.springframework.org/schema/beans/spring-beans.xsd 
      http://www.springframework.org/schema/oxm http://www.springframework.org/schema/oxm/spring-oxm.xsd"> 
    <bean id="ctdMessageConverter" 
     class="org.springframework.amqp.support.converter.ContentTypeDelegatingMessageConverter"> 
     <property name="delegates"> 
      <map> 
       <entry key="text/plain" value-ref="simpleMessageConverter" /> 
      </map> 
     </property> 
    </bean> 
    <bean id="simpleMessageConverter" 
     class="org.springframework.amqp.support.converter.SimpleMessageConverter" />   
</beans>

来源

2017-10-04 sromit

，做你有一个你想注入的消息转换器的'@ Bean'定义？ –

其导入org.springframework.amqp.support.converter.MessageConverter;实例 – sromit

我的问题是，你期望在这里注入什么，为什么是你的期望？这在您分享的代码中并不明显。 –

一旦我们在主应用程序类在春季启动，而不是@ContextConfiguration("classpath:META-INF/spring/rabbitmq-producer.xml")提@ImportResource("classpath:META-INF/spring/rabbitmq-producer.xml")的问题就解决了其中包含的bean实例

来源

2017-10-06 16:28:15 sromit

RabbitMQ MessageConverter在运行Spring Boot应用程序时出现错误

回答

相关问题