mq接出服务及相应组件介绍

1、MQ功能：代替交易跟外部MQ 节点名称说MQ MQ功能：代替交易跟外部MQ 节点名称说MQ serviceid=2name=MQ接出服务MQ同步等待响应返回函数如下：异步发送：*MQ同步等待响应返回函数如下：异步发送：*paramidentifierMQ *paramidentifierMQpublic sic PyList mqOallSync(PyStringidentifier,PyString msgId, PyString correlationID,PyStringrequestPacket,egertimeout)MQ工厂（可不用设置技术组件设计：导入相关函数 技术组件设计：导入

2、相关函数 设计事例：*codinggbk*- 文件名称P_MQConn.py 组件组: MQ 通讯测试创建时间2015-03-31fromAFALoggerimportLoggerError; from traceback import format_exc;from PyMQCall importallSync,def P_mqOallSync(identifier,msgID,correlationID,requestPacket, MQ消息关联ID 创建时间2015-03-31public sic PyList mqOallAsync(PyStringidentifier,PyStrin

3、g PyStringcorrelationID,PyStringrequestPacket,PyPyString tradeID,PyStringerrorMsg)AddedbyAFAIDE (nottype(identifier)isreturn0PARAM参数 (nottype(msgIDisreturn0PARAM参数AddedbyAFAIDE (nottype(identifier)isreturn0PARAM参数 (nottype(msgIDisreturn0PARAM参数(nottype(correlationID)isreturn0PARAM参数 correlationID类型不

4、匹配; (not type(requestPacket) is str):return0PARAM参数 requestPacket类型不匹配(nottype(timeout)return0PARAM参数 timeout类型不匹配returnrequestPacket,#AddbodyexceptException,e: AddedbyAFAIDE err=str(format_exc(); return0,EXCP00,Error:+defflag,tradeID,errorMsg): 创建时间2015-03-31AddedbyAFAIDE if(nottype(identifier)isre

5、turn0PARAM参数 identifier类型不匹配; if (not type(msgID) is str):return0PARAM参数 msgID类型不匹配; if (not type(correlationID) is str):return0PARAM参数 correlationID类型不匹配; if (not type(requestPacket) is str):return0,PARAM,参数 requestPacket类型不匹配; if (not type(flag) isreturn0PARAM参数 flag类型不匹配; if (not type(tradeID) is str):return0PARAM参数 tradeID类型不匹配; if (not type(errorMsg) is str):return 0, PARAM, 参数 errorMsg 类型不匹配; return mqOallAsync(identifier,msgID,correlationID,requestPacket,flag,tradeID,errorMsg); #A