From 8aad17eedc4f9aa9750c4560df659fb8e5c7f7ed Mon Sep 17 00:00:00 2001
From: MLenterman <marcellenterman@hotmail.com>
Date: Thu, 16 May 2024 19:02:19 +0200
Subject: [PATCH] fix: retries are incorrectly triggered due to deadlocked
 transactions

---
 ...ation_Handler_AddDocumentToCaseCommand.xml |  4 +-
 ...tion_Handler_AddDocumentsToCaseCommand.xml |  6 +-
 ...r_UpdateInitiatingSubjectGegMagCommand.xml |  6 +-
 ...figuration_UpdatePaymentCommandHandler.xml |  6 +-
 .../bpel/Configuration_WorkflowSelector.xml   |  6 +-
 .../bpel/Configuration_Workflow_Fallback.xml  |  6 +-
 ...iguration_Workflow_TwoWayCommunication.xml | 80 ++++++++++++++++++-
 .../Configuration_Workflow_UwGegevens.xml     |  6 +-
 8 files changed, 103 insertions(+), 17 deletions(-)

diff --git a/src/main/configurations/bpel/Configuration_Handler_AddDocumentToCaseCommand.xml b/src/main/configurations/bpel/Configuration_Handler_AddDocumentToCaseCommand.xml
index 260e5ab..1880c15 100644
--- a/src/main/configurations/bpel/Configuration_Handler_AddDocumentToCaseCommand.xml
+++ b/src/main/configurations/bpel/Configuration_Handler_AddDocumentToCaseCommand.xml
@@ -10,12 +10,14 @@
         <!-- <Receiver
             name="Handler_AddDocumentToCaseCommand"
             transactionAttribute="RequiresNew"
-            pollInterval="1"
+            pollInterval="5"
             maxRetries="0"
             >
             <MessageStoreListener
                 name="Handler_AddDocumentToCaseCommand"
 				slotId="${instance.name}/AddDocumentToCaseCommand"
+                peekUntransacted="true"
+                statusValueInProcess="I"
 				/>
         </Receiver> -->
 
diff --git a/src/main/configurations/bpel/Configuration_Handler_AddDocumentsToCaseCommand.xml b/src/main/configurations/bpel/Configuration_Handler_AddDocumentsToCaseCommand.xml
index 6e3e071..59ddfd8 100644
--- a/src/main/configurations/bpel/Configuration_Handler_AddDocumentsToCaseCommand.xml
+++ b/src/main/configurations/bpel/Configuration_Handler_AddDocumentsToCaseCommand.xml
@@ -8,12 +8,14 @@
         <Receiver
             name="Handler_AddDocumentsToCaseCommand"
             transactionAttribute="RequiresNew"
-            pollInterval="1"
-            maxRetries="1"
+            pollInterval="5"
+            maxRetries="0"
             >
             <MessageStoreListener
                 name="Handler_AddDocumentsToCaseCommand"
 				slotId="${instance.name}/AddDocumentsToCaseCommand"
+                peekUntransacted="true"
+                statusValueInProcess="I"
 				/>
         </Receiver>
 
diff --git a/src/main/configurations/bpel/Configuration_Handler_UpdateInitiatingSubjectGegMagCommand.xml b/src/main/configurations/bpel/Configuration_Handler_UpdateInitiatingSubjectGegMagCommand.xml
index 75e101f..9684043 100644
--- a/src/main/configurations/bpel/Configuration_Handler_UpdateInitiatingSubjectGegMagCommand.xml
+++ b/src/main/configurations/bpel/Configuration_Handler_UpdateInitiatingSubjectGegMagCommand.xml
@@ -16,12 +16,14 @@
         <!-- <Receiver
             name="Handler_UpdateInitiatingSubjectGegMagCommand"
             transactionAttribute="Required"
-            pollInterval="1"
-            maxRetries="1"
+            pollInterval="5"
+            maxRetries="0"
             >
             <MessageStoreListener
             name="Handler_UpdateInitiatingSubjectGegMagCommand"
             slotId="${instance.name}/UpdateInitiatingSubjectGegMagCommand"
+            peekUntransacted="true"
+            statusValueInProcess="I"
             />
         </Receiver> -->
         
diff --git a/src/main/configurations/bpel/Configuration_UpdatePaymentCommandHandler.xml b/src/main/configurations/bpel/Configuration_UpdatePaymentCommandHandler.xml
index 2e7711b..fa042d4 100644
--- a/src/main/configurations/bpel/Configuration_UpdatePaymentCommandHandler.xml
+++ b/src/main/configurations/bpel/Configuration_UpdatePaymentCommandHandler.xml
@@ -16,12 +16,14 @@
         <Receiver
             name="UpdatePaymentCommandHandler"
             transactionAttribute="RequiresNew"
-            pollInterval="1"
-            maxRetries="1"
+            pollInterval="5"
+            maxRetries="0"
             >
             <MessageStoreListener
                 name="UpdatePaymentCommandHandler"
 				slotId="${instance.name}/UpdatePaymentCommand"
+                peekUntransacted="true"
+                statusValueInProcess="I"
                 sessionKeys="CaseReferenceNumber,PaymentOrderId,PaymentDate"
 				/>
         </Receiver>
diff --git a/src/main/configurations/bpel/Configuration_WorkflowSelector.xml b/src/main/configurations/bpel/Configuration_WorkflowSelector.xml
index 9034d59..a0cbe08 100644
--- a/src/main/configurations/bpel/Configuration_WorkflowSelector.xml
+++ b/src/main/configurations/bpel/Configuration_WorkflowSelector.xml
@@ -21,12 +21,14 @@
         <Receiver
             name="WorkflowSelector"
             transactionAttribute="Required"
-            pollInterval="1"
-            maxRetries="1"
+            pollInterval="5"
+            maxRetries="0"
             >
             <MessageStoreListener
                 name="WorkflowSelector"
 				slotId="${instance.name}/WorkflowSelector"
+                peekUntransacted="true"
+                statusValueInProcess="I"
 				/>
         </Receiver>
 
diff --git a/src/main/configurations/bpel/Configuration_Workflow_Fallback.xml b/src/main/configurations/bpel/Configuration_Workflow_Fallback.xml
index 831a571..3ecf0ee 100644
--- a/src/main/configurations/bpel/Configuration_Workflow_Fallback.xml
+++ b/src/main/configurations/bpel/Configuration_Workflow_Fallback.xml
@@ -16,12 +16,14 @@
         <!-- <Receiver
             name="Workflow_FallbackHandler"
             transactionAttribute="Mandatory"
-            pollInterval="1"
-            maxRetries="1"
+            pollInterval="5"
+            maxRetries="0"
             >
             <MessageStoreListener
                 name="Workflow_FallbackHandler"
 				slotId="${instance.name}/Workflow_Fallback"
+                peekUntransacted="true"
+                statusValueInProcess="I"
 				/>
         </Receiver> -->
 
diff --git a/src/main/configurations/bpel/Configuration_Workflow_TwoWayCommunication.xml b/src/main/configurations/bpel/Configuration_Workflow_TwoWayCommunication.xml
index 380bc67..9912c6e 100644
--- a/src/main/configurations/bpel/Configuration_Workflow_TwoWayCommunication.xml
+++ b/src/main/configurations/bpel/Configuration_Workflow_TwoWayCommunication.xml
@@ -16,12 +16,14 @@
         <!-- <Receiver
             name="Workflow_TwoWayCommunicationHandler"
             transactionAttribute="RequiresNew"
-            pollInterval="1"
-            maxRetries="1"
+            pollInterval="5"
+            maxRetries="0"
             >
             <MessageStoreListener
                 name="Workflow_TwoWayCommunicationHandler"
 				slotId="${instance.name}/Workflow_TwoWayCommunication"
+                peekUntransacted="true"
+                statusValueInProcess="I"
 				/>
         </Receiver> -->
 
@@ -94,9 +96,44 @@
                 xpathExpression="string-length(//*:lookUpCaseIdsResponse/*:caseIdMessage/*:cases/*:case) gt 0"
                 >
                 <Forward name="then" path="CreateReadCasesRequestMessage" />
+                <Forward name="else" path="CaseNotFound_MailCondition" />
+            </XmlIfPipe>
+
+            <XmlIfPipe
+                name="CaseNotFound_MailCondition"
+                xpathExpression="string-length('${openforms2bpel.workflows.tweewegcommunicatie.on-case-not-found.mail-template}') gt 0"
+                >
+                <Forward name="then" path="CaseNotFound_StoreMailTemplateName" />
                 <Forward name="else" path="CaseNotFound_Exception" />
             </XmlIfPipe>
 
+            <PutInSessionPipe
+                name="CaseNotFound_StoreMailTemplateName"
+                >
+                <Param name="TemplateName" value="${openforms2bpel.workflows.tweewegcommunicatie.on-case-not-found.mail-template}" />
+                <Forward name="success" path="CaseNotFound_SendNoReplyUserEmailCommand" />
+            </PutInSessionPipe>
+
+            <SenderPipe
+				name="CaseNotFound_SendNoReplyUserEmailCommand"
+                getInputFromSessionKey="UwGegevens"
+                transactionAttribute="Required"
+				>
+				<MessageStoreSender
+					name="CaseNotFound_SendNoReplyUserEmailCommandMessageStoreSender"
+					slotId="${instance.name}/SendNoReplyUserEmailCommand"
+                    sessionKeys="TemplateName"
+                    onlyStoreWhenMessageIdUnique="true"
+                    transacted="true"
+					>
+                    <Param name="messageId" xpathExpression="concat($CaseReferenceNumber, '-', $TargetCaseReferenceNumber)">
+                        <Param name="TargetCaseReferenceNumber" sessionKey="CaseReferenceNumber" />
+                        <Param name="CaseReferenceNumber" sessionKey="originalMessage" xpathExpression="/ZgwObject/public_reference" />
+                    </Param>
+				</MessageStoreSender>
+                <Forward name="success" path="EXIT" />
+			</SenderPipe>
+
             <ExceptionPipe name="CaseNotFound_Exception" />
 
             <XsltPipe
@@ -165,10 +202,45 @@
                 <Param name="UwGegevensSubject" sessionKey="UwGegevensSubject" />
                 <Param name="CaseInitiatingSubject" sessionKey="CaseInitiatingSubject" />
                 <Forward name="then" path="CreateAddDocumentsToCaseCommand" />
-                <Forward name="else" path="UwGegevensSubjectIsNotCaseInitiatingSubject_Exception" />
+                <Forward name="else" path="SubjectNotEqualsCaseSubject_MailCondition" />
             </XmlIfPipe>
 
-            <ExceptionPipe name="UwGegevensSubjectIsNotCaseInitiatingSubject_Exception" />
+            <XmlIfPipe
+                name="SubjectNotEqualsCaseSubject_MailCondition"
+                xpathExpression="string-length('${openforms2bpel.workflows.tweewegcommunicatie.on-subject-not-equals-case-subject.mail-template}') gt 0"
+                >
+                <Forward name="then" path="SubjectNotEqualsCaseSubject_StoreMailTemplateName" />
+                <Forward name="else" path="SubjectNotEqualsCaseSubject_Exception" />
+            </XmlIfPipe>
+
+            <PutInSessionPipe
+                name="SubjectNotEqualsCaseSubject_StoreMailTemplateName"
+                >
+                <Param name="TemplateName" value="${openforms2bpel.workflows.tweewegcommunicatie.on-subject-not-equals-case-subject.mail-template}" />
+                <Forward name="success" path="SubjectNotEqualsCaseSubject_SendNoReplyUserEmailCommand" />
+            </PutInSessionPipe>
+
+            <SenderPipe
+				name="SubjectNotEqualsCaseSubject_SendNoReplyUserEmailCommand"
+                getInputFromSessionKey="UwGegevens"
+                transactionAttribute="Required"
+				>
+				<MessageStoreSender
+					name="SubjectNotEqualsCaseSubject_SendNoReplyUserEmailCommandMessageStoreSender"
+					slotId="${instance.name}/SendNoReplyUserEmailCommand"
+                    sessionKeys="TemplateName"
+                    onlyStoreWhenMessageIdUnique="true"
+                    transacted="true"
+					>
+                    <Param name="messageId" xpathExpression="concat($CaseReferenceNumber, '-', $TargetCaseReferenceNumber)">
+                        <Param name="TargetCaseReferenceNumber" sessionKey="CaseReferenceNumber" />
+                        <Param name="CaseReferenceNumber" sessionKey="originalMessage" xpathExpression="/ZgwObject/public_reference" />
+                    </Param>
+				</MessageStoreSender>
+                <Forward name="success" path="EXIT" />
+			</SenderPipe>
+
+            <ExceptionPipe name="SubjectNotEqualsCaseSubject_Exception" />
 
             <XsltPipe
                 name="CreateAddDocumentsToCaseCommand"
diff --git a/src/main/configurations/bpel/Configuration_Workflow_UwGegevens.xml b/src/main/configurations/bpel/Configuration_Workflow_UwGegevens.xml
index 51554d6..96b377f 100644
--- a/src/main/configurations/bpel/Configuration_Workflow_UwGegevens.xml
+++ b/src/main/configurations/bpel/Configuration_Workflow_UwGegevens.xml
@@ -16,12 +16,14 @@
         <!-- <Receiver
             name="Workflow_UwGegevensHandler"
             transactionAttribute="RequiresNew"
-            pollInterval="1"
-            maxRetries="1"
+            pollInterval="5"
+            maxRetries="0"
             >
             <MessageStoreListener
                 name="Workflow_UwGegevensHandler"
 				slotId="${instance.name}/Workflow_UwGegevens"
+                peekUntransacted="true"
+                statusValueInProcess="I"
 				/>
         </Receiver> -->