JmsListenerContainerFacotory 不可用：NoSuchBeanDefinitionException，即使已配置 DefaultJmsListenerContainerFact
Posted
技术标签:
【中文标题】JmsListenerContainerFacotory 不可用：NoSuchBeanDefinitionException，即使已配置 DefaultJmsListenerContainerFactory【英文标题】：JmsListenerContainerFacotory Not available: NoSuchBeanDefinitionException, even though have configured a DefaultJmsListenerContainerFactory 【发布时间】：2021-10-22 04:54:18 【问题描述】：我正在编写单元/集成测试来检查使用 IBM MQ 的 JMS 侦听器是否被正确调用。我的 IncomingDataListener 中有两个监听器。它们用于同一队列中的两种类型的数据，由 MyDataProcessorService 和 MyOtherDataProcessorService 处理。
如下所示，我已经模拟了 MyDataProcessorService 和 MyOtherDataProcessorService 这两个服务。
但我没有使用 JmsTemplate 将消息发送到我的队列，以测试是否调用了正确的方法。
相反，我通过直接调用recieveMessage() 方法并检查是否调用了正确的数据处理器服务来直接读取xml 文件。
请告诉我是否应该使用 JmsTemplate 将消息发送到队列，而不是继续使用这种直接调用接收方的方法？
@RunWith(SpringRunner.class)
@Import(IncomingDataListener.class, DefaultJmsListenerContainerFactory.class)
@ContextConfiguration(classes = JmsConfig.class)
@PropertySource("classpath:config/application-test.properties")
public class IncomingDataListenerTest
@Autowired
private IncomingDataListener incomingDataListener;
@MockBean
private MyDataProcessorService myDataProcessorService;
@MockBean
private MyOtherDataProcessorService myOtherDataProcessorService;
private String myDataFileString;
@PostConstruct
public void setup() throws IOException
myDataFileString = XmlUtils.readFile("FileHavingXMLData.xml");
@Test
public void testProcessMyData() throws StaticDataValidationException
incomingDataListener.receiveMessage(myDataFileString);// Directly I am calling the IncomingDataListener classes recieveMessage method, is it right or wrong??
verify(myDataProcessorService, times(1)).process(any());
verify(myOtherDataProcessorService, times(0)).processOther(any());
这是配置类，最初我想创建一个 JmsTemplate 将消息发送到队列，然后在侦听器端测试是否调用了正确的处理器！
@Configuration
@PropertySource("classpath:config/application-test.properties")
@Slf4j
public class JmsConfig
@Value("$mq.jms.host")
private String host;
@Value("$mq.jms.port")
private Integer port;
@Value("$mq.jms.queue.manager")
private String queueManager;
@Value("$mq.jms.channel")
private String channel;
@Value("$mq.inbound.queue")
private String queue;
@Value("$mq.timeout")
private Long timeout;
@Bean
public MQQueueConnectionFactory getConnectionFactory()
MQQueueConnectionFactory mqQueueConnectionFactory = new MQQueueConnectionFactory();
try
mqQueueConnectionFactory.setHostName(host);
mqQueueConnectionFactory.setQueueManager(queueManager);
mqQueueConnectionFactory.setChannel(channel);
catch (JMSException e)
log.debug("Error creating Connection Factory");
return mqQueueConnectionFactory;
@Bean
public JmsTemplate jmsTemplateFactory(MQQueueConnectionFactory mqQueueConnectionFactory)
JmsTemplate jmsTemplate = new JmsTemplate(mqQueueConnectionFactory);
return jmsTemplate;
@Bean
public JmsListenerContainerFactory queueContainer(MQQueueConnectionFactory mqQueueConnectionFactory)
DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
factory.setConnectionFactory(mqQueueConnectionFactory);
return factory;
据我所知，我已经完成了所有需要的事情，但我遇到了如下所列的例外情况。
java.lang.IllegalStateException: Failed to load ApplicationContext
at org.springframework.test.context.cache.DefaultCacheAwareContextLoaderDelegate.loadContext(DefaultCacheAwareContextLoaderDelegate.java:132)
at org.springframework.test.context.support.DefaultTestContext.getApplicationContext(DefaultTestContext.java:123)
at org.springframework.boot.test.mock.mockito.MockitoTestExecutionListener.postProcessFields(MockitoTestExecutionListener.java:95)
at org.springframework.boot.test.mock.mockito.MockitoTestExecutionListener.injectFields(MockitoTestExecutionListener.java:79)
at org.springframework.boot.test.mock.mockito.MockitoTestExecutionListener.prepareTestInstance(MockitoTestExecutionListener.java:54)
at org.springframework.test.context.TestContextManager.prepareTestInstance(TestContextManager.java:244)
at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.createTest(SpringJUnit4ClassRunner.java:227)
at org.springframework.test.context.junit4.SpringJUnit4ClassRunner$1.runReflectiveCall(SpringJUnit4ClassRunner.java:289)
at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.methodBlock(SpringJUnit4ClassRunner.java:291)
at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.runChild(SpringJUnit4ClassRunner.java:246)
at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.runChild(SpringJUnit4ClassRunner.java:97)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.springframework.test.context.junit4.statements.RunBeforeTestClassCallbacks.evaluate(RunBeforeTestClassCallbacks.java:61)
at org.springframework.test.context.junit4.statements.RunAfterTestClassCallbacks.evaluate(RunAfterTestClassCallbacks.java:70)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.run(SpringJUnit4ClassRunner.java:190)
at org.junit.runner.JUnitCore.run(JUnitCore.java:137)
at com.intellij.junit4.JUnit4IdeaTestRunner.startRunnerWithArgs(JUnit4IdeaTestRunner.java:68)
at com.intellij.rt.junit.IdeaTestRunner$Repeater.startRunnerWithArgs(IdeaTestRunner.java:33)
at com.intellij.rt.junit.JUnitStarter.prepareStreamsAndStart(JUnitStarter.java:230)
at com.intellij.rt.junit.JUnitStarter.main(JUnitStarter.java:58)
Caused by: org.springframework.beans.factory.NoSuchBeanDefinitionException: No bean named 'jmsListenerContainerFactory' available
at org.springframework.beans.factory.support.DefaultListableBeanFactory.getBeanDefinition(DefaultListableBeanFactory.java:814)
at org.springframework.beans.factory.support.AbstractBeanFactory.getMergedLocalBeanDefinition(AbstractBeanFactory.java:1282)
at org.springframework.beans.factory.support.AbstractBeanFactory.doGetBean(AbstractBeanFactory.java:297)
at org.springframework.beans.factory.support.AbstractBeanFactory.getBean(AbstractBeanFactory.java:207)
at org.springframework.jms.config.JmsListenerEndpointRegistrar.resolveContainerFactory(JmsListenerEndpointRegistrar.java:159)
at org.springframework.jms.config.JmsListenerEndpointRegistrar.registerAllEndpoints(JmsListenerEndpointRegistrar.java:143)
at org.springframework.jms.config.JmsListenerEndpointRegistrar.afterPropertiesSet(JmsListenerEndpointRegistrar.java:135)
at org.springframework.jms.annotation.JmsListenerAnnotationBeanPostProcessor.afterSingletonsInstantiated(JmsListenerAnnotationBeanPostProcessor.java:210)
at org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(DefaultListableBeanFactory.java:912)
at org.springframework.context.support.AbstractApplicationContext.finishBeanFactoryInitialization(AbstractApplicationContext.java:878)
at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:550)
at org.springframework.test.context.support.AbstractGenericContextLoader.loadContext(AbstractGenericContextLoader.java:128)
at org.springframework.test.context.support.AbstractGenericContextLoader.loadContext(AbstractGenericContextLoader.java:60)
at org.springframework.test.context.support.AbstractDelegatingSmartContextLoader.delegateLoading(AbstractDelegatingSmartContextLoader.java:275)
at org.springframework.test.context.support.AbstractDelegatingSmartContextLoader.loadContext(AbstractDelegatingSmartContextLoader.java:243)
at org.springframework.test.context.cache.DefaultCacheAwareContextLoaderDelegate.loadContextInternal(DefaultCacheAwareContextLoaderDelegate.java:99)
at org.springframework.test.context.cache.DefaultCacheAwareContextLoaderDelegate.loadContext(DefaultCacheAwareContextLoaderDelegate.java:124)
... 25 more
请告诉我如何摆脱这个难题。
【问题讨论】：
【参考方案1】：你的工厂有一个非标准的 bean 名称；默认为jmsListenerContainerFactory；如果您将其命名为其他名称，则必须在 @JmsListener 注释上指定 bean 名称。
要么
@Bean
public JmsListenerContainerFactory jmsListenerContainerFactory(MQQueueConnectionFactory mqQueueConnectionFactory)
DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
factory.setConnectionFactory(mqQueueConnectionFactory);
return factory;
或
@Bean("jmsListenerContainerFactory")
public JmsListenerContainerFactory queueContainer(MQQueueConnectionFactory mqQueueConnectionFactory)
DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
factory.setConnectionFactory(mqQueueConnectionFactory);
return factory;
/**
* The bean name of the @link org.springframework.jms.config.JmsListenerContainerFactory
* to use to create the message listener container responsible for serving this endpoint.
* <p>If not specified, the default container factory is used, if any.
*/
String containerFactory() default "";
【讨论】：
谢谢加里，你帮助了我多少次！！永远感谢。你认为我做得对吗，或者我应该将消息发送到实际的生产队列并测试我的处理器是否被正确调用！！ 这取决于你的目标是什么；直接调用侦听器更像是一个单元测试而不是集成测试，但非常有效。实际上向代理发送消息将是一个集成测试，这也是一个有效的事情，以验证配置是否正确。所以，两者都有用。 因此，在如上所示的同一类中，我可以配置 JmsTemplate 以向代理发送消息以进行集成测试。如果我错了，请纠正我。 是的；但大多数人会在测试中使用嵌入式代理（例如 ActiveMQ）；特别是对于您不想依赖外部服务器的 CI 构建。 TestContainers 是另一种选择 - 看起来有一个 IBM MQ 容器 github.com/ibm-messaging/mq-container【参考方案2】：我认为以下其中一项应该适合您
-
在配置文件中将方法名称 queueContainer 重命名为 jmsListenerContainerFactory
在配置文件中使用 @Bean("jmsListenerContainerFactory") 而不是 @Bean
将注入工厂的属性的type更改为JmsListenerContainerFactory
将注入工厂的属性的 name 更改为 jmsListenerContainerFactory
您可以从以下来源了解更多关于 spring 如何命名 bean 并将它们连接到类的信息：
https://www.baeldung.com/spring-bean-names https://www.baeldung.com/spring-annotations-resource-inject-autowire【讨论】：
感谢您的链接。 只能接受一个答案，因为 Gary 是第一个因此接受了他。但是这些链接很有帮助 可以理解 ;-) 我赞成你的回答，也让我知道“将属性类型更改为 JmsListenerContainerFactory”以及第四点是什么意思。我有一个请求，请始终使用代码示例备份答案。他们详细说明了一切。 第 3 点和第 4 点可能不适用于您的具体情况，因为您可能自己不进行工厂自动装配。代码示例在第二个链接baeldung.com/spring-annotations-resource-inject-autowire的4.1.1和4.1.3点下以上是关于JmsListenerContainerFacotory 不可用：NoSuchBeanDefinitionException，即使已配置 DefaultJmsListenerContainerFact的主要内容，如果未能解决你的问题，请参考以下文章