services.moleculer.transporter

Class FileSystemTransporter.DirectoryHandler

java.lang.Object

services.moleculer.transporter.FileSystemTransporter.DirectoryHandler

Enclosing class:

FileSystemTransporter

protected static class FileSystemTransporter.DirectoryHandler
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	debug
protected java.io.File	directory
protected long	fileTimeout
protected long	lastChecked
protected long	lastModified
protected java.util.LinkedHashMap<java.lang.String,java.lang.Long>	loadedFiles
protected org.slf4j.Logger	logger
protected boolean	polled
protected java.util.HashSet<FileSystemTransporter.RemovableFile>	removableFiles
protected boolean	shared

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	DirectoryHandler(java.io.File directory, long fileTimeout, boolean shared, boolean polled, boolean debug, int storedFileNames)

Method Summary

Modifier and Type	Method and Description
protected java.io.File[]	listFiles(long now)
protected java.util.LinkedList<byte[]>	readAndRemoveNextFiles()
protected void	removeAllFiles()
protected void	removeAllSavedFiles()
protected void	removeTimeoutedFiles()
protected void	saveTempFile(byte[] bytes)

Methods inherited from class java.lang.Object

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

Field Detail

logger

protected final org.slf4j.Logger logger

directory

protected final java.io.File directory

fileTimeout

protected final long fileTimeout

shared

protected final boolean shared

polled

protected final boolean polled

debug

protected final boolean debug

removableFiles

protected final java.util.HashSet<FileSystemTransporter.RemovableFile> removableFiles

loadedFiles

protected java.util.LinkedHashMap<java.lang.String,java.lang.Long> loadedFiles

lastChecked

protected volatile long lastChecked

lastModified

protected volatile long lastModified

Constructor Detail

DirectoryHandler

protected DirectoryHandler(java.io.File directory,
                           long fileTimeout,
                           boolean shared,
                           boolean polled,
                           boolean debug,
                           int storedFileNames)

Method Detail

readAndRemoveNextFiles

protected java.util.LinkedList<byte[]> readAndRemoveNextFiles()

listFiles

protected java.io.File[] listFiles(long now)

saveTempFile

protected void saveTempFile(byte[] bytes)

removeTimeoutedFiles

protected void removeTimeoutedFiles()

removeAllFiles

protected void removeAllFiles()

removeAllSavedFiles

protected void removeAllSavedFiles()