@Category(value="Advanced") public class ParallelSenders extends SenderSeries
HasStatistics.Action
senderWrapperProcessor
parameterNamesMustBeUnique, paramList
log
Constructor and Description |
---|
ParallelSenders() |
Modifier and Type | Method and Description |
---|---|
void |
configure()
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 |
createTaskExecutor() |
SenderResult |
doSendMessage(Message message,
PipeLineSession session) |
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) |
close, consumesSessionVariable, getSenders, getStatisticsKeeper, isSenderConfigured, iterateOverStatistics, open, setSender
getLogPrefix, sendMessage, setGetInputFromFixedValue, setGetInputFromSessionKey, setPreserveInput, setStoreInputInSessionKey, setStoreResultInSessionKey
addParameter, checkStringAttributeOrParameter, getParameterList, getParameterOverriddenAttributeValue, getParameterOverriddenAttributeValue, getParameterValueList
createBean, getName, setApplicationContext, setName
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getCache, setCache
isSynchronous, sendMessageOrThrow
getName, setName
getApplicationContext, getName
getConfigurationClassLoader
public void configure() throws ConfigurationException
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 the configure()
or open()
method, to improve performance.configure
in interface IConfigurable
configure
in interface ISender
configure
in class SenderSeries
ConfigurationException
public SenderResult doSendMessage(Message message, PipeLineSession session) throws SenderException, TimeoutException
doSendMessage
in class SenderSeries
SenderException
TimeoutException
public void setSynchronous(boolean value)
protected org.springframework.core.task.TaskExecutor createTaskExecutor()
public void registerSender(ISender sender)
registerSender
in class SenderSeries
public void setMaxConcurrentThreads(int maxThreads)
Copyright © 2023 Frank!Framework. All rights reserved.