MQSeries.net :: View topic

marco · Posted: Wed Oct 12, 2005 11:15 pm Post subject:

Hi,

I'm writing a plugin-node to browse some Q's on certain intervals. (to see if the messages are picked up)
When initializing the node I create and fill 2 arrays, one with the queues an one with the intervals.
The data is in a DB2 table so I have to execute a statement.
(this code is only executed during init !! )

Now the problem :

when I put a message on a queue, the node does it's work, after the specified interval, the message is propagated to the out-terminal.
In debug this is :
Message
-> Properties
-> MQMD
-> BLOB
works perfect ...

I then delete the message and put a new message on the queue, again, after the speciefied interval the message is propagated
In debug :
Message
-> Properties
-> XML
-> XML Parsing Errors have occured

I've tested the "firstParserClassName" before creating the assembly to be propagated, and it still is "MQHMD" !!

To thicken the plot I can add the following :
When using a similar function that creates and fills the arrays via a jdbc-connection everything works perfect, even the second message.

What am I missing here ?

Tx
Marco

the function :

private void getQueues_brk(MbMessageAssembly assembly) throws MbException
{
MbMessage msg = createMessage("test".getBytes());
MbMessageAssembly temp = new MbMessageAssembly(assembly,msg);
MbSQLStatement state = createSQLStatement( database, "SET OutputLocalEnvironment.Q[] = PASSTHRU('"+query+"');" );
state.setThrowExceptionOnDatabaseError(false);
state.setTreatWarningsAsErrors(true);

state.select( assembly, temp );
if (DEBUG)log("the statement was executed");

MbElement root = temp.getLocalEnvironment().getRootElement();
MbElement mb_q[] = root.getAllElementsByPath("Q");

lq = new MQQueue[mb_q.length];
qNames = new String[mb_q.length];
interval = new int[mb_q.length];
testInterval = new long[mb_q.length];
qAmount = mb_q.length;

for(int i=0; i<mb_q.length;i++)
{
if(DEBUG) log("queue: "+(String)mb_q[i].getFirstChild().getValue());
qNames[i] = (String)mb_q[i].getFirstChild().getValue();

if(DEBUG) log("interval: "+((Integer)(mb_q[i].getFirstChild()).getNextSibling().getValue()).toString());
interval[i] = ((Integer)(mb_q[i].getFirstChild()).getNextSibling().getValue()).intValue();
}

destroyMessageAssembly(temp);

openQueues(-1);
}