 |
|
| Configuring WebSphere MQ |
Sample Trigger Programs
| mqclient.sas |
The following program runs on the Windows XP machine and requests a data set:
data _null_; length msg $ 200; length qid2 tid rc 8; length map $80; length recv1 $50; length event $10; length rpname $256; length type $8; length qual1 qual2 $40; libname out '.'; tid=0; rc=0; put '----'; put 'Call INIT'; CALL INIT(tid, 'MQSERIES', rc); if rc ^= 0 then do; put 'INIT: failed'; msg = sysmsg(); put msg; end; else put 'INIT: succeeded'; rc=0; qid=0; put '----'; put 'Call OPENQUEUE to open the response queue'; CALL OPENQUEUE(qid, tid, 'XPQMGR:REPLY', 'fetch', rc, "POLL(TIMEOUT=20)"); if rc ^= 0 then do; put 'OPENQUEUE: failed'; msg = sysmsg(); put msg; end; else put 'OPENQUEUE: succeeded'; rc=0; qid2=0; put 'Call OPENQUEUE to open the request queue on qid2'; CALL OPENQUEUE(qid2, tid, 'XPQMGR:AIX.TRIGQUEUE', 'DELIVERY', rc, "POLL(Timeout=15)"); if rc ^= 0 then do; put 'OPENQUEUE: failed'; msg = sysmsg(); put msg; end; else put 'OPENQUEUE: succeeded'; rc=0; put '----'; put 'Call SETMAP'; CALL SETMAP('mqclientmap', 'REGISTRY', rc, 'CHAR,,50'); if rc ^= 0 then do; put 'SETMAP: failed'; msg = sysmsg(); put msg; end; else put 'SETMAP: succeeded'; parm1="calories"; put '---- Send a message to the request queue qid requesting the specified data set -----'; put 'Call SENDMESSAGE'; call sendmessage(qid2,rc,"map, respqueue", "mqclientmap","R64:D8650",parm1); if rc ^= 0 then do; put 'send message failed: '; msg=sysmsg(); put msg; end; else put 'send message succeeded'; slept = sleep(1); rc = 0; put '---- receive a data set from the reply queue ----'; put 'Call RECEIVEMESSAGE'; map = "mqclientmap"; call receivemessage(qid, rc, event, attchflg,"map", map, recv1); put 'response queue =' rpname; put 'qid =' qid; put 'event = ' event; put 'attchflg =' attchflg; if rc ^= 0 then do; put 'receive message failed: '; msg=sysmsg(); put msg; end; else do; put 'receive message succeeded'; put "map =" map; put "recv1 =" recv1; end; if event eq 'DELIVERY' then do; put 'Message has been delivered'; if attchflg = 1 then do; put '---- check for attachments ----'; call getattachment(qid, lastflag, attachid, type, qual1, qual2, rc); if rc ^= 0 then do; put 'get attachment failed: '; msg=sysmsg(); put msg; end; else put 'get attachment succeeded'; if type="DATASET" then do; put '--- accept attachment into a data set ---'; put "qual2 = " qual2; call acceptattachment(qid, attachid, "out", qual2, rc); if rc ^= 0 then do; put 'accept DATASET failed: '; msg=sysmsg(); put msg; end; else put 'accept DATASET succeeded'; end; end; end; rc=0; put '----'; put 'Call CLOSEQUEUE for queue1'; CALL CLOSEQUEUE(qid, rc); if rc ^= 0 then do; put 'CLOSEQUEUE: failed'; msg = sysmsg(); put msg; end; else put 'CLOSEQUEUE: succeeded'; rc=0; put '----'; put 'Call CLOSEQUEUE for queue2'; CALL CLOSEQUEUE(qid2, rc); if rc ^= 0 then do; put 'CLOSEQUEUE: failed'; msg = sysmsg(); put msg; end; else put 'CLOSEQUEUE: succeeded'; rc=0; put '----'; put 'Call TERM'; CALL TERM(tid, rc); if rc ^= 0 then do; put 'TERM: failed'; msg = sysmsg(); put msg; end; else put 'TERM: succeeded'; run;
| mqserver.sas |
The following program runs on the AIX machine and returns a data set:
data calories; input item $ 1 - 16 calories 18-20 ; datalines; ground beef 230 hot dog 100 banana 100 broccoli 45 skim milk 50 ; data _null_; length msg $ 200; length qid qid2 tid rc 8; length map $80; length recv1 $50; length attachname $21; length event $10; length rpname $256; tid=0; rc=0; put '----'; put 'Call INIT'; CALL INIT(tid, 'MQSERIES-C', rc); if rc ^= 0 then do; put 'INIT: failed'; msg = sysmsg(); put msg; end; else put 'INIT: succeeded'; rc=0; qid=0; put '----'; put 'Call OPENQUEUE for queue1'; CALL OPENQUEUE(qid, tid, 'AIX:TRIGQUEUE', 'fetch', rc, "POLL(Timeout=10)"); if rc ^= 0 then do; put 'OPENQUEUE: failed'; msg = sysmsg(); put msg; end; else put 'OPENQUEUE: succeeded'; rc=0; put '----'; put 'Call SETMAP'; CALL SETMAP('mqservermap', 'REGISTRY', rc, 'CHAR,,50'); if rc ^= 0 then do; put 'SETMAP: failed'; msg = sysmsg(); put msg; end; else put 'SETMAP: succeeded'; rc = 0; put '---- receive a message from the remote queue ----'; put 'Call RECEIVEMESSAGE'; map = "mqservermap"; rpname=' '; call receivemessage(qid, rc, event, attchflg,"map, respqueue", map, rpname, recv1); put 'recv1 =' recv1; put 'response queue =' rpname; put 'qid =' qid; put 'event = ' event; put 'attchflg =' attchflg; if rc ^= 0 then do; put 'receive message failed: '; msg=sysmsg(); put msg; end; else do; put 'receive message succeeded'; put map; end; if event eq 'DELIVERY' then do; rc = 0; qid2=0; put '---- open the response queue qid2 ----'; put 'Call OPENQUEUE for queue2'; CALL OPENQUEUE(qid2, tid, rpname, 'delivery', rc, "POLL(Timeout=15)"); if rc ^= 0 then do; put 'OPENQUEUE: failed'; msg = sysmsg(); put msg; end; else put 'OPENQUEUE: succeeded'; put 'rpname =' rpname; put '---- send the requested data set to the response queue ----'; put 'Call SENDMESSAGE'; attachname = 'dataset,work,' || recv1; put "attachname = " attachname; call sendmessage(qid2,rc,"map, attachlist", "mqservermap",attachname, recv1 ); if rc ^= 0 then do; put 'send message failed: '; msg=sysmsg(); put msg; end; else put 'send message succeeded'; rc=0; put '----'; put 'Call CLOSEQUEUE for queue2'; CALL CLOSEQUEUE(qid2, rc); if rc ^= 0 then do; put 'CLOSEQUEUE: failed'; msg = sysmsg(); put msg; end; else put 'CLOSEQUEUE: succeeded'; end; rc=0; put '----'; put 'Call CLOSEQUEUE for queue1'; CALL CLOSEQUEUE(qid, rc); if rc ^= 0 then do; put 'CLOSEQUEUE: failed'; msg = sysmsg(); put msg; end; else put 'CLOSEQUEUE: succeeded'; rc=0; put '----'; put 'Call TERM'; CALL TERM(tid, rc); if rc ^= 0 then do; put 'TERM: failed'; msg = sysmsg(); put msg; end; else put 'TERM: succeeded'; run;
|
|
Copyright © 2010 by SAS Institute Inc., Cary, NC, USA. All rights reserved.