1

我应该在客户端 WebsphereMQ 的哪里设置 MQMD 消息上下文?

MQQueueConnectionFactory mqConnectionFactory = new MQQueueConnectionFactory();
mqConnectionFactory.setHostName(producerProperties.getProperty("wmq.host"));
mqConnectionFactory.setPort(Integer.valueOf(producerProperties.getProperty("wmq.port")));
mqConnectionFactory.setTransportType(JMSC.MQJMS_TP_CLIENT_MQ_TCPIP);
mqConnectionFactory.setQueueManager(producerProperties.getProperty("wmq.manager"));
mqConnectionFactory.setChannel("MyChannel");

/**
 * Producer Section
 */
// Getting producer connection from the MQ server and starting it
Connection producerConnection = mqConnectionFactory.createConnection();
System.out.println("Going to start the producer connection...");
producerConnection.start();

// JMS messages are sent and received using a Session.
Session producerSession = producerConnection.createSession(false,
        Session.AUTO_ACKNOWLEDGE);
// Destination represents here our queue(testQ) on the MQ server.
Destination producerDestination = producerSession.createQueue(producerProperties.getProperty("wmq.queue.name"));

// MessageProducer is used for sending messages
MessageProducer producer = producerSession.createProducer(producerDestination1);
//create text message going to send

TextMessage sendingMessage = producerSession.createTextMessage("Hi Welcome");
sendingMessage.setJMSType(queueName);
System.out.println("Sending the message...");



//sending the message
producer.send(sendingMessage);
4

2 回答 2

1

请参阅示例程序。如果您安装到 Windows 上的默认位置,它位于:

"C:\Program Files (x86)\IBM\WebSphere MQ\tools\jms\samples\simple\SimpleMQMDWrite.java"

或者在 *NIX 平台上:

/opt/mqm/samp/jms/samples/simple/SimpleMQMDWrite.java
于 2013-04-11T03:15:24.543 回答
-1

转至 WMQ 信息中心并查找 JMSX* 和 JMS_IBM_* 选择器。

于 2013-04-11T14:50:31.443 回答