国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 開發 > 綜合 > 正文

使用c#操作IBM WebSphere MQ

2024-07-21 02:28:37
字體:
來源:轉載
供稿:網友


    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);

發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 叙永县| 浦县| 西宁市| 东乌珠穆沁旗| 雅江县| 边坝县| 永济市| 保山市| 罗定市| 文化| 新昌县| 舞钢市| 政和县| 伊通| 永和县| 河津市| 石屏县| 东丰县| 延吉市| 泗水县| 乌拉特后旗| 苍南县| 镶黄旗| 通江县| 永和县| 余姚市| 绵阳市| 宜兰县| 牡丹江市| 永丰县| 呈贡县| 读书| 西贡区| 全南县| 左云县| 皋兰县| 抚远县| 乡城县| 西畴县| 阳曲县| 桦南县|