创建MQ队列管理器报2025错
// 对mq的连接使用连接池
MQEnvironment.addConnectionPoolToken();
Hashtable table = new Hashtable();
table.put(MQC.HOST_NAME_PROPERTY, this.ip);
table.put(MQC.PORT_PROPERTY, this.port);
table.put(MQC.CHANNEL_PROPERTY, this.channel);
table.put(MQC.CCSID_PROPERTY, this.ccsid);
table.put(MQC.USER_ID_PROPERTY, this.mqUser);
table.put(MQC.PASSWORD_PROPERTY, this.mqPasswd);
// 此处已经使用了连接池,不会每次都重新建立连接
MQQueueManager mqManager = null;
try {
mqManager = new MQQueueManager(this.mqName, table);
} catch (MQException e) {
log.error("create mq listening fail", e);
}