C
Chaya Krishnappa
Guest
/*** Producer.p ****/ /* Publishes A Text message. */ DEFINE VARIABLE ptpsession AS HANDLE. DEFINE VARIABLE messageH AS HANDLE. DEFINE VARIABLE iping AS INTEGER NO-UNDO INITIAL 20. DEFINE VARIABLE lDebug AS LOGICAL. DEFINE VARIABLE cdate AS CHARACTER NO-UNDO FORMAT "x(16)". DEFINE VARIABLE ddate AS DATE NO-UNDO. /* Creates a session object. */ RUN jms/jmssession.p PERSISTENT SET ptpsession ("-H localhost -S 5162 -AppService AD.sonicMQ1"). /* Set user credentials. */ RUN setBrokerURL IN ptpsession (INPUT "tcp://localhost:61616"). RUN setUser IN ptpsession (INPUT "admin"). RUN setPassword IN ptpsession (INPUT "admin"). /* Connect to the broker. */ RUN beginSession IN ptpsession. /* Create a text message */ RUN createTextMessage IN ptpsession (OUTPUT messageH). ddate = DATE(cdate). RUN setText IN messageH ("This is test message sent on " + STRING(TIME,"HH:MM:SS")). /* Publish the message on the "SampleQ1" topic */ RUN sendToQueue IN ptpsession ("SampleQ1", messageH, ?, ?, ?). RUN deleteMessage IN messageH. RUN deleteSession IN ptpsession. Message "Sent". Note: This procedure was shared in one of the posts - community.progress.com/.../22805
Continue reading...
Continue reading...