terminate process instance when starter subscription ends

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);