MQ 连接问题
admin 发表于 2010-12-03 | 来源:互联网 | 阅读:

MQSERVER = "DC/TCP/192.168.100.228(2000)"
MQCCSID = 819
以上都是服务器端已经配置好了地
DC是服务器连接通道
192.168.100.228(2000)是服务器IP和侦听器端口
代码如下:
OLEObject MQS, QM, Q, MW, MR, PO, GO
String ls_mqmgr, ls_s
integer i
MQS = CREATE OLEObject // MQSeries Session
QM = CREATE OLEObject // QueueManager
Q = CREATE OLEObject // Queue
MW = CREATE OLEObject // Message Written
MR = CREATE OLEObject // Message Read
PO = CREATE OLEOBject // Put options
GO = CREATE OLEOBject // Get options
I = MQS.ConnectToNewObject("MQAX200.MqSession") // see note 1
MessageBox("",string (i))
ls_mqmgr = "0326GSB" // see note 2
QM = MQS.AccessQueueManager(ls_mqmgr)
Q = QM.AccessQueue("032601B01",16) // see note 3
// WRITE
MW = MQS.AccessMessage
MW.MessageData = http://topic.csdn.net/u/20101130/15/"HELLO WORLD " + string(cpu())
PO = MQS.AccessPutMessageOptions()
Q.Put( MW, PO)
// READ
MR = MQS.AccessMessage()
MR.MessageIdHex = MR.MessageIdHex // see note 4
GO = MQS.AccessGetMessageOptions()
Q.Get( MR, GO)
ls_s = MR.ReadString(MR.MessageLength)
MessageBox("MQSeries", ls_s)
Q.close()
QM.disconnect()

老是 提醒 error calling external object function AccessQueueManager 忘帮忙解决
死等啊。

已经有2 个评论
  1. dbb123 说:

    AccessQueueManager 没声明? 或者声明有错误!

  2. weiwei 说:

    恢复是你地ConnectToNewObject没有成功导致地,你判断一下返回值,如果成功再向下执行

我要评论

评论功能因故关闭!

请加入我们的QQ群一起参与讨论:群号59400482(500人超级群)


返回首页 | 关于我们 | 联系我们 | 广告合作 | 网站地图 | 友情链接 | 版权声明