Package org.frankframework.senders
Class ParallelSenders
java.lang.Object
org.frankframework.senders.SenderBase
org.frankframework.senders.SenderWithParametersBase
org.frankframework.senders.SenderWrapperBase
org.frankframework.senders.SenderSeries
org.frankframework.senders.ParallelSenders
- All Implemented Interfaces:
ICacheEnabled<String,
,String> AdapterAware
,IConfigurable
,IConfigurationAware
,INamedObject
,IScopeProvider
,ISender
,ISenderWithParameters
,IWithParameters
,org.springframework.beans.factory.Aware
,org.springframework.context.ApplicationContextAware
- Direct Known Subclasses:
ShadowSender
Collection of Senders, that are executed all at the same time.
- Since:
- 4.9
- Author:
- Gerrit van Brakel
-
Field Summary
Fields inherited from class org.frankframework.senders.SenderWrapperBase
adapter, configurationMetrics, senderWrapperProcessor
Fields inherited from class org.frankframework.senders.SenderWithParametersBase
parameterNamesMustBeUnique, paramList
Fields inherited from class org.frankframework.senders.SenderBase
log
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
configure()
is called once at startup of the framework in the configure method of the owner of this sender.protected org.springframework.core.task.TaskExecutor
doSendMessage
(Message message, PipeLineSession session) org.springframework.core.task.TaskExecutor
int
void
registerSender
(ISender sender) one or more specifications of senders.void
setMaxConcurrentThreads
(int maxThreads) Set the upper limit to the amount of concurrent threads that can be run simultaneously.void
setSynchronous
(boolean value) Methods inherited from class org.frankframework.senders.SenderSeries
close, consumesSessionVariable, getSenders, getStatisticsKeeper, isSenderConfigured, isSynchronous, open, setSender
Methods inherited from class org.frankframework.senders.SenderWrapperBase
getCache, getGetInputFromFixedValue, getGetInputFromSessionKey, getStoreInputInSessionKey, getStoreResultInSessionKey, isPreserveInput, sendMessage, setAdapter, setCache, setConfigurationMetrics, setGetInputFromFixedValue, setGetInputFromSessionKey, setPreserveInput, setSenderWrapperProcessor, setStoreInputInSessionKey, setStoreResultInSessionKey
Methods inherited from class org.frankframework.senders.SenderWithParametersBase
addParameter, checkStringAttributeOrParameter, getParameterList, getParameterOverriddenAttributeValue, getParameterOverriddenAttributeValue, getParameterValueList
Methods inherited from class org.frankframework.senders.SenderBase
createBean, getApplicationContext, getConfigurationClassLoader, getLogPrefix, getName, setApplicationContext, setName
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.IConfigurationAware
getApplicationContext, getName
Methods inherited from interface org.frankframework.core.INamedObject
getName, setName
Methods inherited from interface org.frankframework.core.IScopeProvider
getConfigurationClassLoader
Methods inherited from interface org.frankframework.core.ISender
sendMessageOrThrow
-
Constructor Details
-
ParallelSenders
public ParallelSenders()
-
-
Method Details
-
configure
Description copied from interface:ISender
configure()
is called once at startup of the framework in the configure method of the owner of this sender. Purpose of this method is to check whether the static configuration of the sender is correct. As much as possible class-instantiating should take place in theconfigure()
oropen()
method, to improve performance.- Specified by:
configure
in interfaceIConfigurable
- Specified by:
configure
in interfaceISender
- Overrides:
configure
in classSenderSeries
- Throws:
ConfigurationException
-
doSendMessage
- Overrides:
doSendMessage
in classSenderSeries
- Throws:
SenderException
-
setSynchronous
public void setSynchronous(boolean value) - Overrides:
setSynchronous
in classSenderSeries
-
createTaskExecutor
protected org.springframework.core.task.TaskExecutor createTaskExecutor() -
registerSender
one or more specifications of senders. Each will receive the same input message, to be processed in parallel- Overrides:
registerSender
in classSenderSeries
-
setMaxConcurrentThreads
public void setMaxConcurrentThreads(int maxThreads) Set the upper limit to the amount of concurrent threads that can be run simultaneously. Use 0 to disable.- Default value
- 0
-
getMaxConcurrentThreads
public int getMaxConcurrentThreads() -
getExecutor
public org.springframework.core.task.TaskExecutor getExecutor()
-