Chinaunix首页 | 论坛 | 博客
  • 博客访问: 1934605
  • 博文数量: 389
  • 博客积分: 7877
  • 博客等级: 少将
  • 技术积分: 4531
  • 用 户 组: 普通用户
  • 注册时间: 2007-12-10 14:02
文章分类

全部博文(389)

文章存档

2024年(1)

2022年(1)

2021年(1)

2020年(1)

2019年(1)

2018年(3)

2017年(6)

2016年(4)

2015年(8)

2014年(15)

2013年(31)

2012年(19)

2011年(47)

2010年(33)

2009年(105)

2008年(109)

2007年(4)

分类:

2008-12-04 08:33:20

因为应用的需要,我需要再建一个QMGR暂时叫B, 它要去连我们之前已有的一个QMGR A, 在A上面建remote queue 而这个queue指向的就是B上的local queue, 程式将消息放入A上的remote queue 这个时候消息就通过传输队列到了B上的local queue,而这支queue定义了trigger process, 触发程式接受消息并做出处理动作,因为应用那边的程式还没有完成我自己先用一个脚本来代替这支trigger process, 脚本的作用就是在/tmp下面生成一个文件,结果我在测试的时候怎么也没有实现这个功能,而当我把同样的测试放到一个已有的环境测试时是可以执行的,后面我更改了local queue的INITQ的值,换成这个环境原有的结果就好了。后来折磨了好久,还是一个新人应用那边的提醒我trigger monitor没有启动,我们这边的trigger monitor程式是自己开发的并没有使用MQ自带的,还是有些基础概念不够清晰!记住这次教训...

QMGR B的定义:

DEFINE QREMOTE ('SHARE.REPLY1')     PUT(ENABLED)          DEFPRTY(0)          DEFPSIST(NO)          SCOPE(QMGR)          XMITQ('TO.A')        RNAME('SHARE.REPLY')        RQMNAME('A')        CLUSTER(' ')        CLUSNL(' ')        DEFBIND(OPEN)          REPLACE

DEFINE QLOCAL ('LQUEUE')  USAGE(NORMAL)          TRIGGER          TRIGTYPE(FIRST)          TRIGDPTH(1)          TRIGMPRI(0)          TRIGDATA(' ')        PROCESS('TRG.LQUEUE')        INITQ('INITQ_LS')        RETINTVL(999999999)          BOTHRESH(0)          BOQNAME(' ')        QDEPTHHI(80)          QDEPTHLO(20)          QDPMAXEV(ENABLED)          QDPHIEV(DISABLED)          QDPLOEV(DISABLED)          QSVCINT(999999999)          QSVCIEV(NONE)          DISTL(NO)          NPMCLASS(NORMAL)          CLUSTER(' ')        CLUSNL(' ')        DEFBIND(OPEN)          REPLACE


DEFINE QLOCAL ('TO.A')  USAGE(XMITQ)  TRIGGER   TRIGTYPE(FIRST)  TRIGDPTH(1) TRIGMPRI(0) TRIGDATA('B.TO.A')  INITQ('SYSTEM.CHANNEL.INITQ')   REPLACE


DEFINE CHANNEL ('A.TO.B') CHLTYPE(RCVR)  TRPTYPE(TCP) REPLACE


DEFINE CHANNEL ('B.TO.A') CHLTYPE(SDR)        TRPTYPE(TCP)  CONNAME('192.168.1.1(62001)')  XMITQ('TO.A') REPLACE

DEFINE CHANNEL ('B') CHLTYPE(SVRCONN)        TRPTYPE(TCP)  MCAUSER('mqm')  REPLACE

DEFINE PROCESS ('TRG.LQUEUE')        DESCR(' ')        APPLTYPE(UNIX)          APPLICID('/usr/exe/lqueue')        USERDATA(' ')        ENVRDATA('2')        REPLACE


QMGR A的定义:

DEFINE QLOCAL ('SHARE.REPLY')     PUT(ENABLED)        DEFPRTY(0)        DEFPSIST(NO)        SCOPE(QMGR)        GET(ENABLED)         MAXDEPTH(5000)        MAXMSGL(4194304)        SHARE        DEFSOPT(SHARED)        MSGDLVSQ(PRIORITY)        HARDENBO        USAGE(NORMAL)        NOTRIGGER        TRIGTYPE(FIRST)        TRIGDPTH(1)        TRIGMPRI(0)        TRIGDATA(' ')        PROCESS(' ')        INITQ(' ')        RETINTVL(999999999)        BOTHRESH(0)        BOQNAME(' ')        QDEPTHHI(80)        QDEPTHLO(20)        QDPMAXEV(ENABLED)        QDPHIEV(DISABLED)        QDPLOEV(DISABLED)        QSVCINT(999999999)        QSVCIEV(NONE)        DISTL(NO)        NPMCLASS(NORMAL)        CLUSTER(' ')        CLUSNL(' ')        DEFBIND(OPEN)        REPLACE


DEFINE QLOCAL ('TO.B')   DESCR(' ')        PUT(ENABLED)        DEFPRTY(0)        DEFPSIST(NO)        SCOPE(QMGR)        GET(DISABLED)        MAXDEPTH(5000)        MAXMSGL(4194304)        SHARE        DEFSOPT(SHARED)        MSGDLVSQ(PRIORITY)        HARDENBO        USAGE(XMITQ)        NOTRIGGER        TRIGTYPE(EVERY)        TRIGDPTH(1)        TRIGMPRI(0)        TRIGDATA(' ')        PROCESS(' ')        INITQ(' ')        RETINTVL(999999999)        BOTHRESH(0)        BOQNAME(' ')        QDEPTHHI(80)        QDEPTHLO(20)        QDPMAXEV(ENABLED)        QDPHIEV(DISABLED)        QDPLOEV(DISABLED)        QSVCINT(999999999)        QSVCIEV(NONE)        DISTL(YES)        NPMCLASS(NORMAL)        CLUSTER(' ')        CLUSNL(' ')        DEFBIND(OPEN)        REPLACE


DEFINE QREMOTE ('LQUEUE')    DESCR(' ')        PUT(ENABLED)        DEFPRTY(0)        DEFPSIST(NO)        SCOPE(QMGR)        XMITQ('TO.B')        RNAME('LQUEUE')        RQMNAME('B')        CLUSTER(' ')        CLUSNL(' ')        DEFBIND(OPEN)        REPLACE


DEFINE CHANNEL ('A.TO.B') CHLTYPE(SDR)        TRPTYPE(TCP)        BATCHINT(0)        BATCHHB(0)        BATCHSZ(50)        CONNAME('192.168.1.1(62008)')        LOCLADDR(' ')        CONVERT(NO)        DESCR(' ')        DISCINT(999999)        HBINT(300)        LONGRTY(999999999)        LONGTMR(1200)        SHORTRTY(10)        SHORTTMR(60)        MAXMSGL(4194304)        MCATYPE(PROCESS)        MCAUSER(' ')        MSGDATA(' ')        MSGEXIT(' ')        NPMSPEED(FAST)        RCVDATA(' ')        RCVEXIT(' ')        SCYDATA(' ')        SCYEXIT(' ')        SENDDATA(' ')        SENDEXIT(' ')        SEQWRAP(999999999)        USERID(' ')        XMITQ('TO.B')        SSLCIPH(' ')        SSLPEER(' ')         KAINT(AUTO)        REPLACE


DEFINE CHANNEL ('B.TO.A') CHLTYPE(RCVR)        TRPTYPE(TCP)        BATCHSZ(50)        DESCR(' ')        HBINT(300)        MAXMSGL(4194304)        MCAUSER(' ')        MRDATA(' ')        MREXIT(' ')        MRRTY(10)        MRTMR(1000)        MSGDATA(' ')        MSGEXIT(' ')        NPMSPEED(FAST)        PUTAUT(DEF)        RCVDATA(' ')        RCVEXIT(' ')        SCYDATA(' ')        SCYEXIT(' ')        SENDDATA(' ')        SENDEXIT(' ')        SEQWRAP(999999999)        SSLCAUTH(REQUIRED)        SSLCIPH(' ')        SSLPEER(' ')         KAINT(AUTO)        REPLACE

阅读(2634) | 评论(0) | 转发(0) |
给主人留下些什么吧!~~