MQ JMS 简单下载消息

Question

我正在尝试实现一个从 MQ 服务器下载消息的简单客户端。 MQ 服务器已经存在，我无权访问它。 在我在网上找到的所有示例中，都使用了“createQueue()”方法，如下所示：

  MQQueueConnectionFactory cf = new MQQueueConnectionFactory();

  // Config
  cf.setHostName("localhost");
  cf.setPort(1414);
  cf.setTransportType(JMSC.MQJMS_TP_CLIENT_MQ_TCPIP);
  cf.setQueueManager("QM_thinkpad");
  cf.setChannel("SYSTEM.DEF.SVRCONN");

  MQQueueConnection connection = (MQQueueConnection) cf.createQueueConnection();
  MQQueueSession session = (MQQueueSession) connection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);
  MQQueue queue = (MQQueue) session.createQueue("queue:///Q1");
  MQQueueSender sender =  (MQQueueSender) session.createSender(queue);
  MQQueueReceiver receiver = (MQQueueReceiver) session.createReceiver(queue);
  ...
  JMSMessage receivedMessage = (JMSMessage) receiver.receive(10000);

但是，就我而言，我不想创建队列，我只想使用现有的远程队列。还是我错了？我该怎么办？

Answer 1

createQueue() 实际上并不创建 MQ 队列。它只是为 queue 创建一个标识符，可用于后续调用，例如在您的情况下为 createReceiver。