-
Notifications
You must be signed in to change notification settings - Fork 81
ShadowSender
BonnoSmeele edited this page Oct 14, 2024
·
1 revision
<SenderPipe name="ShadowSender">
<ShadowSender originalSender="${GetDLPolicyValues_1.sendTibcoMessage}" resultSender="ResultSender">
<!-- senders are called 'true' and 'false' to be able to switch original sender between tibco and frank -->
<EsbJmsSender name="true"
lookupDestination="false"
destinationName="${GetDLPolicyValues_1.mig.queue}"
queueConnectionFactoryName="jms/qcf_tibco_esb_rr"
messageProtocol="RR"/>
<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 query="update MESSAGES m set COMPARE_STATUS='READY'
where CORRELATION_ID=?
and COMPARE_STATUS='TODO'
and COMPONENT='tibco'
and exists (select * from MESSAGES m2
where m2.CORRELATION_ID=m.CORRELATION_ID
and m2.ENDPOINT_NAME=m.ENDPOINT_NAME
and m2.ENDPOINT_SEQ_NR=m.ENDPOINT_SEQ_NR
and m2.ACTION=m.ACTION
and m2.COMPONENT='frank'
and m2.CHECKPOINT_NR < 1000)">
<Param name="CORRELATION_ID" sessionKey="customId"/>
</FixedQuerySender>
</SenderSeriesSender>
</ShadowSender>
</SenderPipe>