MQSeries.net :: View topic - Wepshere Message Broker: Input Node deploy doesnt work

vtoledoc · Posted: Wed Oct 06, 2004 4:58 am Post subject:

We are implementing a java input node, under the following software versions:

Message Broker Toolkit: 5.0.3
Message Broker : 5.0.1.3
Agent Controller: 5.0.2
Message Queue: 5.3
S.O: Windows 2000 Professional

When we deploy the input node, with the exact code from the IBM Redbook, the propagation appears to have this error from the event viewer
(it is translated, it are not the exacts words)

Environment:
Broker name: BRK_02
Message Flow name: prueba4
Execution Group: jbustamante

Error in The event viewer
------------------------------------------

( BRK_02.jbustamante )
The ouput message doesnt contains any valid MQMD; test output node 'prueba4.MQOutput'.

The WebSphere Business Integration Message Brokers output node has received a message to be written in the WebSphere Business Integration output queue, but the message doesnt contains any MQMD valid.
This situation can be produced when an output message is not created in a proper way using a compute node.

Check the message flow to determine if the message has been created in a proper way. If it is not so, fix the problem and deploy de broker again.

/*------------------------------------------------------------------------------------------------------------------------------------------------
* CODE EXAMPLE FROM THE IBM RED BOOK "Developing Solutions in WebSphere MQ Integrator" Version 2.1
*------------------------------------------------------------------------------------------------------------------------------------------------*/
public class FILEJInputNode extends MbInputNode implements MbInputNodeInterface{

String listenDir; /* DO NOT provide a default value */

public FILEJInputNode() throws MbException
{
createOutputTerminal("out");
createOutputTerminal("failure");
createOutputTerminal("catch");
}

public int run(MbMessageAssembly assembly) throws MbException
{
try
{
File inputFile = new File(listenDir);
File[] fileArray = inputFile.listFiles();
String mystr = fileArray[0].toString();
System.out.println(new Date().toString() + "\nSaw File: " + mystr);
FileInputStream realinputFile = new FileInputStream(fileArray[0]);
int buflen = realinputFile.available();
byte[] buffer = new byte[buflen];
realinputFile.read(buffer);
realinputFile.close();
System.out.println("File Deleted: " + fileArray[0].delete());
MbMessage msg = createMessage(buffer);
MbMessageAssembly newAssembly = new MbMessageAssembly(assembly, msg);

MbOutputTerminal out = getOutputTerminal("out");
if(out != null)
out.propagate(newAssembly);
}

catch (java.lang.ArrayIndexOutOfBoundsException laiob)
{
System.out.println(new Date().toString() + "\nListen Dir is empty: " + laiob);
try { Thread.sleep(10000); } catch (java.lang.InterruptedException jlie) { System.out.println("Couldn't Sleep: " + jlie); }
return TIMEOUT;
}

catch (java.io.FileNotFoundException fnfe)
{
System.out.println("Problem creating File Input Stream: " + fnfe);
}

catch (java.io.IOException ioe)
{
System.out.println("Problem Sizing, Reading, or Closing the Real Input File: " + ioe);
}

try { Thread.sleep(10000); } catch (java.lang.InterruptedException jlie) { System.out.println("Couldn't Sleep: " + jlie); }

return SUCCESS_CONTINUE;
}

....
}