Class DirPoll

java.lang.Object

org.jpos.util.SimpleLogSource

org.jpos.util.DirPoll

All Implemented Interfaces:

FilenameFilter, Runnable, Configurable, Destroyable, LogSource

public class DirPoll
extends SimpleLogSource
implements Runnable, FilenameFilter, Configurable, Destroyable

DirPoll operates on a set of directories which defaults to

• request
• response
• tmp
• run
• bad
• archive

scanning for incoming requests (of varying priorities) on the request directory and processing them by means of DirPoll.Processor or DirPoll.FileProcessor

Since:

jPOS 1.2.7

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	DirPoll.DirPollException
static interface	DirPoll.FileProcessor
static interface	DirPoll.Processor
class	DirPoll.ProcessorRunner

Field Summary

Fields

Modifier and Type	Field	Description
protected Configuration	cfg

Fields inherited from class SimpleLogSource

logger, realm

Constructor Summary

Constructors

Constructor	Description
DirPoll()

Method Summary

Modifier and Type	Method	Description
boolean	accept(File dir, String name)
void	addPriority(String fileExtension)
void	createDirs()
void	destroy()
protected File	getArchiveDir()
protected File	getBadDir()
String	getPath()
long	getPollInterval()
Object	getProcessor()	Return instance implementing DirPoll.FileProcessor or DirPoll.Processor
protected File	getRequestDir()
protected File	getResponseDir()
protected File	getRunDir()
protected File	getTmpDir()
boolean	isPaused()
boolean	isRegexPriorityMatching()
void	pause()
void	run()
protected File	scan()
void	setAcceptZeroLength(boolean acceptZeroLength)
void	setArchiveDateFormat(String dateFormat)
void	setArchiveDir(String dir)
void	setBadDir(String dir)
void	setConfiguration(Configuration cfg)	DirPool receives Configuration requests and pass along them to the underlying processor.
void	setPath(String base)
void	setPollInterval(long pollInterval)
void	setPriorities(String priorities)
void	setProcessor(Object processor)
void	setRegexPriorityMatching(boolean regexPriorityMatching)
void	setRequestDir(String dir)
void	setResponseDir(String dir)
void	setResponseSuffix(String suffix)
void	setRunDir(String dir)
void	setShouldArchive(boolean shouldArchive)
void	setShouldCompressArchive(boolean shouldCompressArchive)
void	setShouldTimestampArchive(boolean shouldTimestampArchive)
void	setThreadPool(ExecutorService executor)
void	setTmpDir(String dir)
void	unpause()

Methods inherited from class SimpleLogSource

error, error, getLogger, getRealm, info, info, setLogger, setRealm, warning, warning

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

cfg

protected Configuration cfg

Constructor Details

DirPoll

public DirPoll()

Method Details

setPath

public void setPath(String base)

setShouldTimestampArchive

public void setShouldTimestampArchive(boolean shouldTimestampArchive)

setArchiveDateFormat

public void setArchiveDateFormat(String dateFormat)

setShouldArchive

public void setShouldArchive(boolean shouldArchive)

setShouldCompressArchive

public void setShouldCompressArchive(boolean shouldCompressArchive)

setAcceptZeroLength

public void setAcceptZeroLength(boolean acceptZeroLength)

getPath

public String getPath()

setRequestDir

public void setRequestDir(String dir)

setResponseDir

public void setResponseDir(String dir)

setTmpDir

public void setTmpDir(String dir)

setBadDir

public void setBadDir(String dir)

setRunDir

public void setRunDir(String dir)

setArchiveDir

public void setArchiveDir(String dir)

setPollInterval

public void setPollInterval(long pollInterval)

setResponseSuffix

public void setResponseSuffix(String suffix)

getPollInterval

public long getPollInterval()

setProcessor

public void setProcessor(Object processor)

getRequestDir

protected File getRequestDir()

getResponseDir

protected File getResponseDir()

getTmpDir

protected File getTmpDir()

getBadDir

protected File getBadDir()

getRunDir

protected File getRunDir()

getArchiveDir

protected File getArchiveDir()

isRegexPriorityMatching

public boolean isRegexPriorityMatching()

setRegexPriorityMatching

public void setRegexPriorityMatching(boolean regexPriorityMatching)

getProcessor

public Object getProcessor()

Return instance implementing DirPoll.FileProcessor or DirPoll.Processor

Returns:

Object - need to be casted to DirPoll.FileProcessor or DirPoll.Processor

setConfiguration

public void setConfiguration(Configuration cfg)
                      throws ConfigurationException

DirPool receives Configuration requests and pass along them to the underlying processor.

Specified by:

setConfiguration in interface Configurable

Parameters:

cfg - Configuration object

Throws:

ConfigurationException - on errors

setPriorities

public void setPriorities(String priorities)

Parameters:

priorities - blank separated list of extensions

setThreadPool

public void setThreadPool(ExecutorService executor)

accept

public boolean accept(File dir,
 String name)

Specified by:

accept in interface FilenameFilter

run

public void run()

Specified by:

run in interface Runnable

destroy

public void destroy()

Specified by:

destroy in interface Destroyable

createDirs

public void createDirs()

addPriority

public void addPriority(String fileExtension)

scan

protected File scan()

pause

public void pause()

unpause

public void unpause()

isPaused

public boolean isPaused()