在 Spring Boot 中调度 JMS 监听器

Question

我在 Spring Boot 应用程序中有一个方法可以侦听 ActiveMQ 中的队列。我想安排该方法，使其不会在应用程序启动时开始侦听队列并每 X 分钟运行一次。

这是我为完成任务而编写的方法。我已禁用 JMSListener 自动启动，这样它就不会在应用程序启动时开始监听。

@Scheduled(fixedDelay = 1000, initialDelay = 1000)
@JmsListener(destination = "queueName")
public void receiveMessage(final Message jsonMessage) throws JMSException {
   System.out.println("Received message " + jsonMessage);

}

@Bean
public DefaultJmsListenerContainerFactory jmsListenerContainerFactory() {
   DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
   factory.setConnectionFactory(connectionFactory());
   factory.setConcurrency("1-1");
   factory.setAutoStartup(false);
   return factory;
}

但是当我运行应用程序时，我得到一个异常，它说调度的方法不能有参数：

Encountered invalid @Scheduled method 'receiveMessage': Only no-arg methods may be annotated with @Scheduled

有没有办法可以安排JMSListener，使其在应用程序启动延迟后启动，并安排为每 X 分钟运行一次并从队列中读取消息？

Answer 1

你不能在那里使用@Scheduled。

使用JmsListenerEndpointRegistry bean 在需要时启动和停止监听器。

@JmsListener(id = "foo" ...)


registry.getListenerContainer("foo").start();
...
registry.getListenerContainer("foo").stop();