org.springframework.integration.adapter.file
Class Backlog<T>
java.lang.Object
org.springframework.integration.adapter.file.Backlog<T>
public class Backlog<T>
- extends java.lang.Object
Tracks changes in a collection. This implementation is thread-safe as it
allows to synchronously process a new directory structure.
- Author:
- Marius Bogoevici, Mark Fisher, Iwein Fuld
Field Summary |
private java.util.Map<java.lang.String,T> |
backlog
|
private org.apache.commons.logging.Log |
logger
|
private java.util.Map<java.lang.String,T> |
previousSnapshot
|
private java.lang.ThreadLocal<java.util.Map<java.lang.String,T>> |
processingBuffer
This is the storage for backlog that is being processed by a specific
thread. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
logger
private final org.apache.commons.logging.Log logger
previousSnapshot
private java.util.Map<java.lang.String,T> previousSnapshot
backlog
private final java.util.Map<java.lang.String,T> backlog
processingBuffer
private java.lang.ThreadLocal<java.util.Map<java.lang.String,T>> processingBuffer
- This is the storage for backlog that is being processed by a specific
thread. Not initialized means that we're not in thread safe mode (just
working directly on the backlog)
Backlog
public Backlog()
processSnapshot
public void processSnapshot(java.util.Map<java.lang.String,T> currentSnapshot)
itemProcessing
public void itemProcessing(java.lang.String... keys)
processingFailed
public void processingFailed()
fileProcessed
public void fileProcessed(java.lang.String... keys)
getBacklog
public java.util.Map<java.lang.String,T> getBacklog()
getProcessingBuffer
public java.util.Map<java.lang.String,T> getProcessingBuffer()