Examples

Example 1: 3

begin;
3EXECUTE FUNCTION MQPublish('Testing 123');
3commit:

This example publishes the message with the following parameters: 3

3
• publisher_name: default publisher
3
• policy_name: default policy
3
• msg_data: "Testing 123"
3
• topic: None
3
• correl_id: None

Example 2: 3

begin;
3EXECUTE FUNCTION MQPublish('MYPUBLISHER','Testing 345','TESTTOPIC');
3commit;

This example publishes the message with the following parameters: 3

3
• publisher_name: "MYPUBLISHER"
3
• policy_name: default policy
3
• msg_data: "Testing 345"
3
• topic: "TESTTOPIC"
3
• correl_id: None

Example 3: 3

begin;
3EXECUTE FUNCTION MQPublish('MYPUBLISHER','MYPOLICY','Testing 678','TESTTOPIC',
3'TEST1');
3commit;

This example publishes the message with the following parameters: 3

3
• publisher_name: "MYPUBLISHER"
3
• policy_name: "MYPOLICY"
3
• msg_data: "Testing 678"
3
• topic: "TESTTOPIC"
3
• correl_id: "TEST1"

Example 4: 3

begin;
3EXECUTE FUNCTION MQPublish('Testing 901','TESTS');
3commit;

This example publishes the message with the following parameters: 3

3
• publisher_name: default publisher
3
• policy_name: default policy
3
• msg_data: "Testing 901"
3
• topic: "TESTS"
3
• correl_id: None

Example 5: 3

begin;
3EXECUTE FUNCTION MQPublish('SEND.MESSAGE', 'emergency', 'CODE BLUE', 'expedite');
3commit;

This example publishes the message with the following parameters: 3

3
• publisher_name: "SEND.MESSAGE"
3
• policy_name: "emergency"
3
• msg_data: "CODE BLUE"
3
• topic: "expedite"
3
• correl_id: None

Example 6: The following table contains sample rows and columns 3in the "informix".mqipubsub table. 3

3

begin;
3 EXECUTE FUNCTION 
3    MQSubscribe('IDS.DEFAULT.SUBSCRIBER',
3                'IDS.DEFAULT.PUB.SUB.POLICY', 'Weather');
3commit;

This statement demonstrates a subscriber registering an interest 3in messages containing the topic "Weather," with the following parameters: 3

3
• subscriber_name: "IDS.DEFAULT.SUBSCRIBER"
3
• policy_name: "IDS.DEFAULT.PUB.SUB.POLICY"
3
• topic: "Weather"

begin;
3   EXECUTE FUNCTION MQPublish('IDS.DEFAULT.PUBLISHER', 
3                            'IDS.DEFAULT.PUB.SUB.POLICY', 'Rain', 'Weather');
3commit;

This statement publishes the message with the following parameters: 3

3
• publisher_name: "IDS.DEFAULT.PUBLISHER"
3
• policy_name: "IDS.DEFAULT.PUB.SUB.POLICY"
3
• msg_data: "Rain"
3
• topic: "Weather"
3
• correl_id: None

begin;
3   EXECUTE FUNCTION MQReceive('IDS.DEFAULT.SUBSCRIBER.RECEIVER',
3                              'IDS.DEFAULT.PUB.SUB.POLICY');
3commit;

This statement receives the message with the following parameters 3(it returns "Rain"): 3

3
• service_name: "IDS.DEFAULT.SUBSCRIBER.RECEIVER"
3
• policy_name: "IDS.DEFAULT.PUB.SUB.POLICY"