|
xmlBlaster 2.2.0 API | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.xmlBlaster.contrib.filewatcher.Publisher
public class Publisher
Publisher
Nested Class Summary | |
---|---|
class |
Publisher.ReplSource
|
class |
Publisher.ReplSourceData
|
Field Summary | |
---|---|
private I_XmlBlasterAccess |
access
|
private ConnectQos |
connectQos
|
private boolean |
copyOnMove
|
private long |
delaySinceLastFileChange
|
private DirectoryManager[] |
directoryManagers
|
private java.lang.String |
directoryName
|
private java.lang.String |
discarded
|
private java.lang.String |
fileFilter
|
private java.lang.String |
filterType
|
private boolean |
forceShutdown
used to break the loop in doPublish when shutting down |
private Global |
global
|
private I_Info |
info_
|
private boolean |
isActive
|
private boolean |
isShutdown
used to identify if it has shut down (to get a new global) |
private java.lang.String |
lockExtention
|
private static java.util.logging.Logger |
log
|
private int |
maximumChunkSize
|
private long |
maximumFileSize
|
private java.lang.String |
ME
|
private java.lang.String |
name
only used as a default login name and logging |
private long |
pollInterval
|
private XmlBlasterPublisher |
publisher
|
private java.lang.String |
publishKey
|
private java.lang.String |
publishQos
|
private boolean |
recursive
|
private java.lang.String |
replPrefix
|
private Publisher.ReplSource |
replSource
|
private ReplSourceEngine |
replSourceEngine
|
private java.lang.String |
sent
|
private static Timeout |
timeout
|
private Timestamp |
timeoutHandle
|
static java.lang.String |
USE_REGEX
|
Constructor Summary | |
---|---|
Publisher(Global globOrig,
java.lang.String name,
I_Info info)
|
Method Summary | |
---|---|
void |
activate()
|
private void |
activatePoller()
|
private void |
createDirectoryManagers()
Create the file checker instance with the current configuration. |
void |
deActivate()
|
private FileInfo[] |
doPublish(DirectoryManager directoryManager)
Publish file or files to xmlBlaster. |
private java.lang.String[] |
getChildDirectories(boolean isRecursive,
DirectoryManager rootDirManager)
|
long |
getDelaySinceLastFileChange()
|
java.lang.String |
getDirectoryName()
|
java.lang.String |
getDiscarded()
|
java.lang.String |
getFileFilter()
|
java.lang.String |
getFilterType()
|
java.lang.String |
getLockExtention()
|
long |
getMaximumFileSize()
|
long |
getPollInterval()
|
java.lang.String |
getSent()
|
private java.lang.String |
getSubDir(DirectoryManager root,
java.lang.String base,
java.lang.String subDir)
|
void |
init()
Connects to the xmlBlaster. |
boolean |
isActive()
|
boolean |
isCopyOnMove()
|
boolean |
isRecursive()
|
private java.lang.String |
preparePubQos(java.lang.String origQos)
|
private void |
prepareReplSource(boolean doFill)
|
void |
publish()
Fail-safe sending files. |
private void |
reCreateDirectoryManagers()
Useful for JMX invocations |
void |
setCopyOnMove(boolean copyOnMove)
|
void |
setDelaySinceLastFileChange(long delaySinceLastFileChange)
|
void |
setDirectoryName(java.lang.String directoryName)
|
void |
setDiscarded(java.lang.String discarded)
|
void |
setFileFilter(java.lang.String fileFilter)
|
void |
setFilterType(java.lang.String filterType)
|
void |
setLockExtention(java.lang.String lockExtention)
|
void |
setMaximumFileSize(long maximumFileSize)
|
void |
setPollInterval(long pollInterval)
|
void |
setRecursive(boolean rec)
|
void |
setSent(java.lang.String sent)
|
void |
shutdown()
If an exception occurs it means it could not publish the entry |
void |
timeout(java.lang.Object userData)
You will be notified about the timeout through this method. |
java.lang.String |
toString()
|
java.lang.String |
toString(FileInfo[] infos,
int max)
Create a comma separated list of file names. |
java.lang.String |
triggerScan()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Field Detail |
---|
private java.lang.String ME
private Global global
private static java.util.logging.Logger log
private DirectoryManager[] directoryManagers
private I_XmlBlasterAccess access
private java.lang.String publishKey
private java.lang.String publishQos
private ConnectQos connectQos
private long pollInterval
private long maximumFileSize
private java.lang.String fileFilter
private java.lang.String filterType
private java.lang.String directoryName
private boolean copyOnMove
private java.lang.String sent
private java.lang.String discarded
private java.lang.String lockExtention
private long delaySinceLastFileChange
private boolean recursive
public static final java.lang.String USE_REGEX
private Timestamp timeoutHandle
private static Timeout timeout
private boolean isShutdown
private boolean forceShutdown
private java.lang.String name
private boolean isActive
private int maximumChunkSize
private java.lang.String replPrefix
private I_Info info_
private Publisher.ReplSource replSource
private ReplSourceEngine replSourceEngine
private XmlBlasterPublisher publisher
Constructor Detail |
---|
public Publisher(Global globOrig, java.lang.String name, I_Info info) throws XmlBlasterException
XmlBlasterException
Method Detail |
---|
private void prepareReplSource(boolean doFill) throws XmlBlasterException
XmlBlasterException
private java.lang.String getSubDir(DirectoryManager root, java.lang.String base, java.lang.String subDir)
private java.lang.String[] getChildDirectories(boolean isRecursive, DirectoryManager rootDirManager)
private void createDirectoryManagers() throws XmlBlasterException
XmlBlasterException
private void reCreateDirectoryManagers()
public java.lang.String toString()
toString
in class java.lang.Object
public void init() throws XmlBlasterException
XmlBlasterException
public void shutdown() throws XmlBlasterException
XmlBlasterException
public void publish()
public java.lang.String toString(FileInfo[] infos, int max)
infos
- max
- Max file names to collect
private java.lang.String preparePubQos(java.lang.String origQos) throws XmlBlasterException
XmlBlasterException
private FileInfo[] doPublish(DirectoryManager directoryManager) throws XmlBlasterException
XmlBlasterException
private void activatePoller()
public void timeout(java.lang.Object userData)
I_Timeout
timeout
in interface I_Timeout
userData
- You get bounced back your userData which you passed
with Timeout.addTimeoutListener()I_Timeout.timeout(java.lang.Object)
public void activate() throws java.lang.Exception
java.lang.Exception
public void deActivate()
public boolean isActive()
public java.lang.String triggerScan()
public java.lang.String getDirectoryName()
public void setDirectoryName(java.lang.String directoryName)
directoryName
- The directoryName to set.public java.lang.String getFileFilter()
public void setFileFilter(java.lang.String fileFilter)
fileFilter
- The fileFilter to set.public java.lang.String getFilterType()
public void setFilterType(java.lang.String filterType)
filterType
- The filterType to set.public long getMaximumFileSize()
public void setMaximumFileSize(long maximumFileSize)
maximumFileSize
- The maximumFileSize to set.public long getPollInterval()
public void setPollInterval(long pollInterval)
pollInterval
- The pollInterval to set.public boolean isCopyOnMove()
public void setCopyOnMove(boolean copyOnMove)
copyOnMove
- The copyOnMove to set.public long getDelaySinceLastFileChange()
public void setDelaySinceLastFileChange(long delaySinceLastFileChange)
delaySinceLastFileChange
- The delaySinceLastFileChange to set.public java.lang.String getDiscarded()
public void setDiscarded(java.lang.String discarded)
discarded
- The discarded to set.public java.lang.String getLockExtention()
public void setLockExtention(java.lang.String lockExtention)
lockExtention
- The lockExtention to set.public java.lang.String getSent()
public void setSent(java.lang.String sent)
sent
- The sent to set.public boolean isRecursive()
public void setRecursive(boolean rec)
|
xmlBlaster 2.2.0 API | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |