org.ikasan.component.endpoint.filesystem.producer

Class FileProducer<T>

java.lang.Object

org.ikasan.component.endpoint.filesystem.producer.FileProducer<T>

All Implemented Interfaces:

Producer<T>, Configured<FileProducerConfiguration>, ConfiguredResource<FileProducerConfiguration>

public class FileProducer<T>
extends Object
implements Producer<T>, ConfiguredResource<FileProducerConfiguration>

File producer.

Author:

mitcje

Constructor Summary

Constructors

Constructor and Description
FileProducer()

Method Summary

Methods

Modifier and Type	Method and Description
FileProducerConfiguration	getConfiguration()
String	getConfiguredResourceId()
void	invoke(T message)
protected void	process(Object payload)
void	setConfiguration(FileProducerConfiguration configuration)
void	setConfiguredResourceId(String configurationId)
protected void	writeFile(File file, Object payload) Write the payload to the file based on the incoming payload type.

Methods inherited from class java.lang.Object

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

Constructor Detail

FileProducer

public FileProducer()

Method Detail

getConfiguredResourceId

public String getConfiguredResourceId()

Specified by:

getConfiguredResourceId in interface ConfiguredResource<FileProducerConfiguration>

setConfiguredResourceId

public void setConfiguredResourceId(String configurationId)

Specified by:

setConfiguredResourceId in interface ConfiguredResource<FileProducerConfiguration>

getConfiguration

public FileProducerConfiguration getConfiguration()

Specified by:

getConfiguration in interface Configured<FileProducerConfiguration>

setConfiguration

public void setConfiguration(FileProducerConfiguration configuration)

Specified by:

setConfiguration in interface Configured<FileProducerConfiguration>

invoke

public void invoke(T message)
            throws EndpointException

Specified by:

invoke in interface Producer<T>

Throws:

EndpointException

process

protected void process(Object payload)

writeFile

protected void writeFile(File file,
             Object payload)
                  throws IOException

Write the payload to the file based on the incoming payload type.

Parameters:

file -

payload -

Throws:

IOException