public static interface FileWritingMessageHandler.MessageFlushPredicate
FileExistsMode.APPEND_NO_FLUSH
an implementation of this interface is called for each file that has pending data
to flush.FileWritingMessageHandler.trigger(Message)
Modifier and Type | Method and Description |
---|---|
boolean |
shouldFlush(java.lang.String fileAbsolutePath,
long lastWrite,
org.springframework.messaging.Message<?> filterMessage) |
boolean shouldFlush(java.lang.String fileAbsolutePath, long lastWrite, org.springframework.messaging.Message<?> filterMessage)
fileAbsolutePath
- the path to the file.lastWrite
- the time of the last write - System.currentTimeMillis()
.filterMessage
- an optional message to be used in the decision process.