nl.nn.adapterframework.batch

Class ResultBlock2Sender

java.lang.Object

nl.nn.adapterframework.batch.AbstractResultHandler

nl.nn.adapterframework.batch.ResultWriter

nl.nn.adapterframework.batch.Result2StringWriter

nl.nn.adapterframework.batch.ResultBlock2Sender

All Implemented Interfaces:

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

public class ResultBlock2Sender
extends Result2StringWriter

ResultHandler that collects a number of records and sends them together to a sender.

Since:

4.7

Author:

Gerrit van Brakel

Parameters

any parameters defined on the resultHandler will be handed to the sender, if this is a ISenderWithParameters

Field Summary

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

log, paramList

Constructor Summary

Constructors

Constructor and Description
ResultBlock2Sender()

Method Summary

Modifier and Type	Method and Description
void	close()
void	closeBlock(PipeLineSession session, String streamId, String blockName, Map<String,Object> blocks)
void	closeDocument(PipeLineSession session, String streamId)
void	configure()
protected int	decLevel(String streamId)
protected int	getCounter(String streamId)
int	getLevel(String streamId)
protected int	incCounter(String streamId)
protected int	incLevel(String streamId)
void	open()
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	setSender(ISender sender) Sender to which each block of results is sent

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

createWriter, finalizeResult

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

closeRecordType, getWriter, handleResult, openRecordType, replacePattern, setBlockNamePattern, setOnCloseBlock, setOnCloseDocument, setOnOpenBlock, setOnOpenDocument, writeNewLine

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

addParameter, getParameterList, hasPrefix, isDefault, 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

ResultBlock2Sender

public ResultBlock2Sender()

Method Detail

configure

public void configure()
               throws ConfigurationException

Specified by:

configure in interface IConfigurable

Overrides:

configure in class AbstractResultHandler

Throws:

ConfigurationException

open

public void open()
          throws SenderException

Specified by:

open in interface IResultHandler

Overrides:

open in class AbstractResultHandler

Throws:

SenderException

close

public void close()
           throws SenderException

Specified by:

close in interface IResultHandler

Overrides:

close in class AbstractResultHandler

Throws:

SenderException

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 ResultWriter

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 ResultWriter

getCounter

protected int getCounter(String streamId)
                  throws SenderException

Throws:

SenderException

incCounter

protected int incCounter(String streamId)
                  throws SenderException

Throws:

SenderException

getLevel

public int getLevel(String streamId)
             throws SenderException

Throws:

SenderException

incLevel

protected int incLevel(String streamId)
                throws SenderException

Throws:

SenderException

decLevel

protected int decLevel(String streamId)
                throws SenderException

Throws:

SenderException

openBlock

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

Specified by:

openBlock in interface IResultHandler

Overrides:

openBlock in class ResultWriter

Throws:

Exception

closeBlock

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

Specified by:

closeBlock in interface IResultHandler

Overrides:

closeBlock in class ResultWriter

Throws:

Exception

setSender

public void setSender(ISender sender)

Sender to which each block of results is sent