这段代码将消息发送到Q。MQEnvironment静态值被设置。但是,在管理器中并未引用MQEnvironment。那么,如何提供属性(主机名、通道、端口、CCSID)以连接到MQ?
MQEnvironment.hostname ="10.XX.XXX.XX";
MQEnvironment.channel = "SYSTEM.DEF.SVRCONN";
MQEnvironment.port = 1415;
MQEnvironment.CCSID = 819;
System.out.println("connecting MQQueueManager...");
try {
MQQueueManager manager = new MQQueueManager("SXX");
MQQueue queue = null;
int openOptions = MQC.MQOO_OUTPUT; //MQC.MQOO_INPUT_AS_Q_DEF |
queue = manager.accessQueue("Q_NAME",
openOptions,
null, null, null);
// send message
MQMessage sendMessage = new MQMessage();
sendMessage.writeObject("TEST MESSAGE@@@@@@@@@@@@@@@@@");
MQPutMessageOptions pmo = new MQPutMessageOptions();
queue.put(sendMessage, pmo);