{"id":6363,"date":"2016-10-12T18:33:14","date_gmt":"2016-10-12T10:33:14","guid":{"rendered":"http:\/\/rmohan.com\/?p=6363"},"modified":"2016-10-12T18:47:04","modified_gmt":"2016-10-12T10:47:04","slug":"mq-messaging","status":"publish","type":"post","link":"https:\/\/mohan.sg\/?p=6363","title":{"rendered":"MQ messaging"},"content":{"rendered":"

This example is a simple demonstration for understanding how MQ transfer messages between two queue managers and the minimum required MQ components for the same.
\nKindly Share\/Like\/Follow<\/strong> the page if you like this article.<\/span><\/p>\n

Below are the steps involved in this example.Source queue manager<\/strong>
\n——————————<\/strong>
\n1.) Create source queue manager.
\n2.) Start source queue manager.
\n3.) Connect to source queue manager using runmqsc command.
\n4.) Create a listener in source queue manager.
\n5.) Create transmission queue in source queue manager.
\n6.) Create a remote queue in source queue manager.
\n7.) Create a sender channel in source queue manager.
\n8.) Quit MQSC<\/span><\/p>\n

Destination queue manager<\/strong>
\n————————————-
\n1.) Create destination queue manager.
\n2.) Start destination queue manager.
\n3.) Connect to destination queue manager using runmqsc command.
\n4.) Create a listener in destination queue manager.
\n5.) Create a receiver channel in destination queue manager.
\n6.) Create a local queue in destination queue manager.
\n7.) Quit MQSC.<\/p>\n

Restart Source & Destination Queue Managers.<\/strong>
\n————————————————————-
\n1.) Stop source queue manager.
\n2.) Stop destination queue manager.
\n3.) Start source queue manager.
\n3.a.) Make sure that the listener started for source queue manager , if not start the listener.
\n4.) start destination queue manager.
\n4.a.) Make sure that the listener started for destination queue manager, if not start the listener.
\n5.) Connect to source queue manager using runmqsc command.
\n6.) Start sender channel on source queue manager.
\n7.) Check the channel status of both queue managers and make sure that both channels are running..
\n8.) Quit MQSC.<\/p>\n

Testing<\/strong>
\n———-
\n1.) Put a message in remote queue of source queue manager.
\n2.) browse\/get messages from local queue of destination queue manager.<\/p>\n

Now let us implement above steps in a test server.<\/p>\n

A.) Source queue manager (MqM1<\/em>)<\/strong>
\n———————————————<\/p>\n

1.) <\/em>Create source queue manager MqM1<\/em><\/strong>
\n
\n[root@myhost mqm]# crtmqm MqM1<\/em>
\nWebSphere MQ queue manager created.<\/em>
\nDirectory ‘\/var\/mqm\/qmgrs\/MqM1’ created.<\/em>
\nCreating or replacing default objects for MqM1.<\/em>
\nDefault objects statistics : 65 created. 0 replaced. 0 failed.<\/em>
\nCompleting setup.<\/em>
\nSetup completed.<\/em><\/span><\/p>\n

2.)<\/strong> S<\/strong><\/em>tart source queue manager MqM1<\/em><\/strong>
\n[root@myhost mqm]# strmqm MqM1<\/em>
\nWebSphere MQ queue manager ‘MqM1’ starting.<\/em>
\n5 log records accessed on queue manager ‘MqM1’ during the log replay phase.<\/em>
\nLog replay for queue manager ‘MqM1’ complete.<\/em>
\nTransaction manager state recovered for queue manager ‘MqM1’.<\/em>
\nWebSphere MQ queue manager ‘MqM1’ started.<\/em><\/span><\/p>\n

3.) <\/em>Connect to source queue manager MqM1<\/em>\u00a0using runmqsc command.<\/strong>
\n[root@myhost mqm]# runmqsc MqM1<\/em>
\n5724-H72 (C) Copyright IBM Corp. 1994, 2009. ALL RIGHTS RESERVED.<\/em>
\nStarting MQSC for queue manager MqM1.<\/em><\/p>\n

4.) <\/em>Create a listener in source queue manager MqM1<\/em>.<\/strong><\/p>\n

define listener (‘MqM1.LSNR’) TRPTYPE( TCP ) PORT (1486)<\/em>
\n1 : define listener (‘MqM1.LSNR’) TRPTYPE( TCP ) PORT (1486)<\/em>
\nAMQ8626: WebSphere MQ listener created.<\/em><\/p>\n

5.) <\/em>Create transmition queue in source queue manager.<\/strong>
\ndefine qlocal (‘TR1.MqM1.Q1’) USAGE (XMITQ)<\/em>
\n2 : define qlocal (‘TR1.MqM1.Q1’) USAGE (XMITQ)<\/em>
\nAMQ8006: WebSphere MQ queue created.<\/em><\/p>\n

6.) <\/em>Create a remote queue in source queue manager.<\/strong><\/p>\n

define qremote (‘RMT.MqM1.Q1’) XMITQ (‘TR1.MqM1.Q1’) RQMNAME(‘MqM2’) RNAME(‘LOC.MqM2.Q1’)<\/em>
\n3 : define qremote (‘RMT.MqM1.Q1’) XMITQ (‘TR1.MqM1.Q1’) RQMNAME(MqM2) RNAME(‘LOC.MqM2.Q1’)<\/em>
\nAMQ8006: WebSphere MQ queue created.<\/em><\/span><\/p>\n

Points to be noted:-
\nXMITQ :- Should be the same name mentioned while creating transmission queue in step A.5
\nRQMNAME :- Specify the same name mentioned while creating destination queue manager B.1<\/span><\/p>\n

7.) <\/em>Create a sender channel in source queue manager.<\/strong>
\ndefine channel (‘MqM1.SNDR’) CHLTYPE(SDR) CONNAME(‘localhost(1487)’) XMITQ(‘TR1.MqM1.Q1’)<\/em>
\n4 : define channel (‘MqM1.SNDR’) CHLTYPE(SDR) CONNAME(‘localhost(1487)’) XMITQ(‘TR1.MqM1.Q1’)<\/em>
\nAMQ8014: WebSphere MQ channel created.<\/em>
\nPoints to be noted:-<\/em><\/span><\/p>\n

XMITQ :- Should be the same name mentioned while creating transmission queue in step A.5<\/span>
\nCONNAME:-<\/em> Specify the hostname\/ipaddress and port number of the remote queue manager<\/span><\/p>\n

8.) <\/em>Quit MQSC<\/strong><\/p>\n

end<\/em><\/p>\n

B.) Destination queue manager (MqM2)<\/strong>
\n—————————————————-<\/p>\n

1.)<\/strong> <\/em>Create destination queue manager MqM2<\/em><\/strong>
\n[root@myhost mqm]# crtmqm MqM2<\/em>
\nWebSphere MQ queue manager created.<\/em>
\nDirectory ‘\/var\/mqm\/qmgrs\/MqM2’ created.<\/em>
\nCreating or replacing default objects for MqM2.<\/em>
\nDefault objects statistics : 65 created. 0 replaced. 0 failed.<\/em>
\nCompleting setup.<\/em>
\nSetup completed.<\/em><\/p>\n

2.) <\/em>Start destination queue manager MqM2<\/em><\/strong>
\n[root@myhost mqm]# strmqm MqM2<\/em>
\nWebSphere MQ queue manager ‘MqM2’ starting.<\/em>
\n5 log records accessed on queue manager ‘MqM2’ during the log replay phase.<\/em>
\nLog replay for queue manager ‘MqM2’ complete.<\/em>
\nTransaction manager state recovered for queue manager ‘MqM2’.<\/em>
\nWebSphere MQ queue manager ‘MqM2’ started<\/em>.<\/p>\n

3.) <\/em>Connect to destination queue manager MqM2 <\/em>using runmqsc command.<\/strong><\/p>\n

[root@myhost mqm]# runmqsc MqM2<\/em>
\n5724-H72 (C) Copyright IBM Corp. 1994, 2009. ALL RIGHTS RESERVED.<\/em>
\nStarting MQSC for queue manager MqM2.<\/em><\/p>\n

4.) <\/em>Create a listener in destination queue manager.<\/strong>
\ndefine listener (‘MqM2.LSNR’) TRPTYPE( TCP ) PORT (1487)<\/em>
\n1 : define listener (‘MqM2.LSNR’) TRPTYPE( TCP ) PORT (1487)<\/em>
\nAMQ8626: WebSphere MQ listener created.<\/em><\/p>\n

5.) <\/em>Create a receiver channel in destination queue manager.<\/strong>
\ndefine channel (‘MqM1.SNDR’) CHLTYPE(RCVR)<\/em>
\n2 : define channel (‘MqM1.SNDR’) CHLTYPE(RCVR)<\/em>
\nAMQ8014: WebSphere MQ channel created.<\/em><\/p>\n

Points to be noted:- <\/em>
\nChannel name should be the same name mentioned while creating channel in step A.7<\/p>\n

6.)\u00a0<\/em><\/strong> Create a local queue in destination queue manager.<\/strong>
\ndefine qlocal (‘LOC.MqM2.Q1’)<\/em>
\n3 : define qlocal (‘LOC.MqM2.Q1’)<\/em>
\nAMQ8006: WebSphere MQ queue created.<\/em><\/p>\n

7.) <\/em>Quit MQSC<\/strong><\/p>\n

end<\/em><\/p>\n

C.) Restart Source and Destination Queue Managers<\/strong>
\n——————————————————————–<\/strong><\/p>\n

1.) <\/em>Stop source queue manager MqM1.<\/em><\/strong>
\n[root@myhost mqm]# endmqm MqM1<\/em>
\nQuiesce request accepted. The queue manager will stop when all outstanding work is complete.<\/em><\/p>\n

2.) <\/em>Stop destination queue manager MqM2.<\/em><\/strong><\/p>\n

[root@myhost mqm]# endmqm MqM2<\/em>
\nQuiesce request accepted. The queue manager will stop when all outstanding work is complete.<\/em><\/p>\n

3.) <\/em>Start source queue manager MqM1<\/em>.<\/strong>
\n[root@myhost mqm]# strmqm MqM1<\/em>
\nWebSphere MQ queue manager ‘MqM1’ starting.<\/em>
\n5 log records accessed on queue manager ‘MqM1’ during the log replay phase.<\/em>
\nLog replay for queue manager ‘MqM1’ complete.<\/em>
\nTransaction manager state recovered for queue manager ‘MqM1’.<\/em>
\nWebSphere MQ queue manager ‘MqM1’ started<\/em>.<\/p>\n

4.) <\/em>Start destination queue manager MqM2<\/em><\/strong><\/p>\n

[root@myhost mqm]# strmqm MqM2<\/em>
\nWebSphere MQ queue manager ‘MqM2’ starting.<\/em>
\n5 log records accessed on queue manager ‘MqM2’ during the log replay phase.<\/em>
\nLog replay for queue manager ‘MqM2’ complete.<\/em>
\nTransaction manager state recovered for queue manager ‘MqM2’.<\/em>
\nWebSphere MQ queue manager ‘MqM2’ started.<\/em><\/p>\n

5.) <\/em>Connect to source queue manager MqM1 <\/em>using runmqsc command.
\n\u00a0<\/em><\/strong>
\n[root@myhost mqm]# runmqsc MqM1<\/em>
\n5724-H72 (C) Copyright IBM Corp. 1994, 2009. ALL RIGHTS RESERVED.<\/em>
\nStarting MQSC for queue manager MqM1.<\/em><\/p>\n

6.) <\/em>Start sender channel on source queue manager.<\/strong>
\nstart channel (‘MqM1.SNDR’)<\/em>
\n1 : start channel (‘MqM1.SNDR’)<\/em>
\nAMQ8018: Start WebSphere MQ channel accepted.<\/em><\/p>\n

Points to be noted:-<\/em> Starting sender channel will start the receiver channel automatically.<\/em> <\/span>
\nStep D contains the steps to check channel status.<\/span><\/p>\n

NOTE:-<\/strong>
\nMake sure that listeners are started, if not started use below steps to start listeners<\/em>
\n1.) <\/em>Connect to source queue manager MqM1 <\/em>using runmqsc command.<\/strong>
\n[root@myhost mqm]# runmqsc MqM1<\/em><\/p>\n

2.)<\/em> Verify Listener ‘MqM1.LSNR’ <\/em>\u00a0is running in source queue manager MqM1 <\/strong><\/p>\n

display lsstatus (‘MqM1.LSNR’)<\/em><\/p>\n

\"listener\"<\/a><\/p>\n

 <\/p>\n

2.a.) <\/em>If the listener ‘MqM1.LSNR’<\/em>\u00a0is not running start it by using below mqsc command<\/strong><\/span>\u00a0<\/span><\/p>\n

start listener (‘MqM1.LSNR’)<\/em><\/span><\/p>\n

1 : start listener (‘MqM1.LSNR’)<\/em><\/span>
\nAMQ8021: Request to start WebSphere MQ Listener accepted.<\/em><\/span>
\n
\n<\/span>3.) Quit MQSC<\/strong><\/span>
\n
\n<\/span>end<\/em><\/span>
\n
\n<\/span>4.) <\/em>Connect to destination queue manager MqM2 <\/em>using runmqsc command.<\/strong><\/span>
\n[root@myhost mqm]# runmqsc MqM2<\/em><\/span>
\n5.)<\/em> Verify listener ‘MqM2.LSNR’<\/em> is running in destination queue manager MqM2<\/em> <\/strong><\/span><\/div>\n

 <\/p>\n

\"listener2\"<\/a><\/p>\n

 <\/p>\n

5.a.) If the listener ‘MqM2.LSNR’<\/em> is not running start it by using below mqsc command<\/strong><\/span><\/div>\n
start listener (‘MqM2.LSNR’)<\/em>
\n1 : start listener (‘MqM2.LSNR’)<\/em>
\nAMQ8021: Request to start WebSphere MQ Listener accepted.<\/em><\/p>\n

D.) Checking channel status of both Qmgr<\/strong>
\n——————————————————<\/strong><\/p>\n

1.)<\/em>Connect to source queue manager MqM1 <\/em>using runmqsc command.<\/strong>
\n[root@myhost mqm]# runmqsc MqM1<\/em>
\n2.)<\/em> Verify the channel ‘MqM1.SNDR’<\/em> status<\/strong><\/p>\n

display chstatus (‘MqM1.SNDR’)<\/em><\/div>\n

\"chstatus1\"<\/a><\/p>\n

 <\/p>\n

3.) Quit MQSC<\/em><\/strong><\/p>\n

4.) <\/em>Connect to destination queue manager MqM2 <\/em>using runmqsc command.<\/strong>
\n[root@myhost mqm]# runmqsc MqM2<\/em>
\n5.) Verify the channel ‘MqM1.SNDR’<\/em> status<\/strong><\/p>\n

display chstatus (‘MqM1.SNDR’)<\/em><\/p>\n

 <\/p>\n

\"chstatus2\"<\/a><\/p>\n

 <\/p>\n

E.) Testing the setup<\/strong><\/div>\n
—————————<\/p>\n

Note:-<\/strong> If not already installed, Install the samples before proceeding with below test<\/em>.<\/p>\n

1.) Put a message in remote Queue of MqM1<\/strong><\/p>\n

\/opt\/mqm\/samp\/bin\/amqsput RMT.MqM1.Q1 MqM1<\/em>
\nType below text<\/p>\n

This is a test message from RMT.MqM1.Q1 (remote Queue) of MqM1 to LOC.MqM2.Q1 (Local Queue) of MqM2<\/em><\/p>\n

Press ctrl+z<\/p>\n

Eg:-
\n[root@myhost bin]# \/opt\/mqm\/samp\/bin\/amqsput RMT.MqM1.Q1 MqM1
\nSample AMQSPUT0 start
\ntarget queue is RMT.MqM1.Q1
\nThis is a test message from RMT.MqM1.Q1 (remote Queue) of MqM1 to LOC.MqM2.Q1 (Local Queue) of MqM2
\n[2]+ Stopped \/opt\/mqm\/samp\/bin\/amqsput RMT.MqM1.Q1 MqM1<\/em>
\n[root@myhost bin]#<\/p>\n

2.) Browse\/get the message from Local Queue of MqM2.<\/strong><\/div>\n

————————————————————————<\/strong>
\n\/opt\/mqm\/samp\/bin\/amqsget LOC.MqM2.Q1 MqM2<\/em><\/p>\n

[root@myhost bin]# \/opt\/mqm\/samp\/bin\/amqsget LOC.MqM2.Q1 MqM2
\nSample AMQSGET0 start<\/p>\n

message <This is a test message from RMT.MqM1.Q1 (remote Queue) of MqM1 to LOC.MqM2.Q1 (Local Queue) of MqM2><\/em><\/div>\n

no more messages
\nSample AMQSGET0 end<\/em>
\n[root@myhost bin]#<\/p>\n<\/div>\n
Kindly Like\/Follow the page if you like this article.<\/strong><\/div>\n
Request you to post your comments so that I can improve the content.<\/div>\n","protected":false},"excerpt":{"rendered":"

This example is a simple demonstration for understanding how MQ transfer messages between two queue managers and the minimum required MQ components for the same. Kindly Share\/Like\/Follow the page if you like this article.<\/p>\n

Below are the steps involved in this example.Source queue manager —————————— 1.) Create source queue manager. 2.) Start source queue manager. […]<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[57],"tags":[],"_links":{"self":[{"href":"https:\/\/mohan.sg\/index.php?rest_route=\/wp\/v2\/posts\/6363"}],"collection":[{"href":"https:\/\/mohan.sg\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/mohan.sg\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/mohan.sg\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/mohan.sg\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=6363"}],"version-history":[{"count":3,"href":"https:\/\/mohan.sg\/index.php?rest_route=\/wp\/v2\/posts\/6363\/revisions"}],"predecessor-version":[{"id":6370,"href":"https:\/\/mohan.sg\/index.php?rest_route=\/wp\/v2\/posts\/6363\/revisions\/6370"}],"wp:attachment":[{"href":"https:\/\/mohan.sg\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=6363"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/mohan.sg\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=6363"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/mohan.sg\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=6363"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}