spring - DefaultMessageListenerContainer 未接收消息

Question

我有一个 DefaultMessageListenerContainer 配置如下:

DefaultMessageListenerContainer container = new DefaultMessageListenerContainer();
container.setConcurrentConsumers(4);
container.setConnectionFactory(connectionFactory);
container.setDestinationName(String.format("Consumer.%s.VirtualTopic.%s", group, topic));
container.setSessionAcknowledgeMode(Session.CLIENT_ACKNOWLEDGE);
container.setSessionTransacted(true);
container.setMessageListener(new DelegatingMessageListener(listener, messageMapper, event));

container.start();

消息容器永远不会接收消息，并且我的消息监听器也永远不会被调用。保持其他所有不变，如果我只是将 DefaultMessageListenerContainer 切换到 SimpleMessageListenerContainer，它可以工作 - 但 SimpleMessageListenerContainer 在连接丢失后不会恢复

日志中没有错误，也几乎没有任何相关消息。有谁知道为什么会发生这种情况吗？

Answer 1

在 Java 中(在 Spring 应用程序上下文之外)构建容器时，您需要在 start() 之前调用 afterPropertiesSet()。

上下文会自动为 Spring bean 执行此操作。