nl.nn.adapterframework.filesystem

Class ConnectedFileSystemBase<F,C>

java.lang.Object

nl.nn.adapterframework.filesystem.FileSystemBase<F>

nl.nn.adapterframework.filesystem.ConnectedFileSystemBase<F,C>

All Implemented Interfaces:

HasPhysicalDestination, IBasicFileSystem<F>

Direct Known Subclasses:

MailFileSystemBase

public abstract class ConnectedFileSystemBase<F,C>
extends FileSystemBase<F>

Baseclass for FileSystems that use a 'Connection' to connect to their storage.

Author:

Gerrit van Brakel

Field Summary

Fields inherited from class nl.nn.adapterframework.filesystem.FileSystemBase

log

Constructor Summary

Constructors

Constructor and Description
ConnectedFileSystemBase()

Method Summary

Modifier and Type	Method and Description
void	close()
protected void	closeConnection(C connection) Close connection to the FileSystem, releasing all resources.
protected abstract C	createConnection() Create a fresh connection to the FileSystem.
protected C	getConnection() Get a Connection from the pool, or the global shared connection.
void	open()
protected InputStream	pendingRelease(InputStream stream, C connection) Postpone the release of the connection to after the stream is closed.
protected void	releaseConnection(C connection, boolean invalidateConnection) Release the connection, return it to the pool or invalidate it.

Methods inherited from class nl.nn.adapterframework.filesystem.FileSystemBase

getMaxNumberOfMessagesToList, getNumberOfFilesInFolder, isOpen, setMaxNumberOfMessagesToList

Methods inherited from class java.lang.Object

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

Methods inherited from interface nl.nn.adapterframework.filesystem.IBasicFileSystem

configure, copyFile, createFolder, deleteFile, exists, folderExists, getAdditionalFileProperties, getCanonicalName, getFileSize, getModificationTime, getName, getParentFolder, listFiles, moveFile, readFile, removeFolder, toFile, toFile

Methods inherited from interface nl.nn.adapterframework.core.HasPhysicalDestination

getDomain, getPhysicalDestinationName

Constructor Detail

ConnectedFileSystemBase

public ConnectedFileSystemBase()

Method Detail

createConnection

protected abstract C createConnection()
                               throws FileSystemException

Create a fresh connection to the FileSystem.

Throws:

FileSystemException

closeConnection

protected void closeConnection(C connection)
                        throws FileSystemException

Close connection to the FileSystem, releasing all resources.

Throws:

FileSystemException

open

public void open()
          throws FileSystemException

Specified by:

open in interface IBasicFileSystem<F>

Overrides:

open in class FileSystemBase<F>

Throws:

FileSystemException

close

public void close()
           throws FileSystemException

Specified by:

close in interface IBasicFileSystem<F>

Overrides:

close in class FileSystemBase<F>

Throws:

FileSystemException

getConnection

protected C getConnection()
                   throws FileSystemException

Get a Connection from the pool, or the global shared connection.

Throws:

FileSystemException

releaseConnection

protected void releaseConnection(C connection,
                                 boolean invalidateConnection)

Release the connection, return it to the pool or invalidate it.

pendingRelease

protected InputStream pendingRelease(InputStream stream,
                                     C connection)

Postpone the release of the connection to after the stream is closed. If any IOExceptions on the stream occur, the connection is invalidated.