in src/Microsoft.Azure.NotificationHubs/NamespaceManager.cs [526:553]
public async Task<NotificationHubJob> GetNotificationHubJobAsync(string jobId, string notificationHubPath, CancellationToken cancellationToken)
{
var requestUri = new UriBuilder(_baseUri)
{
Scheme = Uri.UriSchemeHttps,
Path = $"{notificationHubPath}/jobs/{jobId}",
Query = $"api-version={ManagementStrings.ApiVersion}"
};
return await _retryPolicy.RunOperation(async (ct) =>
{
using (var response = await SendAsync(() =>
{
var httpRequestMessage = CreateHttpRequest(HttpMethod.Get, requestUri.Uri);
return httpRequestMessage;
}, ct).ConfigureAwait(false))
{
var trackingId = string.Empty;
if (response.Headers.TryGetValues(TrackingIdHeaderKey, out var values))
{
trackingId = values.FirstOrDefault();
}
var xmlResponse = await GetXmlContent(response, trackingId).ConfigureAwait(false);
return GetModelFromResponse<NotificationHubJob>(xmlResponse, trackingId);
};
}, cancellationToken);
}