使用多个 jms 侦听器处理多个队列的可能性

Question

我有以下 Java 进程正在侦听 ActiveMQ 的 MyMessageQueue 队列。我可以看到使用此语句 System.out.println("Message Retrieved is:" +message); 检索到的消息 在processBrokerQueues 方法内。

@Component
public class MessageConsumer {

    @Autowired
    private JavaMailSender javaMailSender;

    // one instance, reuse
    private final CloseableHttpClient httpClient = HttpClients.createDefault();

    private static Connection connection;

    // URL of the JMS server. DEFAULT_BROKER_URL will just mean that JMS server is on localhost
    private static String url = ActiveMQConnection.DEFAULT_BROKER_URL;
    private static String subject = "MyMessageQueue"; //Queue Name
    // default broker URL is : tcp://localhost:61616"
    private static ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("ApplicationContext.xml");
    private static final Logger logger = LoggerFactory.getLogger(MessageConsumer.class);
    private static final DateFormat sdf = new SimpleDateFormat("yyyy/MM/dd HH:mm:ss");

    // Working Code with JMS 2.0
    @JmsListener(destination = "MyMessageQueue")
    public void processBrokerQueues(String message) throws DaoException, JMSException {


        System.out.println("Message Retrieved is:" + message);


    }

    private void createConnection() throws JMSException {
        // Getting JMS connection from the server
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(url);
        connection = connectionFactory.createConnection();
    }

    private void close() throws IOException {
        httpClient.close();
    }

}

我想知道，如果我想听 20-30 个不同的队列，添加多个具有不同队列名称的 @JmsListener(destination = "MyMessageQueue") 是否正确，例如 MessageQueue1, MessageQueue2 ....... 等等，直到 MessageQueue30？

Answer 1

您可以使用通配符主题名称。 一个简单的JUnit测试如下...

public EmbeddedActiveMQBroker embeddedBroker = new EmbeddedActiveMQBroker();
@Autowired JmsTemplate jmsTemplate;

@Test
void testListener() throws Exception{
    jmsTemplate.convertAndSend("MyMessageQueue.1", "Test");

}

@JmsListener(destination = "MyMessageQueue.>")
public void processBrokerQueues(ActiveMQTextMessage msg) throws Exception {
    System.out.println("Message Retrieved is:" + msg.getText() + " TopicName:" + msg.getDestination().getPhysicalName());
}

相关依赖

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-activemq</artifactId>
    <version>2.5.3</version>
</dependency>
<dependency>
    <groupId>org.apache.activemq.tooling</groupId>
    <artifactId>activemq-junit</artifactId>
    <version>5.16.2</version>
    <scope>test</scope>
</dependency>
<dependency>
    <groupId>junit</groupId>
    <artifactId>junit</artifactId>
    <version>4.13</version>
    <scope>test</scope>
</dependency>