code: private void publishEvent(WSJobInstance jobInst, String topicToPublish, String correlationId) {
          if (eventsPublisher != null) {
              eventsPublisher.publishJobInstanceEvent(jobInst, topicToPublish, correlationId);
          }
      }
docs: Helper method to publish event with correlationId
  
  @param jobInstance
  @param topicToPublish
  @param correlationId