MQSeries.net :: View topic

arunkumar1989 · Posted: Wed Nov 21, 2012 4:52 am Post subject:

I have created a small application ...In that i have put 1 MQ Input and 3 MQ Output.... and 1 compute node.... the compute node process are done successfully.... while PROPAGATING only getting invalid terminal error..

this is my code :

CREATE COMPUTE MODULE DateManipulationFlow_Compute
DECLARE dob,doj,now TIMESTAMP CURRENT_TIMESTAMP;
DECLARE age,experience INTEGER 0;
DECLARE curDesignation CHARACTER;

CREATE FUNCTION Main() RETURNS BOOLEAN
BEGIN
CALL CopyMessageHeaders();
-- CALL CopyEntireMessage();

CALL firstOutput();
PROPAGATE TO TERMINAL 'out';

CALL secondOutput();
PROPAGATE TO TERMINAL 'out1';

CALL thirdOutput();
PROPAGATE TO TERMINAL 'out2';

RETURN TRUE;
END;

CREATE PROCEDURE firstOutput ( )
BEGIN
SET OutputRoot.XMLNSC.EmployeeInfo.EmployeeName=InputRoot.XMLNSC.MyInfo.Name;
SET OutputRoot.XMLNSC.EmployeeInfo.Designation='SoftwareEngineer';

SET now = CAST(CURRENT_TIMESTAMP AS TIMESTAMP FORMAT 'yyyyMMdd-HHmmss');

DECLARE d1 TIMESTAMP InputRoot.XMLNSC.MyInfo.DOB;
SET dob=CAST(d1 AS TIMESTAMP FORMAT 'yyyyMMdd-HHmmss');
SET age=(now-dob)YEAR;
SET OutputRoot.XMLNSC.EmployeeInfo.Age=age;

DECLARE d2 TIMESTAMP InputRoot.XMLNSC.MyInfo.DOJ;
SET doj=CAST(d2 AS TIMESTAMP FORMAT 'yyyyMMdd-HHmmss');
SET experience=(now-doj)YEAR;
SET OutputRoot.XMLNSC.EmployeeInfo.Experience=experience;

SET OutputRoot.XMLNSC.EmployeeInfo.Today=now;

DECLARE gt1 TIMESTAMP CURRENT_GMTTIMESTAMP;
SET OutputRoot.XMLNSC.EmployeeInfo.GMT=now;

-- SET OutputLocalEnvironment.Destination.MQ.DestinationData[1].queueName = 'OUTPUT_Q1';

END;

CREATE PROCEDURE secondOutput ( )
BEGIN
-- SET OutputLocalEnvironment.Destination.MQ.DestinationData[2].queueName = 'OUTPUT_Q2';

END;

CREATE PROCEDURE thirdOutput ( )
BEGIN
-- SET OutputLocalEnvironment.Destination.MQ.DestinationData[3].queueName = 'OUTPUT_Q3';
END;

CREATE PROCEDURE CopyMessageHeaders() BEGIN
DECLARE I INTEGER 1;
DECLARE J INTEGER;
SET J = CARDINALITY(InputRoot.*[]);
WHILE I < J DO
SET OutputRoot.*[I] = InputRoot.*[I];
SET I = I + 1;
END WHILE;
END;

CREATE PROCEDURE CopyEntireMessage() BEGIN
SET OutputRoot = InputRoot;
END;
END MODULE;