ibm websphere mq 5.3升級到csd05之后,提供了使用.net操作mq的類庫,安裝完成之后,會在mq的安裝目錄的bin文件夾下面多出一個amqmdnet.dll文件,把這個dll作為引用添加到你的.net工程中,你的.net程序中就可以操作ibm websphere mq。
我的mq是中文版的,操作系統是win2k003 sp1,無論是在隊列管理器,還是用代碼新建的隊列,都與我本機時間相差8小時,不曉得何解,哪位高人可以釋疑?
//新建本地隊列
pcfmessageagent agent = new pcfmessageagent("qm_janus");
pcfmessage request = new pcfmessage(cmqcfc.mqcmd_create_q);
request.addparameter(mqc.mqca_q_name, "test_queue");
request.addparameter(mqc.mqia_q_type, mqc.mqqt_local);
//request.addparameter(mqc.mqia_usage, mqc.mqus_transmission);
pcfmessage[] response = agent.send(request);
//刪除隊列
pcfmessageagent agent = new pcfmessageagent("qm_janus");
pcfmessage request = new pcfmessage(cmqcfc.mqcmd_delete_q);
request.addparameter(mqc.mqca_q_name, "test_queue");
pcfmessage[] response = agent.send(request);
//從隊列中讀取消息
mqqueuemanager qmgr = new mqqueuemanager("qm_janus");
mqqueue queue = qmgr.accessqueue("postcard", mqc.mqoo_input_as_q_def | mqc.mqoo_fail_if_quiescing);
mqgetmessageoptions gmo = new mqgetmessageoptions();
gmo.options = mqc.mqgmo_wait;
gmo.waitinterval = 1000;
gmo.matchoptions = mqc.mqmo_none;
mqmessage message = new mqmessage();
queue.get(message);
//向隊列寫消息
mqqueuemanager qmgr = new mqqueuemanager("qm_janus");
mqqueue queue = qmgr.accessqueue("postcard", mqc.mqoo_output);
mqmessage message = new mqmessage();
message.writestring("message body");
queue.put(message);
//枚舉所有隊列
pcfmessageagent agent = new pcfmessageagent("qm_janus");
pcfmessage request = new pcfmessage(cmqcfc.mqcmd_inquire_q_names);
request.addparameter(mqc.mqca_q_name, "*");
pcfmessage[] response = agent.send(request);
string[] names = response[0].getstringlistparametervalue(cmqcfc.mqcacf_q_names);
新聞熱點
疑難解答