nl.nn.adapterframework.batch

Class ResultWriter

java.lang.Object

nl.nn.adapterframework.batch.AbstractResultHandler

nl.nn.adapterframework.batch.ResultWriter

All Implemented Interfaces:

IResultHandler, IConfigurable, IConfigurationAware, INamedObject, IScopeProvider, IWithParameters, org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware

Direct Known Subclasses:

Result2Filewriter, Result2LobWriterBase, Result2StringWriter

public abstract class ResultWriter
extends AbstractResultHandler

Baseclass for resulthandlers that write the transformed record to a writer.

Since:

4.7

Author:

Gerrit van Brakel

Field Summary

Fields inherited from class nl.nn.adapterframework.batch.AbstractResultHandler

log, paramList

Constructor Summary

Constructors

Constructor and Description
ResultWriter()

Method Summary

Modifier and Type	Method and Description
void	closeBlock(PipeLineSession session, String streamId, String blockName, Map<String,Object> blocks)
void	closeDocument(PipeLineSession session, String streamId)
void	closeRecordType(PipeLineSession session, String streamId)
protected abstract Writer	createWriter(PipeLineSession session, String streamId)
String	finalizeResult(PipeLineSession session, String streamId, boolean error) Called when all records in the original file are handled.
protected Writer	getWriter(PipeLineSession session, String streamId, boolean create)
void	handleResult(PipeLineSession session, String streamId, String recordKey, String result) write a result record.
void	openBlock(PipeLineSession session, String streamId, String blockName, Map<String,Object> blocks)
void	openDocument(PipeLineSession session, String streamId) Called once, before the first record of a stream is presented to handleResult.
void	openRecordType(PipeLineSession session, String streamId)
protected String	replacePattern(String target, String blockName)
void	setBlockNamePattern(String pattern) string that is replaced by name of block or name of stream in above strings
void	setOnCloseBlock(String line) string that is written after the end of each logical block, as defined in the flow
void	setOnCloseDocument(String line) string that is written after all data of results is written
void	setOnOpenBlock(String line) string that is written before the start of each logical block, as defined in the flow
void	setOnOpenDocument(String line) string that is written before any data of results is written
protected void	writeNewLine(Writer w)

Methods inherited from class nl.nn.adapterframework.batch.AbstractResultHandler

addParameter, close, configure, getParameterList, hasPrefix, isDefault, open, setBlockByRecordType, setDefault, setName, setPipe, setPrefix, setSuffix

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.batch.IResultHandler

isBlockByRecordType

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

getName

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

getApplicationContext, getName

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

getConfigurationClassLoader

Methods inherited from interface org.springframework.context.ApplicationContextAware

setApplicationContext

Constructor Detail

ResultWriter

public ResultWriter()

Method Detail

createWriter

protected abstract Writer createWriter(PipeLineSession session,
                                       String streamId)
                                throws Exception

Throws:

Exception

openDocument

public void openDocument(PipeLineSession session,
                         String streamId)
                  throws Exception

Description copied from interface: IResultHandler

Called once, before the first record of a stream is presented to handleResult.

Specified by:

openDocument in interface IResultHandler

Overrides:

openDocument in class AbstractResultHandler

Parameters:

session - current PipeLineSession

streamId - identification of the original file/stream/message

Throws:

Exception

closeDocument

public void closeDocument(PipeLineSession session,
                          String streamId)

Specified by:

closeDocument in interface IResultHandler

Overrides:

closeDocument in class AbstractResultHandler

finalizeResult

public String finalizeResult(PipeLineSession session,
                             String streamId,
                             boolean error)
                      throws Exception

Description copied from interface: IResultHandler

Called when all records in the original file are handled.

Parameters:

session - current PipeLineSession

streamId - identification of the original file/stream/message containing the untransformed records

Returns:

the name or names of the output files

Throws:

Exception

handleResult

public void handleResult(PipeLineSession session,
                         String streamId,
                         String recordKey,
                         String result)
                  throws Exception

Description copied from interface: IResultHandler

write a result record.

Parameters:

session - current PipeLineSession

streamId - identification of the original file/stream/message containing the untransformed records

recordKey - key of the record (describes the record type)

result - transformed record

Throws:

Exception

writeNewLine

protected void writeNewLine(Writer w)
                     throws IOException

Throws:

IOException

openRecordType

public void openRecordType(PipeLineSession session,
                           String streamId)
                    throws Exception

Parameters:

session - current PipeLineSession

streamId - identification of the original file/stream/message containing the untransformed records

Throws:

Exception

closeRecordType

public void closeRecordType(PipeLineSession session,
                            String streamId)
                     throws Exception

Parameters:

session - current PipeLineSession

streamId - identification of the original file/stream/message containing the untransformed records

Throws:

Exception

replacePattern

protected String replacePattern(String target,
                                String blockName)

openBlock

public void openBlock(PipeLineSession session,
                      String streamId,
                      String blockName,
                      Map<String,Object> blocks)
               throws Exception

Throws:

Exception

closeBlock

public void closeBlock(PipeLineSession session,
                       String streamId,
                       String blockName,
                       Map<String,Object> blocks)
                throws Exception

Throws:

Exception

getWriter

protected Writer getWriter(PipeLineSession session,
                           String streamId,
                           boolean create)
                    throws Exception

Throws:

Exception

setOnOpenDocument

public void setOnOpenDocument(String line)

string that is written before any data of results is written

Default value

<document name="#name#">

setOnCloseDocument

public void setOnCloseDocument(String line)

string that is written after all data of results is written

Default value

</document>

setOnOpenBlock

public void setOnOpenBlock(String line)

string that is written before the start of each logical block, as defined in the flow

Default value

<#name#>

setOnCloseBlock

public void setOnCloseBlock(String line)

string that is written after the end of each logical block, as defined in the flow

Default value

</#name#>

setBlockNamePattern

public void setBlockNamePattern(String pattern)

string that is replaced by name of block or name of stream in above strings

Default value

#name#