本文共 1818 字,大约阅读时间需要 6 分钟。
//新建本地队列
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);
来自 “ ITPUB博客 ” ,链接:http://blog.itpub.net/14789789/viewspace-409928/,如需转载,请注明出处,否则将追究法律责任。
转载于:http://blog.itpub.net/14789789/viewspace-409928/