Create Consumer and Provider Flows like
Consumer Flow:-
CSV_IN
Passing_Dept_Salary
esql in ComputeNode:-
CREATE COMPUTE
MODULE Consumer_flow_Compute
CREATE FUNCTION
Main() RETURNS BOOLEAN
BEGIN
DECLARE DEPT CHARACTER;
DECLARE SAL INTEGER;
SET DEPT=InputRoot.MRM.DEPT;
SET SAL=InputRoot.MRM.SAL;
SET OutputLocalEnvironment.Destination.HTTP.QueryString.key =DEPT;
SET OutputLocalEnvironment.Destination.HTTP.QueryString.key1 =SAL;
SET OutputLocalEnvironment.Destination.HTTP.RequestURL='http://localhost:7080/getQueryString?';
RETURN TRUE;
END;
END MODULE;
Request_Details
Just give a sample url to supress error at node like
http://test.com
Result_Details
Provider Flow:-
Properties On Each
Node of Provider flow are given below
Take_Dept_Salary
Retrieve_Details
esql in ComputeNode:-
CREATE COMPUTE
MODULE Provider_flow_Compute
CREATE FUNCTION
Main() RETURNS BOOLEAN
BEGIN
DECLARE Dept_Sal_Location,SPLIT,DEPT CHARACTER;
DECLARE SAL INTEGER;
SET Dept_Sal_Location=InputRoot.HTTPInputHeader.[10];
SET SPLIT=SUBSTRING(Dept_Sal_Location
AFTER '=');
SET DEPT =SUBSTRING(SPLIT BEFORE '&');
SET SAL =SUBSTRING(SPLIT AFTER '=');
SET OutputRoot.XMLNSC.Employee.Details[]=PASSTHRU('SELECT * FROM
mdeai.EMPLOYEE WHERE DEPT=? AND SALARY>?' TO
Database.EmpTestDSN VALUES(DEPT,SAL));
RETURN TRUE;
END;
END MODULE;
Provide_Respone
Input Message:-
EAI,10000
Create
Message set for the Input Message with below details
DataBase
records in the table
Tree
Structure created with DataBase Details upon successful process
Message in
Output Queue upon successful transaction is completed
