Package org.frankframework.senders

Class ShadowSender

java.lang.Object

org.frankframework.senders.AbstractSender

org.frankframework.senders.AbstractSenderWithParameters

org.frankframework.senders.AbstractSenderWrapper

org.frankframework.senders.SenderSeries

org.frankframework.senders.ParallelSenders

org.frankframework.senders.ShadowSender

All Implemented Interfaces:

ICacheEnabled<String,String>, FrankElement, HasApplicationContext, HasName, IConfigurable, IScopeProvider, ISender, ISenderWithParameters, IWithParameters, NameAware, org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware, org.springframework.context.Lifecycle

public class ShadowSender
extends ParallelSenders

Collection of Senders, that are executed all at the same time. Once the results are processed, all results will be sent to the resultSender, while the original sender will return its result to the pipeline.

Multiple sub-senders can be configured within the ShadowSender, the minimum amount of senders is 2 (originalSender + resultSender)

Since:

7.0

Author:

Niels Meijer

Field Summary

Fields inherited from class org.frankframework.senders.AbstractSenderWrapper

configurationMetrics, senderWrapperProcessor

Fields inherited from class org.frankframework.senders.AbstractSenderWithParameters

parameterNamesMustBeUnique, paramList

Fields inherited from class org.frankframework.senders.AbstractSender

log

Constructor Summary

Constructors

Constructor	Description
ShadowSender()

Method Summary

Modifier and Type	Method	Description
protected void	addResult(SaxDocumentBuilder builder, ISender sender, Map<ISender,ParallelSenderExecutor> executorMap, String tagName)
void	configure()	Configure this component.
protected void	executeGuarded(ISender sender, Message message, PipeLineSession session, Phaser guard, Map<ISender,ParallelSenderExecutor> executorMap)
SenderResult	sendMessage(Message message, PipeLineSession session)	Override this from the parallel sender as it should only execute the original and shadowsenders here!
void	setOriginalSender(String senderName)	Name of the sender that is considered that is considered to be the golden standard, i.e. the source of truth.
void	setResultSender(String senderName)	The sender name which will process the results
void	setWaitForShadowsToFinish(boolean waitForShadowsToFinish)	If true the sender will wait for all shadows to have finished.
List<ISender>	validateExecutableSenders()

Methods inherited from class org.frankframework.senders.ParallelSenders

addSender, createTaskExecutor, doSendMessage, setMaxConcurrentThreads, setSynchronous

Methods inherited from class org.frankframework.senders.SenderSeries

consumesSessionVariable, getSenders, getStatisticsKeeper, isSenderConfigured, setSender, start, stop

Methods inherited from class org.frankframework.senders.AbstractSenderWrapper

setGetInputFromFixedValue, setGetInputFromSessionKey, setName, setPreserveInput, setStoreInputInSessionKey, setStoreResultInSessionKey

Methods inherited from class org.frankframework.senders.AbstractSenderWithParameters

addParameter, checkStringAttributeOrParameter, getParameterList, getParameterOverriddenAttributeValue, getParameterOverriddenAttributeValue, getParameterValueList

Methods inherited from class org.frankframework.senders.AbstractSender

createBean, getLogPrefix, getName, isRunning, setApplicationContext

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.context.ApplicationContextAware

setApplicationContext

Methods inherited from interface org.frankframework.core.FrankElement

addConfigWarning

Methods inherited from interface org.frankframework.core.HasApplicationContext

getApplicationContext, getConfigurationClassLoader

Methods inherited from interface org.frankframework.core.HasName

getName

Methods inherited from interface org.frankframework.cache.ICacheEnabled

getCache, setCache

Methods inherited from interface org.frankframework.core.ISender

isSynchronous, sendMessageOrThrow

Constructor Details

ShadowSender

public ShadowSender()

Method Details

configure

public void configure()
               throws ConfigurationException

Description copied from interface: IConfigurable

Configure this component.

configure() is called once at startup of the framework in the configure method of the owner of this IConfigurable. Purpose of this method is to check whether the static configuration of the object is correct. As much as possible class-instantiating should take place in the configure(), to improve performance.

In the case of a container, this will propagate the configure signal to all components that apply.

Specified by:

configure in interface IConfigurable

Overrides:

configure in class ParallelSenders

Throws:

ConfigurationException - in case it was not able to configure the component.

validateExecutableSenders

public List<ISender> validateExecutableSenders()
                                        throws ConfigurationException

Throws:

ConfigurationException

executeGuarded

protected void executeGuarded(ISender sender,
 Message message,
 PipeLineSession session,
 Phaser guard,
 Map<ISender,ParallelSenderExecutor> executorMap)
                       throws SenderException

Throws:

SenderException

sendMessage

@Nonnull
public SenderResult sendMessage(@Nonnull
 Message message,
 @Nonnull
 PipeLineSession session)
                         throws SenderException,
TimeoutException

Override this from the parallel sender as it should only execute the original and shadowsenders here!

Specified by:

sendMessage in interface ISender

Overrides:

sendMessage in class AbstractSenderWrapper

Throws:

SenderException

TimeoutException

addResult

protected void addResult(SaxDocumentBuilder builder,
 ISender sender,
 Map<ISender,ParallelSenderExecutor> executorMap,
 String tagName)
                  throws SAXException,
IOException

Throws:

SAXException

IOException

setOriginalSender

public void setOriginalSender(String senderName)

Name of the sender that is considered that is considered to be the golden standard, i.e. the source of truth.

Default value

the first sender specified

setResultSender

public void setResultSender(String senderName)

The sender name which will process the results

Default value

the last sender specified

setWaitForShadowsToFinish

public void setWaitForShadowsToFinish(boolean waitForShadowsToFinish)

If true the sender will wait for all shadows to have finished. Otherwise the collection of results will happen in a background thread.

Default value

false