| java.lang.Object com.bostechcorp.cbesb.runtime.ccsl.jbi.messaging.CbConsumerProcessor
All known Subclasses: com.bostechcorp.cbesb.runtime.component.jms.processors.ConsumerProcessor, com.bostechcorp.cbesb.runtime.component.tcpip.processors.ConsumerProcessor, com.bostechcorp.cbesb.runtime.component.http.processors.ConsumerProcessor, com.bostechcorp.cbesb.runtime.ccsl.jbi.messaging.CbEmbeddedSchedulerConsumerProcessor,
CbConsumerProcessor | abstract public class CbConsumerProcessor implements IComponentProcessor(Code) | | The abtract consumer processor class for ChainBuilder ESB components. It
provides the base functions for consumer processor for consumer endpoint in
JBI component. It use JBI API to implement the JBI Message Exchange Pattern;
The component developer should extend this class and make call to the
process() method and provides implementation for abstacrt methods.
It hides the great complexity of JBI Spec and API from component developers.
author: elu |
Method Summary | |
protected void | doProcessFault(NormalizedMessage nm, String fault) | protected String | doProcessFault(NormalizedMessage nm) | abstract protected void | doProcessOut(NormalizedMessage nm, String s, MessageExchange me) | protected void | doProcessOut(NormalizedMessage nm, MessageExchange me) | protected void | doStart() | protected void | doStop() | protected ServiceDescriptionHandler | getSvcDescHandlerInstance() | protected void | handleErrorFault(MessageExchange me, Object data) Get fault message and do something with it; The child class need to
overwrite this one to provide more action such as write into a File, put
into databasee and etc al. | protected boolean | handleInOnly(Object data, MessageExchange me) | protected void | handleInOut(Object data, MessageExchange me) | protected boolean | handleRobustInOnly(Object objMsg, MessageExchange me) | public void | process(Object data) The process() method is called from the consumer processor in extended
class when it read data from external connection and turn it into an
MessageExchange and route to NMR. | public void | processInOnly(MessageExchange exchange) | public void | processInOut(MessageExchange exchange, boolean optional) | public void | processRobustInOnly(MessageExchange exchange) | public void | start() Default method is to start a Work. | public void | stop() | protected void | transform(Object data, MessageExchange me) The transform() method is to transform the data read from connection into
NormalizedMessage in the MessageExchange. |
logger | final protected transient Log logger(Code) | | |
doProcessOut | abstract protected void doProcessOut(NormalizedMessage nm, String s, MessageExchange me) throws Exception(Code) | | |
doProcessOut | protected void doProcessOut(NormalizedMessage nm, MessageExchange me) throws JBIException, CbesbException(Code) | | |
handleErrorFault | protected void handleErrorFault(MessageExchange me, Object data) throws JBIException(Code) | | Get fault message and do something with it; The child class need to
overwrite this one to provide more action such as write into a File, put
into databasee and etc al.
Parameters: me - Parameters: data - |
handleInOnly | protected boolean handleInOnly(Object data, MessageExchange me) throws JBIException(Code) | | |
handleInOut | protected void handleInOut(Object data, MessageExchange me) throws JBIException(Code) | | |
handleRobustInOnly | protected boolean handleRobustInOnly(Object objMsg, MessageExchange me) throws JBIException(Code) | | |
process | public void process(Object data)(Code) | | The process() method is called from the consumer processor in extended
class when it read data from external connection and turn it into an
MessageExchange and route to NMR.
|
processInOnly | public void processInOnly(MessageExchange exchange) throws JBIException(Code) | | |
processInOut | public void processInOut(MessageExchange exchange, boolean optional) throws JBIException(Code) | | |
processRobustInOnly | public void processRobustInOnly(MessageExchange exchange) throws JBIException(Code) | | |
start | public void start() throws Exception(Code) | | Default method is to start a Work. it is needed for BindComponent
required multi-threading processing (e.g, File, FTP, TCP)
|
transform | protected void transform(Object data, MessageExchange me) throws Exception(Code) | | The transform() method is to transform the data read from connection into
NormalizedMessage in the MessageExchange. This implementation expects
"data" to be an instance of ExternalInput. Subclasses can override this
if they have other requirements. Subclasses can also override this if
they need to copy metadata values into the exchange. Most classes should
still be able to use super.transform() to do the actual data copy.
Parameters: data - Parameters: me - throws: Exception - |
|
|