Class FileSystemTransporter.DirectoryHandler

java.lang.Object
services.moleculer.transporter.FileSystemTransporter.DirectoryHandler
Enclosing class:
FileSystemTransporter
protected static class FileSystemTransporter.DirectoryHandler extends Object

  • Field Details

    • logger

      protected final org.slf4j.Logger logger

    • directory

      protected final 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 HashSet<FileSystemTransporter.RemovableFile> removableFiles

    • loadedFiles

      protected LinkedHashMap<String,Long> loadedFiles

    • lastChecked

      protected volatile long lastChecked

    • lastModified

      protected volatile long lastModified

  • Constructor Details

    • DirectoryHandler

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

  • Method Details

    • readAndRemoveNextFiles

      protected LinkedList<byte[]> readAndRemoveNextFiles()

    • listFiles

      protected File[] listFiles(long now)

    • saveTempFile

      protected void saveTempFile(byte[] bytes)

    • removeTimeoutedFiles

      protected void removeTimeoutedFiles()

    • removeAllFiles

      protected void removeAllFiles()

    • removeAllSavedFiles

      protected void removeAllSavedFiles()