Author |
Message
|
kumar.shanj |
Posted: Wed Dec 01, 2010 9:56 am Post subject: Not able to put message into queue in DestinationList |
|
|
Apprentice
Joined: 18 Nov 2010 Posts: 49
|
Websphere Message Broker v6.0
I am not able to put message into queue in OutputLocalEnvironment.Destination.MQ.DestinationData[1].queueName = 'INTRASTAT.CONTROL.INP'.
I have mentioned Destination Mode as DestinationList.
Getting exception message as
(
(0x01000000):RecoverableException = (
(0x03000000):File = 'F:\build\S600_P\src\DataFlowEngine\ImbComputeNode.cpp'
(0x03000000):Line = 464
(0x03000000):Function = 'ImbComputeNode::evaluate'
(0x03000000):Type = 'ComIbmComputeNode'
(0x03000000):Name = 'com/pwc/intrastat/flow/control/IntrastatFlowControl#FCMComposite_1_8.com/pwc/aim/commonerrorhandler/CommonErrorHandler#FCMComposite_1_3'
(0x03000000):Label = 'com.pwc.intrastat.flow.control.IntrastatFlowControl.CommonErrorHandler.Format Exception Message'
(0x03000000):Catalog = 'BIPv600'
(0x03000000):Severity = 3
(0x03000000):Number = 2230
(0x03000000):Text = 'Caught exception and rethrowing'
(0x01000000):RecoverableException = (
(0x03000000):File = 'F:\build\S600_P\src\DataFlowEngine\ImbRdl\ImbRdlStatementGroup.cpp'
(0x03000000):Line = 589
(0x03000000):Function = 'SqlStatementGroup::execute'
(0x03000000):Type = 'ComIbmComputeNode'
(0x03000000):Name = 'com/pwc/intrastat/flow/control/IntrastatFlowControl#FCMComposite_1_8.com/pwc/aim/commonerrorhandler/CommonErrorHandler#FCMComposite_1_3'
(0x03000000):Label = 'com.pwc.intrastat.flow.control.IntrastatFlowControl.CommonErrorHandler.Format Exception Message'
(0x03000000):Catalog = 'BIPv600'
(0x03000000):Severity = 3
(0x03000000):Number = 2488
(0x03000000):Text = 'Error detected, rethrowing'
(0x01000000):Insert = (
(0x03000000):Type = 5
(0x03000000):Text = 'com.pwc.aim.commonerrorhandler.FormatExceptionMessage.Main'
)
(0x01000000):Insert = (
(0x03000000):Type = 5
(0x03000000):Text = '94.3'
)
(0x01000000):Insert = (
(0x03000000):Type = 5
(0x03000000):Text = 'PROPAGATE TO TERMINAL 'out1' FINALIZE DEFAULT DELETE DEFAULT;'
)
(0x01000000):RecoverableException = (
(0x03000000):File = 'F:\build\S600_P\src\DataFlowEngine\ImbMqOutputNode.cpp'
(0x03000000):Line = 782
(0x03000000):Function = 'ImbMqOutputNode::evaluate'
(0x03000000):Type = 'ComIbmMQOutputNode'
(0x03000000):Name = 'com/pwc/intrastat/flow/control/IntrastatFlowControl#FCMComposite_1_8.com/pwc/aim/commonerrorhandler/CommonErrorHandler#FCMComposite_1_25'
(0x03000000):Label = 'com.pwc.intrastat.flow.control.IntrastatFlowControl.CommonErrorHandler.Failure Queue'
(0x03000000):Catalog = 'BIPv600'
(0x03000000):Severity = 3
(0x03000000):Number = 2230
(0x03000000):Text = 'Caught exception and rethrowing'
(0x01000000):MessageException = (
(0x03000000):File = 'F:\build\S600_P\src\DataFlowEngine\ImbMqOutputNode.cpp'
(0x03000000):Line = 1955
(0x03000000):Function = 'ImbMqOutputNode::putMessage'
(0x03000000):Type = 'ComIbmMQOutputNode'
(0x03000000):Name = 'com/pwc/intrastat/flow/control/IntrastatFlowControl#FCMComposite_1_8.com/pwc/aim/commonerrorhandler/CommonErrorHandler#FCMComposite_1_25'
(0x03000000):Label = 'com.pwc.intrastat.flow.control.IntrastatFlowControl.CommonErrorHandler.Failure Queue'
(0x03000000):Catalog = 'BIPv600'
(0x03000000):Severity = 3
(0x03000000):Number = 2666
(0x03000000):Text = 'Failed to open queue'
(0x01000000):Insert = (
(0x03000000):Type = 2
(0x03000000):Text = '-1'
)
(0x01000000):Insert = (
(0x03000000):Type = 5
(0x03000000):Text = 'MQW101'
)
(0x01000000):Insert = (
(0x03000000):Type = 2
(0x03000000):Text = '2085'
)
(0x01000000):Insert = (
(0x03000000):Type = 5
(0x03000000):Text = ''
)
(0x01000000):Insert = (
(0x03000000):Type = 5
(0x03000000):Text = ''
)
(0x01000000):Insert = (
(0x03000000):Type = 5
(0x03000000):Text = ''
)
)
)
)
)
)
Help will be greatly appreciated |
|
Back to top |
|
 |
smdavies99 |
Posted: Wed Dec 01, 2010 10:01 am Post subject: |
|
|
 Jedi Council
Joined: 10 Feb 2003 Posts: 6076 Location: Somewhere over the Rainbow this side of Never-never land.
|
Quote: |
(0x03000000):Text = 'Failed to open queue'
(0x01000000):Insert = (
(0x03000000):Type = 2
(0x03000000):Text = '-1'
)
(0x01000000):Insert = (
(0x03000000):Type = 5
(0x03000000):Text = 'MQW101'
)
(0x01000000):Insert = (
(0x03000000):Type = 2
(0x03000000):Text = '2085'
) |
Your answer is right there in your face.
Google is your friend here. Search for mqrc 2085
or issue that command from a dos prompt on a system that has WMQ Installed. _________________ WMQ User since 1999
MQSI/WBI/WMB/'Thingy' User since 2002
Linux user since 1995
Every time you reinvent the wheel the more square it gets (anon). If in doubt think and investigate before you ask silly questions. |
|
Back to top |
|
 |
kumar.shanj |
Posted: Wed Dec 01, 2010 10:35 am Post subject: |
|
|
Apprentice
Joined: 18 Nov 2010 Posts: 49
|
But when i mention Queue manager and queuename in MQOutput Node and Destination Mode as Queue Name.. it is working fine...
I am not getting reason why destination List is not working when i mention the queue name in Compute Node ESQL code |
|
Back to top |
|
 |
mqjeff |
Posted: Wed Dec 01, 2010 10:52 am Post subject: |
|
|
Grand Master
Joined: 25 Jun 2008 Posts: 17447
|
If you have to specify the QMgr name to get it to work on the MQOutput node, then you have to specify the qmgr name in the destination list. |
|
Back to top |
|
 |
kumar.shanj |
Posted: Thu Dec 02, 2010 1:41 am Post subject: |
|
|
Apprentice
Joined: 18 Nov 2010 Posts: 49
|
We are having a cluster queue manager and we are using cluster queue.
Please help in configuring destination list in ESQL code in compute node.
Do i need to mention Queue manager explicitly in destination list???
How to mention queue manager in destination list???
As of now even after mentioning queue name in Destination list , i am getting error saying 'Failed to open queue' .
Pls help in this regard.... |
|
Back to top |
|
 |
fjb_saper |
Posted: Thu Dec 02, 2010 1:46 am Post subject: |
|
|
 Grand High Poobah
Joined: 18 Nov 2003 Posts: 20756 Location: LI,NY
|
you might want to explicitely set the qmgr to blank (spaces)  _________________ MQ & Broker admin |
|
Back to top |
|
 |
kumar.shanj |
Posted: Thu Dec 02, 2010 2:41 am Post subject: |
|
|
Apprentice
Joined: 18 Nov 2010 Posts: 49
|
i have set blank to Queue manager name and Queue name.
Have set Destination mode as "Destination List ".
Code in my Compute node.
SET OutputLocalEnvironment.Destination.MQ.DestinationData.queueManagerName = 'MyQueueManagerName';
SET OutputLocalEnvironment.Destination.MQ.DestinationData.queueName =
'MyQueueName';
Pls help me in configuring the same |
|
Back to top |
|
 |
smdavies99 |
Posted: Thu Dec 02, 2010 2:50 am Post subject: |
|
|
 Jedi Council
Joined: 10 Feb 2003 Posts: 6076 Location: Somewhere over the Rainbow this side of Never-never land.
|
kumar.shanj wrote: |
i have set blank to Queue manager name and Queue name.
Have set Destination mode as "Destination List ".
Code in my Compute node.
SET OutputLocalEnvironment.Destination.MQ.DestinationData.queueManagerName = 'MyQueueManagerName';
SET OutputLocalEnvironment.Destination.MQ.DestinationData.queueName =
'MyQueueName';
Pls help me in configuring the same |
to be completely accurate the code should be:-
Code: |
SET OutputLocalEnvironment.Destination.MQ.DestinationData[1].queueName =
'MyQueueName';
|
It is a List of destinations. You can have multiple destination queues for the messages. _________________ WMQ User since 1999
MQSI/WBI/WMB/'Thingy' User since 2002
Linux user since 1995
Every time you reinvent the wheel the more square it gets (anon). If in doubt think and investigate before you ask silly questions. |
|
Back to top |
|
 |
kumar.shanj |
Posted: Thu Dec 02, 2010 3:01 am Post subject: |
|
|
Apprentice
Joined: 18 Nov 2010 Posts: 49
|
SET OutputLocalEnvironment.Destination.MQ.DestinationData[1].queueName = 'MyQueueName';
SET OutputLocalEnvironment.Destination.MQ.DestinationData[1].queueManagerName = 'MyQueueManagerName';
i have set blank to Queue manager name and Queue name.
Have set Destination mode as "Destination List ".
but getting an error saying
(
(0x01000000):RecoverableException = (
(0x03000000):File = 'F:\build\S600_P\src\DataFlowEngine\ImbComputeNode.cpp'
(0x03000000):Line = 464
(0x03000000):Function = 'ImbComputeNode::evaluate'
(0x03000000):Type = 'ComIbmComputeNode'
(0x03000000):Name = 'com/pwc/intrastat/flow/control/IntrastatFlowControl#FCMComposite_1_8.com/pwc/aim/commonerrorhandler/CommonErrorHandler#FCMComposite_1_3'
(0x03000000):Label = 'com.pwc.intrastat.flow.control.IntrastatFlowControl.CommonErrorHandler.Format Exception Message'
(0x03000000):Catalog = 'BIPv600'
(0x03000000):Severity = 3
(0x03000000):Number = 2230
(0x03000000):Text = 'Caught exception and rethrowing'
(0x01000000):RecoverableException = (
(0x03000000):File = 'F:\build\S600_P\src\DataFlowEngine\ImbRdl\ImbRdlStatementGroup.cpp'
(0x03000000):Line = 589
(0x03000000):Function = 'SqlStatementGroup::execute'
(0x03000000):Type = 'ComIbmComputeNode'
(0x03000000):Name = 'com/pwc/intrastat/flow/control/IntrastatFlowControl#FCMComposite_1_8.com/pwc/aim/commonerrorhandler/CommonErrorHandler#FCMComposite_1_3'
(0x03000000):Label = 'com.pwc.intrastat.flow.control.IntrastatFlowControl.CommonErrorHandler.Format Exception Message'
(0x03000000):Catalog = 'BIPv600'
(0x03000000):Severity = 3
(0x03000000):Number = 2488
(0x03000000):Text = 'Error detected, rethrowing'
(0x01000000):Insert = (
(0x03000000):Type = 5
(0x03000000):Text = 'com.pwc.aim.commonerrorhandler.FormatExceptionMessage.Main'
)
(0x01000000):Insert = (
(0x03000000):Type = 5
(0x03000000):Text = '94.3'
)
(0x01000000):Insert = (
(0x03000000):Type = 5
(0x03000000):Text = 'PROPAGATE TO TERMINAL 'out1' FINALIZE DEFAULT DELETE DEFAULT;'
)
(0x01000000):RecoverableException = (
(0x03000000):File = 'F:\build\S600_P\src\DataFlowEngine\ImbMqOutputNode.cpp'
(0x03000000):Line = 782
(0x03000000):Function = 'ImbMqOutputNode::evaluate'
(0x03000000):Type = 'ComIbmMQOutputNode'
(0x03000000):Name = 'com/pwc/intrastat/flow/control/IntrastatFlowControl#FCMComposite_1_8.com/pwc/aim/commonerrorhandler/CommonErrorHandler#FCMComposite_1_25'
(0x03000000):Label = 'com.pwc.intrastat.flow.control.IntrastatFlowControl.CommonErrorHandler.Failure Queue'
(0x03000000):Catalog = 'BIPv600'
(0x03000000):Severity = 3
(0x03000000):Number = 2230
(0x03000000):Text = 'Caught exception and rethrowing'
(0x01000000):MessageException = (
(0x03000000):File = 'F:\build\S600_P\src\DataFlowEngine\ImbMqOutputNode.cpp'
(0x03000000):Line = 1955
(0x03000000):Function = 'ImbMqOutputNode::putMessage'
(0x03000000):Type = 'ComIbmMQOutputNode'
(0x03000000):Name = 'com/pwc/intrastat/flow/control/IntrastatFlowControl#FCMComposite_1_8.com/pwc/aim/commonerrorhandler/CommonErrorHandler#FCMComposite_1_25'
(0x03000000):Label = 'com.pwc.intrastat.flow.control.IntrastatFlowControl.CommonErrorHandler.Failure Queue'
(0x03000000):Catalog = 'BIPv600'
(0x03000000):Severity = 3
(0x03000000):Number = 2666
(0x03000000):Text = 'Failed to open queue'
(0x01000000):Insert = (
(0x03000000):Type = 2
(0x03000000):Text = '-1'
)
(0x01000000):Insert = (
(0x03000000):Type = 5
(0x03000000):Text = 'MQW101'
)
(0x01000000):Insert = (
(0x03000000):Type = 2
(0x03000000):Text = '2085'
)
(0x01000000):Insert = (
(0x03000000):Type = 5
(0x03000000):Text = ''
)
(0x01000000):Insert = (
(0x03000000):Type = 5
(0x03000000):Text = ''
)
(0x01000000):Insert = (
(0x03000000):Type = 5
(0x03000000):Text = ''
)
)
)
)
)
)
<ExceptionReport>
<DateTime>2010-12-02 10:56:10.826477</DateTime>
- <BrokerDetails>
<BrokerName>MQDBR002</BrokerName>
<BrokerVersion>6003</BrokerVersion>
<ExecutionGroup>PILOT</ExecutionGroup>
<MessageFlow>com.pwc.intrastat.flow.control.IntrastatFlowControl</MessageFlow>
<ErroredNodeName>com.pwc.intrastat.flow.control.IntrastatFlowControl.Output Queue (Derived)</ErroredNodeName>
</BrokerDetails>
- <MQDetails>
<QueueManagerName>MyQueueManagerName</QueueManagerName>
<InputQueue>MuQueueName</InputQueue>
</MQDetails>
- <AuditMessage>
- <FlowDetails>
<NodeName>CommonErrorHandler.Set Environment Message</NodeName>
<Time>2010-12-02 10:56:10.748164</Time>
</FlowDetails>
- <FlowDetails>
<NodeName>CommonErrorHandler.Format Exception Message</NodeName>
<Time>2010-12-02 10:56:10.826477</Time>
</FlowDetails>
</AuditMessage>
- <ErrorMessage>
- <ErrorDetails>
<ExceptionType>RecoverableException</ExceptionType>
<ErrorCode>2230</ErrorCode>
<ErrorText>Caught exception and rethrowing</ErrorText>
</ErrorDetails>
- <ErrorDetails>
<ExceptionType>MessageException</ExceptionType>
<ErrorCode>2665</ErrorCode>
<ErrorText>Invalid destination list</ErrorText>
- <Description>
- <Insert>
<Text>-1</Text>
</Insert>
- <Insert>
<Text>MQW005</Text>
</Insert>
- <Insert>
<Text>0</Text>
</Insert>
- <Insert>
<Text />
</Insert>
</Description>
</ErrorDetails>
</ErrorMessage>
</ExceptionReport> |
|
Back to top |
|
 |
smdavies99 |
Posted: Thu Dec 02, 2010 4:09 am Post subject: |
|
|
 Jedi Council
Joined: 10 Feb 2003 Posts: 6076 Location: Somewhere over the Rainbow this side of Never-never land.
|
WMQ Error 2085 means?
If you are using this all in an WMQ Cluster then you need to make sure the queue is available from the system where Broker is running.
normal WMQ Utilities and sample apps (eg amqsput) can be used to test this BEFORE you try it from broker.
If we assume that you are setting the Queue Details correctly then the problem lies outside of broker. _________________ WMQ User since 1999
MQSI/WBI/WMB/'Thingy' User since 2002
Linux user since 1995
Every time you reinvent the wheel the more square it gets (anon). If in doubt think and investigate before you ask silly questions. |
|
Back to top |
|
 |
veda |
Posted: Thu Dec 02, 2010 6:23 am Post subject: |
|
|
Novice
Joined: 01 Dec 2010 Posts: 24
|
kumar.shanj wrote: |
SET OutputLocalEnvironment.Destination.MQ.DestinationData[1].queueName = 'MyQueueName';
SET OutputLocalEnvironment.Destination.MQ.DestinationData[1].queueManagerName = 'MyQueueManagerName';
i have set blank to Queue manager name and Queue name.
Have set Destination mode as "Destination List ".
but getting an error saying
(
(0x01000000):RecoverableException = (
(0x03000000):File = 'F:\build\S600_P\src\DataFlowEngine\ImbComputeNode.cpp'
(0x03000000):Line = 464
(0x03000000):Function = 'ImbComputeNode::evaluate'
(0x03000000):Type = 'ComIbmComputeNode'
(0x03000000):Name = 'com/pwc/intrastat/flow/control/IntrastatFlowControl#FCMComposite_1_8.com/pwc/aim/commonerrorhandler/CommonErrorHandler#FCMComposite_1_3'
(0x03000000):Label = 'com.pwc.intrastat.flow.control.IntrastatFlowControl.CommonErrorHandler.Format Exception Message'
(0x03000000):Catalog = 'BIPv600'
(0x03000000):Severity = 3
(0x03000000):Number = 2230
(0x03000000):Text = 'Caught exception and rethrowing'
(0x01000000):RecoverableException = (
(0x03000000):File = 'F:\build\S600_P\src\DataFlowEngine\ImbRdl\ImbRdlStatementGroup.cpp'
(0x03000000):Line = 589
(0x03000000):Function = 'SqlStatementGroup::execute'
(0x03000000):Type = 'ComIbmComputeNode'
(0x03000000):Name = 'com/pwc/intrastat/flow/control/IntrastatFlowControl#FCMComposite_1_8.com/pwc/aim/commonerrorhandler/CommonErrorHandler#FCMComposite_1_3'
(0x03000000):Label = 'com.pwc.intrastat.flow.control.IntrastatFlowControl.CommonErrorHandler.Format Exception Message'
(0x03000000):Catalog = 'BIPv600'
(0x03000000):Severity = 3
(0x03000000):Number = 2488
(0x03000000):Text = 'Error detected, rethrowing'
(0x01000000):Insert = (
(0x03000000):Type = 5
(0x03000000):Text = 'com.pwc.aim.commonerrorhandler.FormatExceptionMessage.Main'
)
(0x01000000):Insert = (
(0x03000000):Type = 5
(0x03000000):Text = '94.3'
)
(0x01000000):Insert = (
(0x03000000):Type = 5
(0x03000000):Text = 'PROPAGATE TO TERMINAL 'out1' FINALIZE DEFAULT DELETE DEFAULT;'
)
(0x01000000):RecoverableException = (
(0x03000000):File = 'F:\build\S600_P\src\DataFlowEngine\ImbMqOutputNode.cpp'
(0x03000000):Line = 782
(0x03000000):Function = 'ImbMqOutputNode::evaluate'
(0x03000000):Type = 'ComIbmMQOutputNode'
(0x03000000):Name = 'com/pwc/intrastat/flow/control/IntrastatFlowControl#FCMComposite_1_8.com/pwc/aim/commonerrorhandler/CommonErrorHandler#FCMComposite_1_25'
(0x03000000):Label = 'com.pwc.intrastat.flow.control.IntrastatFlowControl.CommonErrorHandler.Failure Queue'
(0x03000000):Catalog = 'BIPv600'
(0x03000000):Severity = 3
(0x03000000):Number = 2230
(0x03000000):Text = 'Caught exception and rethrowing'
(0x01000000):MessageException = (
(0x03000000):File = 'F:\build\S600_P\src\DataFlowEngine\ImbMqOutputNode.cpp'
(0x03000000):Line = 1955
(0x03000000):Function = 'ImbMqOutputNode::putMessage'
(0x03000000):Type = 'ComIbmMQOutputNode'
(0x03000000):Name = 'com/pwc/intrastat/flow/control/IntrastatFlowControl#FCMComposite_1_8.com/pwc/aim/commonerrorhandler/CommonErrorHandler#FCMComposite_1_25'
(0x03000000):Label = 'com.pwc.intrastat.flow.control.IntrastatFlowControl.CommonErrorHandler.Failure Queue'
(0x03000000):Catalog = 'BIPv600'
(0x03000000):Severity = 3
(0x03000000):Number = 2666
(0x03000000):Text = 'Failed to open queue'
(0x01000000):Insert = (
(0x03000000):Type = 2
(0x03000000):Text = '-1'
)
(0x01000000):Insert = (
(0x03000000):Type = 5
(0x03000000):Text = 'MQW101'
)
(0x01000000):Insert = (
(0x03000000):Type = 2
(0x03000000):Text = '2085'
)
(0x01000000):Insert = (
(0x03000000):Type = 5
(0x03000000):Text = ''
)
(0x01000000):Insert = (
(0x03000000):Type = 5
(0x03000000):Text = ''
)
(0x01000000):Insert = (
(0x03000000):Type = 5
(0x03000000):Text = ''
)
)
)
)
)
)
<ExceptionReport>
<DateTime>2010-12-02 10:56:10.826477</DateTime>
- <BrokerDetails>
<BrokerName>MQDBR002</BrokerName>
<BrokerVersion>6003</BrokerVersion>
<ExecutionGroup>PILOT</ExecutionGroup>
<MessageFlow>com.pwc.intrastat.flow.control.IntrastatFlowControl</MessageFlow>
<ErroredNodeName>com.pwc.intrastat.flow.control.IntrastatFlowControl.Output Queue (Derived)</ErroredNodeName>
</BrokerDetails>
- <MQDetails>
<QueueManagerName>MyQueueManagerName</QueueManagerName>
<InputQueue>MuQueueName</InputQueue>
</MQDetails>
- <AuditMessage>
- <FlowDetails>
<NodeName>CommonErrorHandler.Set Environment Message</NodeName>
<Time>2010-12-02 10:56:10.748164</Time>
</FlowDetails>
- <FlowDetails>
<NodeName>CommonErrorHandler.Format Exception Message</NodeName>
<Time>2010-12-02 10:56:10.826477</Time>
</FlowDetails>
</AuditMessage>
- <ErrorMessage>
- <ErrorDetails>
<ExceptionType>RecoverableException</ExceptionType>
<ErrorCode>2230</ErrorCode>
<ErrorText>Caught exception and rethrowing</ErrorText>
</ErrorDetails>
- <ErrorDetails>
<ExceptionType>MessageException</ExceptionType>
<ErrorCode>2665</ErrorCode>
<ErrorText>Invalid destination list</ErrorText>
- <Description>
- <Insert>
<Text>-1</Text>
</Insert>
- <Insert>
<Text>MQW005</Text>
</Insert>
- <Insert>
<Text>0</Text>
</Insert>
- <Insert>
<Text />
</Insert>
</Description>
</ErrorDetails>
</ErrorMessage>
</ExceptionReport> |
Is your problem resolved ? You are using a PROPAGATE statement,
with syntax PROPAGATE TO TERMINAL 'out1' FINALIZE DEFAULT DELETE DEFAULT I believe.
If DELETE is set to DEFAULT, or the DELETE clause is absent, the output local environment, message, and exception list are all cleared and their memory recovered immediately after propagation.
And finalize default doesn't allow you to make changes to the message tree.
So I think you better need to change your syntax to something like PROPAGATE TO TERMINAL 'out1' FINALIZE NONE DELETE NONE
Hope this helps..  |
|
Back to top |
|
 |
kumar.shanj |
Posted: Thu Dec 02, 2010 9:01 am Post subject: |
|
|
Apprentice
Joined: 18 Nov 2010 Posts: 49
|
problem is still not resolved....
BROKER SCHEMA com.pwc.intrastat.flow.control
CREATE COMPUTE MODULE IntrastatFlowControl
CREATE FUNCTION Main() RETURNS BOOLEAN
BEGIN
CALL CopyMessageHeaders();
--CALL CopyEntireMessage();
DECLARE count INTEGER;
DECLARE i INTEGER;
DECLARE RIRID INTEGER;
--Through SQL
SET Environment.Variables.Data.RIRREPORTS[] =
(SELECT * FROM
Database.dbo.RunWebsphereReport AS Rwr);
SET count = CARDINALITY(Environment.Variables.Data.RIRREPORTS[]);
SET i = 1;
WHILE (i<=count) do
SET OutputRoot.XMLNSC.Data.RunReport[i]=Environment.Variables.Data.RIRREPORTS[i];
DECLARE Ia INTEGER CARDINALITY(OutputLocalEnvironment.Destination.MQ.DestinationList.DestinationData[]);
IF Ia = 0 THEN
SET OutputLocalEnvironment.Destination.MQ.DestinationList.DestinationData[1].queueName = 'TAX.INTRASTAT.UK.INP';
ELSE
SET OutputLocalEnvironment.Destination.MQ.DestinationList.DestinationData[Ia+1].queueName = 'TAX.INTRASTAT.UK.INP';
END IF;
/*
--SET OutputLocalEnvironment.Destination.MQ.DestinationData[1].queueName = InputRoot.XML.ScheduleRequest.ActionDetails.MQ.MQTargetQ;
--IF(OutputRoot.XMLNSC.Data.RunReport[i].ReportType = 1 )THEN
--SET OutputLocalEnvironment.Destination.MQ.DestinationData[1].queueManagerName =
-- 'UK_CSERV_DW02';
SET OutputLocalEnvironment.Destination.MQDestinationData[1].queueName =
'TAX.INTRASTAT.UK.INP';
*/
-- Set header values
/*
SET OutputRoot.Properties.MessageDomain = 'XML';
SET OutputRoot.MQMD.Format = MQFMT_STRING;
*/
--END IF;
SET i = i+1;
END WHILE;
RETURN TRUE;
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;
this is the compute node code i am using ...
We are having cluster Queue and Cluster Queue manager.
I have mentioned Destination mode as Destination List in MQOutput Node.
But Still its not working.
Pls help me in this regard |
|
Back to top |
|
 |
Vitor |
Posted: Thu Dec 02, 2010 10:08 am Post subject: |
|
|
 Grand High Poobah
Joined: 11 Nov 2005 Posts: 26093 Location: Texas, USA
|
kumar.shanj wrote: |
Pls help me in this regard |
If you want help, be nice put code in code tags so we can read it in your posting!
Moving to the code, what is that CARDINALITY checking the destination list supposed to be achiveing? All you'd get is multiple copies of the same queue name.
Though I think the basic problem is that at no point have you mentioned changing the attributes of the Compute node to allow the destination list to be passed. _________________ Honesty is the best policy.
Insanity is the best defence. |
|
Back to top |
|
 |
joebuckeye |
Posted: Thu Dec 02, 2010 10:12 am Post subject: |
|
|
 Partisan
Joined: 24 Aug 2007 Posts: 365 Location: Columbus, OH
|
As smdavies99 said earlier, you need to check that the queue you are trying to send this message to is in a cluster with your broker queue manager.
Your code example using the queue - TAX.INTRASTAT.UK.INP - does not specify a queue manager so MQ will first look at the broker QM for this queue and if not there it will look in the clusters the broker QM is in.
If your broker QM is not in a cluster with whatever QM has the queue TAX.INTRASTAT.UK.INP on it then you will continue to get your 2085 error messages.
I think you need to use runmqsc on your broker queue manager and see if you can actually see the queue TAX.INTRASTAT.UK.INP from it. |
|
Back to top |
|
 |
j.f.sorge |
Posted: Thu Dec 02, 2010 10:20 am Post subject: |
|
|
Master
Joined: 27 Feb 2008 Posts: 218
|
I think that there is another problem as there is no PROPAGATE within the WHILE loop. The CN will only sent one message containing each record of the database to many queue with the same name. _________________ IBM Certified Solution Designer - WebSphere MQ V6.0
IBM Certified Solution Developer - WebSphere Message Broker V6.0
IBM Certified Solution Developer - WebSphere Message Broker V6.1
IBM Certified Solution Developer - WebSphere Message Broker V7.0 |
|
Back to top |
|
 |
|