code: public CallActivityMock onExecutionSendMessage(final String message) {
      return onExecutionDo(execution -> execution.getProcessEngineServices()
        .getRuntimeService().correlateMessage(message));
    }
docs: On execution, the MockProcess will send the given message to all
  
  @param message the message to receive
  @return self