org.milyn.routing.file

Class FileOutputStreamResource

java.lang.Object

org.milyn.io.AbstractOutputStreamResource

org.milyn.routing.file.FileOutputStreamResource

All Implemented Interfaces:

ContentHandler, DOMVisitBefore, DOMVisitor, ExecutionLifecycleCleanable, Consumer, SAXVisitBefore, SAXVisitor, VisitLifecycleCleanable, Visitor

public class FileOutputStreamResource
extends AbstractOutputStreamResource

An AbstractOutputStreamResource implementation that handles file output streams.

Example configuration:

 <resource-config selector="order-item">
    <resource>org.milyn.io.file.FileOutputStreamResource</resource>
    <param name="resourceName">resourceName</param>
    <param name="fileNamePattern">orderitem-${order.orderId}-${order.orderItem.itemId}.xml</param>
    <param name="destinationDirectoryPattern">order-${order.orderId}</param>
    <param name="listFileNamePattern">orderitems-${order.orderId}.lst</param>
 </resource-config>

 Optional properties (default values shown):
    <param name="highWaterMark">200</param>
    <param name="highWaterMarkTimeout">60000</param>
 

Description of configuration properties:

• resourceName: the name of this resouce. Will be used to identify this resource.
• fileNamePattern: is the pattern that will be used to generate file names. The file is created in the destinationDirectory. Supports templating.
• listFileNamePattern: is name of the file that will contain the file names generated by this configuration. The file is created in the destinationDirectory. Supports templating.
• destinationDirectoryPattern: is the destination directory for files created by this router. Supports templating.
• highWaterMark: max number of output files in the destination directory at any time.
• highWaterMarkTimeout: number of ms to wait for the system to process files in the destination directory so that the number of files drops below the highWaterMark.
• highWaterMarkPollFrequency: number of ms to wait between checks on the High Water Mark, while waiting for it to drop.
• closeOnCondition: An MVEL expression. If it returns true then the output stream is closed on the visitAfter event else it is kept open. If the expression is not set then output stream is closed by default.
• append: Will append to the file specified with the 'fileNamePattern' property. This is useful for example when you want to append to a single csv file.

When does a new file get created?
As soon as an object tries to retrieve the Writer or the OutputStream from this OutputStreamResource and the Stream isn't open then a new file is created. Using the 'closeOnCondition' property you can control when a stream get closed. As long as the stream isn't closed, the same file is used to write too. At then end of the filter process the stream always gets closed. Nothing stays open.

Author:

Daniel Bevenius, maurice.zeijen@smies.com

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	FileOutputStreamResource.SplitFilenameFilter

Field Summary

Fields inherited from class org.milyn.io.AbstractOutputStreamResource

RESOURCE_CONTEXT_KEY_PREFIX

Constructor Summary

Constructors

Constructor and Description
FileOutputStreamResource()

Method Summary

Modifier and Type	Method and Description
protected boolean	closeCondition(ExecutionContext executionContext)
protected void	closeResource(ExecutionContext executionContext) Close the resource output stream.
void	executeExecutionLifecycleCleanup(ExecutionContext executionContext) Cleanup the resources allocated by this resource for the specified ExecutionContext.
FileOutputStream	getOutputStream(ExecutionContext executionContext) Retrieve/create an output stream that is appropriate for the concreate implementation
void	initialize()
FileOutputStreamResource	setAppend(boolean append)
void	setCloseOnCondition(String closeOnCondition)
FileOutputStreamResource	setDestinationDirectoryPattern(String destinationDirectoryPattern)
FileOutputStreamResource	setFileNamePattern(String fileNamePattern)
FileOutputStreamResource	setHighWaterMark(int highWaterMark)
FileOutputStreamResource	setHighWaterMarkPollFrequency(long highWaterMarkPollFrequency)
FileOutputStreamResource	setHighWaterMarkTimeout(long highWaterMarkTimeout)
FileOutputStreamResource	setListFileNamePattern(String listFileNamePattern)
FileOutputStreamResource	setListFileNamePatternCtxKey(String listFileNamePatternCtxKey)

Methods inherited from class org.milyn.io.AbstractOutputStreamResource

consumes, executeVisitLifecycleCleanup, getOutputStream, getOutputWriter, getResourceName, getWriterEncoding, setResourceName, setWriterEncoding, visitBefore, visitBefore

Methods inherited from class java.lang.Object

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

Constructor Detail

FileOutputStreamResource

public FileOutputStreamResource()

Method Detail

setFileNamePattern

public FileOutputStreamResource setFileNamePattern(String fileNamePattern)

setDestinationDirectoryPattern

public FileOutputStreamResource setDestinationDirectoryPattern(String destinationDirectoryPattern)

setListFileNamePattern

public FileOutputStreamResource setListFileNamePattern(String listFileNamePattern)

setListFileNamePatternCtxKey

public FileOutputStreamResource setListFileNamePatternCtxKey(String listFileNamePatternCtxKey)

setHighWaterMark

public FileOutputStreamResource setHighWaterMark(int highWaterMark)

setHighWaterMarkTimeout

public FileOutputStreamResource setHighWaterMarkTimeout(long highWaterMarkTimeout)

setHighWaterMarkPollFrequency

public FileOutputStreamResource setHighWaterMarkPollFrequency(long highWaterMarkPollFrequency)

setCloseOnCondition

public void setCloseOnCondition(String closeOnCondition)

setAppend

public FileOutputStreamResource setAppend(boolean append)

initialize

@Initialize
public void initialize()
                            throws SmooksConfigurationException

Throws:

SmooksConfigurationException

getOutputStream

public FileOutputStream getOutputStream(ExecutionContext executionContext)
                                 throws SmooksRoutingException,
                                        IOException

Description copied from class: AbstractOutputStreamResource

Retrieve/create an output stream that is appropriate for the concreate implementation

Specified by:

getOutputStream in class AbstractOutputStreamResource

Parameters:

executionContext - Execution Context.

Returns:

OutputStream specific to the concreate implementation

Throws:

SmooksRoutingException

IOException

closeCondition

protected boolean closeCondition(ExecutionContext executionContext)

Overrides:

closeCondition in class AbstractOutputStreamResource

closeResource

protected void closeResource(ExecutionContext executionContext)

Description copied from class: AbstractOutputStreamResource

Close the resource output stream.

Classes overriding this method must call super on this method. This will probably need to be done before performing any aditional cleanup.

Overrides:

closeResource in class AbstractOutputStreamResource

Parameters:

executionContext - Smooks ExecutionContext

executeExecutionLifecycleCleanup

public void executeExecutionLifecycleCleanup(ExecutionContext executionContext)

Description copied from interface: ExecutionLifecycleCleanable

Cleanup the resources allocated by this resource for the specified ExecutionContext.

Executes the cleanup at the end of the filter execution.

Specified by:

executeExecutionLifecycleCleanup in interface ExecutionLifecycleCleanable

Overrides:

executeExecutionLifecycleCleanup in class AbstractOutputStreamResource

Parameters:

executionContext - The ExecutionContext.