public class MbInputNode extends MbNode
MbInputNodeInterface
page.
MbInputNode extends MbNode and provides extra methods relevant to input node functionality.
MbInputNodeInterface
MbNode.JDBC_TransactionType
Modifier and Type | Field and Description |
---|---|
static int |
FAILURE_CONTINUE
This should be returned by the
run()
method to indicate that the current transaction should be rolled back and
the same thread to call the run method again. |
static int |
FAILURE_RETURN
This should be returned by the
run()
method to indicate that the current transaction should be rolled back and
the thread to be returned to the thread pool. |
static int |
SUCCESS_CONTINUE
This should be returned by the
run()
method to indicate that the current transaction should be committed and
the same thread to call the run method again. |
static int |
SUCCESS_RETURN
This should be returned by the
run()
method to indicate that the current transaction should be committed and
the thread to be returned to the thread pool. |
static int |
TIMEOUT
This should be returned by the
run()
method rather than to wait for message data for a prolonged period. |
Constructor and Description |
---|
MbInputNode()
Default constructor
|
Modifier and Type | Method and Description |
---|---|
MbMessage |
createMessage(byte[] source)
Creates a new MbMessage object based on the input bit stream stored
in a byte array.
|
boolean |
dispatchThread()
Dispatches a new message flow thread in order to invoke another
thread instance to run the message flow user-defined input node.
|
createInputTerminal, createOutputTerminal, createSQLStatement, createSQLStatement, getAllRoutes, getAttribute, getBroker, getExecutionGroup, getInputTerminal, getInputTerminals, getJDBCType4Connection, getMessageFlow, getName, getOutputTerminal, getOutputTerminals, getRoute, getSecurityManager, getUserDefinedAttribute, setAttribute, toString
public static final int TIMEOUT
run()
method rather than to wait for message data for a prolonged period.public static final int SUCCESS_CONTINUE
run()
method to indicate that the current transaction should be committed and
the same thread to call the run
method again.public static final int SUCCESS_RETURN
run()
method to indicate that the current transaction should be committed and
the thread to be returned to the thread pool.public static final int FAILURE_CONTINUE
run()
method to indicate that the current transaction should be rolled back and
the same thread to call the run
method again.public static final int FAILURE_RETURN
run()
method to indicate that the current transaction should be rolled back and
the thread to be returned to the thread pool.public MbInputNode() throws MbException
MbException
public boolean dispatchThread() throws MbException
MbException
public MbMessage createMessage(byte[] source) throws MbException
source
- An array of bytes containing the input bit stream.MbException