@Deprecated @ConfigurationWarning(value="Not tested and maintained, please look for alternatives if you use this class") public abstract class BatchTransformerPipeBase extends StreamTransformerPipe
Modifier and Type | Class and Description |
---|---|
static class |
BatchTransformerPipeBase.ResultSetReader
Deprecated.
|
Modifier and Type | Field and Description |
---|---|
protected FixedQuerySender |
querySender
Deprecated.
|
originalBlockKey
parameterNamesMustBeUnique
log
LONG_DURATION_MONITORING_EVENT, MESSAGE_SIZE_MONITORING_EVENT, PIPE_EXCEPTION_MONITORING_EVENT
Constructor and Description |
---|
BatchTransformerPipeBase()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
addParameter(Parameter p)
Deprecated.
Add a parameter to the list of parameters
|
void |
configure()
Deprecated.
checks for correct configuration of forward
|
String |
getDatasourceName()
Deprecated.
|
String |
getPhysicalDestinationName()
Deprecated.
|
String |
getQuery()
Deprecated.
|
protected abstract Reader |
getReader(ResultSet rs,
String charset,
String streamId,
PipeLineSession session)
Deprecated.
|
protected BufferedReader |
getReader(String streamId,
Message message,
PipeLineSession session)
Deprecated.
|
void |
setDatasourceName(String datasourceName)
Deprecated.
|
void |
setJmsRealm(String jmsRealmName)
Deprecated.
|
void |
setQuery(String query)
Deprecated.
|
void |
start()
Deprecated.
Perform necessary action to start the pipe.
|
void |
stop()
Deprecated.
Perform necessary actions to stop the
Pipe .For instance, closing JMS connections, DBMS connections etc. |
closeAllBlocks, doPipe, getInputStream, getManager, getRecordHandler, getResultHandler, getStreamId, registerChild, registerChild, registerChild, registerChild, registerManager, registerRecordHandler, registerResultHandler, setCharset, setCloseInputstreamOnExit, setReaderFactory, setStoreOriginalBlock
getParameterValue, setIfParam, setIfValue, setOnlyIfSessionKey, setOnlyIfValue, setSkipOnEmptyInput, setUnlessSessionKey, setUnlessValue, skipPipe
consumesSessionVariable, createBean, findForward, getAdapter, getEventSourceName, getForwards, getInSizeStatDummyObject, getOutSizeStatDummyObject, getParameterList, hasSizeStatistics, registerEvent, registerForward, setApplicationContext, setChompCharSize, setDurationThreshold, setElementToMove, setElementToMoveChain, setElementToMoveSessionKey, setEmptyInputReplacement, setGetInputFromFixedValue, setGetInputFromSessionKey, setHideRegex, setLocker, setLogIntermediaryResults, setMaxThreads, setName, setPreserveInput, setRemoveCompactMsgNamespaces, setRestoreMovedElements, setSecLogSessionKeys, setSizeStatistics, setStoreResultInSessionKey, setWriteToSecLog, throwEvent
configureTransactionAttributes, isTransacted, isTransacted, setTransacted, setTransactionTimeout
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getChompCharSize, getDurationThreshold, getElementToMove, getElementToMoveChain, getElementToMoveSessionKey, getEmptyInputReplacement, getGetInputFromFixedValue, getGetInputFromSessionKey, getLocker, getSecLogSessionKeys, getStoreResultInSessionKey, isPreserveInput, isRemoveCompactMsgNamespaces, isRestoreMovedElements, isWriteToSecLog, setPipeLine, throwEvent
getMaxThreads
getName
getApplicationContext, getName
getConfigurationClassLoader
getName
getTransactionAttribute, getTransactionTimeout, getTxDef, setTransactionAttribute
protected FixedQuerySender querySender
public void configure() throws ConfigurationException
FixedForwardPipe
configure
in interface IConfigurable
configure
in interface IPipe
configure
in class StreamTransformerPipe
ConfigurationException
public void start() throws PipeStartException
IPipe
IPipe.configure()
method, for each start and stop command of the
adapter.start
in interface IPipe
start
in class StreamTransformerPipe
PipeStartException
public void stop()
IPipe
Pipe
.stop
in interface IPipe
stop
in class StreamTransformerPipe
protected abstract Reader getReader(ResultSet rs, String charset, String streamId, PipeLineSession session) throws SenderException
SenderException
protected BufferedReader getReader(String streamId, Message message, PipeLineSession session) throws PipeRunException
getReader
in class StreamTransformerPipe
PipeRunException
public String getPhysicalDestinationName()
public void addParameter(Parameter p)
AbstractPipe
addParameter
in class AbstractPipe
@ReferTo(value=FixedQuerySender.class) public void setQuery(String query)
public String getQuery()
@ReferTo(value=FixedQuerySender.class) public void setDatasourceName(String datasourceName)
public String getDatasourceName()
@ReferTo(value=FixedQuerySender.class) @ConfigurationWarning(value="We discourage the use of jmsRealms for datasources. To specify a datasource other then the default, use the datasourceName attribute directly, instead of referring to a realm") @Deprecated public void setJmsRealm(String jmsRealmName)
Copyright © 2023 Frank!Framework. All rights reserved.