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

首頁 > 學(xué)院 > 開發(fā)設(shè)計 > 正文

使用c#操作IBM WebSphere MQ

2019-11-18 17:00:21
字體:
供稿:網(wǎng)友

    IBM WebSphere MQ 5.3升級到CSD05之后,提供了使用.net操作MQ的類庫,安裝完成之后,會在MQ的安裝目錄的bin文件夾下面多出一個amqmdnet.dll文件,把這個DLL作為引用添加到你的.net工程中,你的.net程序中就可以操作IBM WebSphere MQ。
    我的MQ是中文版的,操作系統(tǒng)是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);

 http://m.survivalescaperooms.com/janus1999/archive/2006/09/11/501133.html


發(fā)表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發(fā)表
主站蜘蛛池模板: 铜梁县| 温州市| 阿尔山市| 慈利县| 宝清县| 寿宁县| 榕江县| 平武县| 博客| 东乡县| 收藏| 汉沽区| 古蔺县| 华亭县| 左云县| 合肥市| 凤凰县| 娱乐| 涟水县| 渝中区| 兴仁县| 涿州市| 什邡市| 临桂县| 白玉县| 三穗县| 金秀| 长汀县| 娄底市| 容城县| 阿拉善盟| 临城县| 临邑县| 竹北市| 安义县| 宝清县| 木里| 天柱县| 太仆寺旗| 监利县| 新和县|