Package com.norconex.committer.core.batch.queue.impl

Class FSQueueUtil

java.lang.Object

com.norconex.committer.core.batch.queue.impl.FSQueueUtil

public final class FSQueueUtil
extends Object

File sytem queue utility methods.

Method Summary

Modifier and Type	Method	Description
static Stream<Path>	findZipFiles(Path dir)	Finds all files with the ".zip" extension from within a given directory, recursively.
static CommitterRequest	fromZipFile(Path sourceFile)
static CommitterRequest	fromZipFile(Path sourceFile, CachedStreamFactory streamFactory)
static boolean	isEmpty(Path dir)	Recursively gets whether a queue directory is empty of queue files.
static void	toZipFile(CommitterRequest request, Path targetFile)

Methods inherited from class java.lang.Object

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

Method Details

isEmpty

public static boolean isEmpty(Path dir)
                       throws IOException

Recursively gets whether a queue directory is empty of queue files.

Parameters:

dir - directory to start looking

Returns:

true if empty

Throws:

IOException - if an I/O error occurs

findZipFiles

public static Stream<Path> findZipFiles(Path dir)
                                 throws IOException

Finds all files with the ".zip" extension from within a given directory, recursively.

Parameters:

dir - directory to start looking

Returns:

a stream of Zip files.

Throws:

IOException - problem occurred searching for files.

toZipFile

public static void toZipFile(CommitterRequest request,
 Path targetFile)
                      throws IOException

Throws:

IOException

fromZipFile

public static CommitterRequest fromZipFile(Path sourceFile)
                                    throws IOException

Throws:

IOException

fromZipFile

public static CommitterRequest fromZipFile(Path sourceFile,
 CachedStreamFactory streamFactory)
                                    throws IOException

Throws:

IOException