org.jboss.soa.esb.listeners
Class RemoteDirectoryPoller

java.lang.Object
  extended by org.jboss.soa.esb.listeners.AbstractPoller
      extended by org.jboss.soa.esb.listeners.RemoteDirectoryPoller
All Implemented Interfaces:
java.lang.Runnable, java.util.Observer

public class RemoteDirectoryPoller
extends AbstractPoller


Field Summary
static java.lang.String FILE_ERROR_DIR
           
static java.lang.String FILE_ERROR_SFX
           
static java.lang.String FILE_INPUT_DIR
           
static java.lang.String FILE_INPUT_SFX
           
static java.lang.String FILE_POST_DEL
           
static java.lang.String FILE_POST_DIR
           
static java.lang.String FILE_POST_SFX
           
static java.lang.String FILE_WORK_SFX
           
protected  boolean m_bPostDel
           
protected  java.io.File m_oErrorDir
           
protected  java.io.File m_oInpDir
           
protected  java.io.File m_oPostDir
           
protected  java.lang.String m_sErrSfx
           
protected  java.lang.String m_sInpSfx
           
protected  java.lang.String m_sPostSfx
           
protected  java.lang.String m_sWrkSfx
           
 
Fields inherited from class org.jboss.soa.esb.listeners.AbstractPoller
m_iDfltPollMillis, m_iMaxThr, m_iMinPollMillis, m_iPollMillis, m_iQthr, m_iSleepForThreads, m_iUpperThreadLimit, m_oDad, m_oExecClass, m_oLogger, m_oParms, m_oThrGrp, PARM_POLL_LTCY
 
Constructor Summary
RemoteDirectoryPoller(GpListener p_oDad, DomElement p_oParms)
           
 
Method Summary
protected  void checkMyParms()
           
protected  java.util.List<java.lang.Object> pollForCandidates()
           
 java.lang.Object preProcess(java.lang.Object p_o)
           
 
Methods inherited from class org.jboss.soa.esb.listeners.AbstractPoller
checkParms, run, update
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

FILE_INPUT_DIR

public static final java.lang.String FILE_INPUT_DIR
See Also:
Constant Field Values

FILE_INPUT_SFX

public static final java.lang.String FILE_INPUT_SFX
See Also:
Constant Field Values

FILE_WORK_SFX

public static final java.lang.String FILE_WORK_SFX
See Also:
Constant Field Values

FILE_ERROR_DIR

public static final java.lang.String FILE_ERROR_DIR
See Also:
Constant Field Values

FILE_ERROR_SFX

public static final java.lang.String FILE_ERROR_SFX
See Also:
Constant Field Values

FILE_POST_DIR

public static final java.lang.String FILE_POST_DIR
See Also:
Constant Field Values

FILE_POST_SFX

public static final java.lang.String FILE_POST_SFX
See Also:
Constant Field Values

FILE_POST_DEL

public static final java.lang.String FILE_POST_DEL
See Also:
Constant Field Values

m_oInpDir

protected java.io.File m_oInpDir

m_oErrorDir

protected java.io.File m_oErrorDir

m_oPostDir

protected java.io.File m_oPostDir

m_sInpSfx

protected java.lang.String m_sInpSfx

m_sWrkSfx

protected java.lang.String m_sWrkSfx

m_sErrSfx

protected java.lang.String m_sErrSfx

m_sPostSfx

protected java.lang.String m_sPostSfx

m_bPostDel

protected boolean m_bPostDel
Constructor Detail

RemoteDirectoryPoller

public RemoteDirectoryPoller(GpListener p_oDad,
                             DomElement p_oParms)
                      throws java.lang.Exception
Throws:
java.lang.Exception
Method Detail

preProcess

public java.lang.Object preProcess(java.lang.Object p_o)
                            throws java.lang.Exception
Specified by:
preProcess in class AbstractPoller
Parameters:
p_o - Object - Must be a File representing the file that has to be processed
Returns:
Object - an array of 3 Files containing:

[0] renamed file (workSuffix appended to input file name)

[1] target file name in case actionClass is unable to complete successfuly

[2] target file name in case actionClass finishes successfuly

Throws:
java.lang.Exception

pollForCandidates

protected java.util.List<java.lang.Object> pollForCandidates()
Specified by:
pollForCandidates in class AbstractPoller

checkMyParms

protected void checkMyParms()
                     throws java.lang.Exception
Throws:
java.lang.Exception