From c1cc36afc229b59b51c4a21aad3e039dbeea8255 Mon Sep 17 00:00:00 2001
From: "Brian M. Long" <brian@inteligr8.com>
Date: Tue, 11 Mar 2025 12:21:47 -0400
Subject: [PATCH] terminate process instance when starter subscription ends

---
 .../java/com/inteligr8/activiti/mq/MqSubscribeDelegate.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/main/java/com/inteligr8/activiti/mq/MqSubscribeDelegate.java b/src/main/java/com/inteligr8/activiti/mq/MqSubscribeDelegate.java
index 0a9f843..17384bb 100644
--- a/src/main/java/com/inteligr8/activiti/mq/MqSubscribeDelegate.java
+++ b/src/main/java/com/inteligr8/activiti/mq/MqSubscribeDelegate.java
@@ -121,7 +121,7 @@ public class MqSubscribeDelegate extends AbstractMqDelegate {
 	    		}
     		) == null) {
     			this.logger.debug("Gracefully stopped looking for MQ messages: {} => {}", mqExecution.getConnectorIdFromModel(), mqExecution.getQueueNameFromModel());
-    			throw new BpmnError("cancelled", "MQ subscription cancelled gracefully");
+    			this.services.getRuntimeService().deleteProcessInstance(execution.getProcessInstanceId(), "MQ subscription cancelled gracefully");
     		}
     	} catch (TimeoutException te) {
     		this.logger.error("MQ connection or communication timed out: " + te.getMessage(), te);