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