public abstract class RequestConnector extends Connector
It is used by IBM Integration Bus to send data to a system. It is created by the ConnectorFactory object which must also be implemented by a connector writer.
The RequestConnector is constructed when a node requiring it;s function is constructed. The following methods are called by IBM Integration Bus to interact with the connector:
initialize
is called a node using the connector is constructed.Terminate
is called when the node is stopped or destroyed.
The RequestConnector is called to create an OutputInteraction when ever a flow instance needs to send data to the system. The created OutputInteractions will be pooled for reuse on several threads.
createRequestInteraction
is called when IBM Integration Bus wants to send data to the end system and receive response data. Override this method to create
an RequestInteraction that can interact with the end system.
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
copyright |
Constructor and Description |
---|
RequestConnector(ConnectorFactory connectorFactory,
java.lang.String name,
java.util.Properties properties) |
Modifier and Type | Method and Description |
---|---|
abstract RequestInteraction |
createRequestInteraction()
This is called by an integration node to create an OutputInteraction to send data to the system.
|
RequestInteraction[] |
getInteractions()
Returns all OutputInteractions created by this connector that have not been terminated.
|
deccrementStatValue, decrementStatValue, getConnectorFactory, getName, getProperties, incrementStatValue, incrementStatValue, initialize, terminate, writeActivityLog, writeActivityLog
public static final java.lang.String copyright
public RequestConnector(ConnectorFactory connectorFactory, java.lang.String name, java.util.Properties properties) throws com.ibm.broker.plugin.MbException
com.ibm.broker.plugin.MbException
public abstract RequestInteraction createRequestInteraction() throws com.ibm.broker.plugin.MbException
com.ibm.broker.plugin.MbException
public final RequestInteraction[] getInteractions() throws com.ibm.broker.plugin.MbException
com.ibm.broker.plugin.MbException