MQSeries.net :: View topic - WBI

schroederms · Posted: Thu Jan 20, 2005 9:28 am Post subject:

I'm having a problem deploying a WBI simple flow. I've been reading the WBI Message Broker Basics to get a feel for the new toolkit, since working in the V 2.1 world. I started to do the BookstoreFlow example and thought I could add some ESQL to the compute node to go against one of our database tables in our AIX sandbox environment to see if I could get it to work, with no success.

What I've done.

1) The compute node has the property for Data Source set to EAI_MSGSRV.

2) Our sandbox (SP20), has in the .odbc.ini file the EAI_MSGRV section for our ORacle database information, this .ini file is the same that we use on DEV and PRD (AIX) currently running under v2.1

3) I right click on my BookstoreFlow to "Run on Server", and I get Publishing was complete with warnings.

4) I look at the the Log in the Broker Administrative Perspective and I see it does not like the alias "t" (Messages below in red). This is the way I coded it in 2.1, so I migrated a flow from v2.1 to 5 just to see if the code had changed in migration for the syntax on the DB call but it did not. So, I was wondering what I'm doing wrong. Orginal esql file in green below.

Thanks in advance,
Mike

BIP2432E: (.READDB, 3.15) : The correlation name 't' is not valid. Those in scope are: , Environment, InputLocalEnvironment, OutputLocalEnvironment, InputRoot, InputBody, InputProperties, OutputRoot, InputExceptionList, OutputExceptionList, InputDestinationList, OutputDestinationList, APPLICATION_SERVICES.

The first element of a field reference must be a valid correlation name, from those in scope. This message may sometimes be due to an incorrectly formed or spelled expression which is not intended to be a field reference being parsed as if it were a field reference because the parser does not recognize it.

Correct the syntax of the expression and redeploy the message flow.

CREATE COMPUTE MODULE BookstoreFlow_Compute
CREATE FUNCTION Main() RETURNS BOOLEAN
BEGIN

CALL CopyMessageHeaders();
-- CALL CopyEntireMessage();

CALL READDB();

RETURN TRUE;
END;

CREATE PROCEDURE CopyMessageHeaders() BEGIN
DECLARE I INTEGER 1;
DECLARE J INTEGER 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;

CREATE PROCEDURE READDB() BEGIN
Set OutputLocalEnvironment.APPLICATION_SERVICES.OUT_DATA[] =
(SELECT t.FUNCTION,
t.REALTIME,
t.SERVICE_QUEUE,
t.SERVICE_QUEUE_MGR,
t.DESCRIPTION,
t.XML_FORMAT,
t.EXAMPLE_XML
FROM Database.EAI_MSGSRV.APPLICATION_SERVICES as t);

END;

END MODULE;