| java.lang.Object com.bostechcorp.cbesb.runtime.ccsl.jbi.messaging.ScheduledProcessHandler
All known Subclasses: com.bostechcorp.cbesb.runtime.component.email.processors.EmailConsumerHandler, com.bostechcorp.cbesb.runtime.component.script.processors.ScriptConsumerHandler, com.bostechcorp.cbesb.runtime.component.file.processors.FileConsumerHandler, com.bostechcorp.cbesb.runtime.component.ftp.processors.FtpConsumerHandler,
ScheduledProcessHandler | abstract public class ScheduledProcessHandler (Code) | | This is the base class that should be extended by concrete Binding Components
that support polling or schedules. This acts as the consumer rather than
implementing a concrete ConsumerProvider class.
|
Method Summary | |
protected void | doProcessFault(NormalizedMessage nm, String fault) | protected void | 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() | abstract protected boolean | doTrigger() | protected boolean | doTriggerProc() | public String | getLastError() | 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, IConsumerHandlerContext chContext) | protected void | handleInOut(Object data, MessageExchange me, IConsumerHandlerContext chContext) | protected boolean | handleRobustInOnly(Object objMsg, MessageExchange me, IConsumerHandlerContext chContext) | public void | process(Object data, IConsumerHandlerContext chContext) The process() method is called from the child consumer processor when it
read data from external connection and turn it into an MessageExchange
and route to NMR. | public void | process(Object data) | public void | processInOnly(MessageExchange exchange) | public void | processInOut(MessageExchange exchange, boolean optional) | public void | processRobustInOnly(MessageExchange exchange) | public void | setLastError(String lastError) | protected void | transform(Object data, MessageExchange me, IConsumerHandlerContext context) The transform() method is to transform the data read from connection into
NormalizedMessage in the MessageExchange. |
logger | final protected transient Log logger(Code) | | |
startProcessTime | protected long startProcessTime(Code) | | |
doProcessFault | protected void doProcessFault(NormalizedMessage nm) throws JBIException, CbesbException(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) | | |
getLastError | public String getLastError()(Code) | | the lastError |
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 - |
process | public void process(Object data, IConsumerHandlerContext chContext)(Code) | | The process() method is called from the child consumer processor 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) | | |
setLastError | public void setLastError(String lastError)(Code) | | Parameters: lastError - the lastError to set |
transform | protected void transform(Object data, MessageExchange me, IConsumerHandlerContext context) 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 - |
|
|