public void Execute()

in backend/MXApi/Jobs/EventHubProcessingJob.cs [24:45]


    public void Execute()
    {
      try
      {
        CancelExistingTasks();
        lock (Lock)
        {
          if (_shuttingDown)
          {
            return;
          }

          CreateNewMessageService();
          _messagingService.ReadMessages(_tokenSource.Token);
        }
      }
      catch (Exception e)
      {
        Trace.TraceError($"Failed to execute event hub processing job: {e}");
        throw;
      }
    }