mq接出服務(wù)及相應(yīng)組件介紹

1、MQ功能：代替交易跟外部MQ 節(jié)點(diǎn)名稱說MQ MQ功能：代替交易跟外部MQ 節(jié)點(diǎn)名稱說MQ serviceid=2name=MQ接出服務(wù)MQ同步等待響應(yīng)返回函數(shù)如下：異步發(fā)送：*MQ同步等待響應(yīng)返回函數(shù)如下：異步發(fā)送：*paramidentifierMQ *paramidentifierMQpublic sic PyList mqOallSync(PyStringidentifier,PyString msgId, PyString correlationID,PyStringrequestPacket,egertimeout)MQ工廠（可不用設(shè)置技術(shù)組件設(shè)計：導(dǎo)入相關(guān)函數(shù) 技術(shù)組件設(shè)計：導(dǎo)入

2、相關(guān)函數(shù) 設(shè)計事例：*codinggbk*- 文件名稱P_MQConn.py 組件組: MQ 通訊測試創(chuàng)建時間2015-03-31fromAFALoggerimportLoggerError; from traceback import format_exc;from PyMQCall importallSync,def P_mqOallSync(identifier,msgID,correlationID,requestPacket, MQ消息關(guān)聯(lián)ID 創(chuàng)建時間2015-03-31public sic PyList mqOallAsync(PyStringidentifier,PyStrin

3、g PyStringcorrelationID,PyStringrequestPacket,PyPyString tradeID,PyStringerrorMsg)AddedbyAFAIDE (nottype(identifier)isreturn0PARAM參數(shù) (nottype(msgIDisreturn0PARAM參數(shù)AddedbyAFAIDE (nottype(identifier)isreturn0PARAM參數(shù) (nottype(msgIDisreturn0PARAM參數(shù)(nottype(correlationID)isreturn0PARAM參數(shù) correlationID類型不

4、匹配; (not type(requestPacket) is str):return0PARAM參數(shù) requestPacket類型不匹配(nottype(timeout)return0PARAM參數(shù) timeout類型不匹配returnrequestPacket,#AddbodyexceptException,e: AddedbyAFAIDE err=str(format_exc(); return0,EXCP00,Error:+defflag,tradeID,errorMsg): 創(chuàng)建時間2015-03-31AddedbyAFAIDE if(nottype(identifier)isre

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