-
Notifications
You must be signed in to change notification settings - Fork 87
SenderWrapperSender
BonnoSmeele edited this page Oct 14, 2024
·
2 revisions
The following is a simple example configuration for using the SenderWrapperSender:
<SenderPipe name="ResultSender" preserveInput="true">
<SenderSeriesSender name="ResultSender">
<SenderWrapperSender preserveInput="true" storeResultInSessionKey="checkpoint_nr">
<FixedQuerySender queryType="SELECT"
scalar="true"
query="select max(CHECKPOINT_NR) + 1 from MESSAGES
where CORRELATION_ID = ?
and CHECKPOINT_NR < 1000">
<Param name="CORRELATION_ID" sessionKey="customId"/>
</FixedQuerySender>
</SenderWrapperSender>
<FixedQuerySender sqlDialect="Oracle"
query="insert into MESSAGES (ID, CORRELATION_ID, ENDPOINT_NAME, ENDPOINT_SEQ_NR, MESSAGE, ACTION, COMPONENT, CHECKPOINT_NR, STATUS) values
(SEQ_MESSAGES.nextval, ?{CORRELATION_ID}, ?{ENDPOINT_NAME}, 0, ?{TIBCO_RESPONSE}, 'response', 'tibco', ?{CHECKPOINT_NR}, 'ORPHAN')">
<Param name="CORRELATION_ID" sessionKey="customId"/>
<Param name="ENDPOINT_NAME" value="${GetPartyDetails_1.queue}"/>
<Param name="TIBCO_RESPONSE" />
<Param name="CHECKPOINT_NR" sessionKey="checkpoint_nr" defaultValue="1"/>
</FixedQuerySender>
</SenderSeriesSender>
</SenderPipe>