|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||
java.lang.Objectorg.jboss.soa.esb.listeners.old.AbstractListener
public abstract class AbstractListener
Base abstract listener implementation.
| Nested Class Summary | |
|---|---|
protected class |
AbstractListener.ActionProcessingPipeline
Action Processing Pipeline. |
| Field Summary | |
|---|---|
protected ConfigTree |
listenerConfig
|
protected org.apache.log4j.Logger |
logger
|
protected int |
m_iMaxThr
|
protected int |
m_iQthr
|
protected int |
m_iSleepForThreads
|
protected int |
m_iUpperThreadLimit
|
protected ActionDefinitionFactory |
m_oActionDefinitionFactory
|
protected java.lang.String[] |
m_oActions
|
protected GpListener |
m_oDad
|
protected MessageFactory |
m_oMsgFactory
|
protected java.lang.ThreadGroup |
m_oThrGrp
|
static java.lang.String |
MESSAGE_PROCESSING_ACTIONS_LIST
Name constant def for the Message attachemnt carrying the list of actions to be applied to the incomming message. |
| Constructor Summary | |
|---|---|
protected |
AbstractListener(GpListener p_oDad,
ConfigTree p_oParms,
ActionDefinitionFactory actionDefinitionFactory)
|
| Method Summary | |
|---|---|
protected abstract void |
close()
Close the listener implemenation. |
protected abstract void |
processingComplete(java.lang.Object initialMsg)
Called on the listener implementation when pipeline processing of a message is complete. |
protected abstract void |
processingError(java.lang.Object initialMsg,
ActionProcessor processor,
java.lang.Throwable error)
Called on the listener implementation when pipeline processing error has occured. |
protected abstract java.lang.Object[] |
receive()
Receive message from underlying channel implementation. |
void |
run()
Implement run method for this Runnable Will continue to run until controlling class (ref in m_oDad) indicates no more looping allowed for all child classes This condition will not prevent child processes to finish normally |
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Field Detail |
|---|
public static final java.lang.String MESSAGE_PROCESSING_ACTIONS_LIST
protected int m_iSleepForThreads
protected int m_iUpperThreadLimit
protected int m_iQthr
protected int m_iMaxThr
protected java.lang.ThreadGroup m_oThrGrp
protected org.apache.log4j.Logger logger
protected GpListener m_oDad
protected ConfigTree listenerConfig
protected java.lang.String[] m_oActions
protected ActionDefinitionFactory m_oActionDefinitionFactory
protected MessageFactory m_oMsgFactory
| Constructor Detail |
|---|
protected AbstractListener(GpListener p_oDad,
ConfigTree p_oParms,
ActionDefinitionFactory actionDefinitionFactory)
throws java.lang.Exception
java.lang.Exception| Method Detail |
|---|
public void run()
run in interface java.lang.Runnableprotected abstract java.lang.Object[] receive()
protected abstract void processingError(java.lang.Object initialMsg,
ActionProcessor processor,
java.lang.Throwable error)
initialMsg - The message that was initialy supplied to the pipeline.processor - The processor that raised the error. Can be null where the error was raised before
pipeline processing of the message.error - The error. Can be null.protected abstract void processingComplete(java.lang.Object initialMsg)
initialMsg - The message that was initialy supplied to the pipeline.protected abstract void close()
|
|||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||