使用主题和队列处理@JmsListener的更简单方法

@Configuration
@EnableJms
public class JmsConfig {

    @Bean
    public ConnectionFactory connectionFactory() {
        // 配置并返回JMS连接工厂
        return new ActiveMQConnectionFactory();
    }

    @Bean
    public JmsListenerContainerFactory<?> jmsListenerContainerFactory(ConnectionFactory connectionFactory) {
        // 配置并返回JMS监听容器工厂
        DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
        factory.setConnectionFactory(connectionFactory);
        return factory;
    }

    @Bean
    public MessageConverter messageConverter() {
        // 配置并返回消息转换器
        return new SimpleMessageConverter();
    }

    @Bean
    public JmsTemplate jmsTemplate(ConnectionFactory connectionFactory, MessageConverter messageConverter) {
        // 配置并返回JMS模板
        JmsTemplate jmsTemplate = new JmsTemplate(connectionFactory);
        jmsTemplate.setMessageConverter(messageConverter);
        return jmsTemplate;
    }
}

@Component
public class JmsListenerExample {

    @JmsListener(destination = "myQueue")
    public void processQueueMessage(String message) {
        // 处理队列消息
        System.out.println("Received from queue: " + message);
    }

    @JmsListener(destination = "myTopic", containerFactory = "jmsListenerContainerFactory")
    public void processTopicMessage(String message) {
        // 处理主题消息
        System.out.println("Received from topic: " + message);
    }
}