org.mule.extension.file.common.api

Class AbstractFileInputStreamSupplier

java.lang.Object

org.mule.extension.file.common.api.AbstractFileInputStreamSupplier

All Implemented Interfaces:

Supplier<InputStream>

public abstract class AbstractFileInputStreamSupplier
extends Object
implements Supplier<InputStream>

This is an abstract class that implements Supplier adding the logic to check that the file size is stable. Each subclass should give implementations of getUpdatedAttributes(), to be able to get the size of the file, and getContentInputStream(), to get the InputStream that is supplied.

Since:

1.2

Field Summary

Fields

Modifier and Type	Field and Description
protected FileAttributes	attributes
protected static String	FILE_NO_LONGER_EXISTS_MESSAGE

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractFileInputStreamSupplier(FileAttributes attributes, Long timeBetweenSizeCheck)

Method Summary

Modifier and Type	Method and Description
InputStream	get()
protected abstract InputStream	getContentInputStream() Gets the InputStream of the file described by the attributes passed to the constructor
protected abstract FileAttributes	getUpdatedAttributes() Gets the updated attributes of the file.
protected void	onFileDeleted()
protected void	onFileDeleted(Exception e)

Methods inherited from class java.lang.Object

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

Field Detail

FILE_NO_LONGER_EXISTS_MESSAGE

protected static final String FILE_NO_LONGER_EXISTS_MESSAGE

See Also:

Constant Field Values

attributes

protected FileAttributes attributes

Constructor Detail

AbstractFileInputStreamSupplier

protected AbstractFileInputStreamSupplier(FileAttributes attributes,
                                          Long timeBetweenSizeCheck)

Method Detail

get

public InputStream get()

Specified by:

get in interface Supplier<InputStream>

onFileDeleted

protected void onFileDeleted()

onFileDeleted

protected void onFileDeleted(Exception e)

getUpdatedAttributes

protected abstract FileAttributes getUpdatedAttributes()

Gets the updated attributes of the file.

Returns:

the updated attributes accourding to the path of the variable attributes passed in the constructor

getContentInputStream

protected abstract InputStream getContentInputStream()

Gets the InputStream of the file described by the attributes passed to the constructor

Returns:

the InputStream of the file