docs: @Override
    public void doLeave(ActivityExecution execution) {
  
      PvmActivity currentActivity = execution.getActivity();
      ActivityImpl compensationHandler = ((ActivityImpl) currentActivity).findCompensationHandler();
  
      // subscription for compensation event subprocess is already created
      if(compensationHandler != null && !isCompensationEventSubprocess(compensationHandler)) {
        createCompensateEventSubscription(execution, compensationHandler);
      }
      super.doLeave(execution);
    }