Skip to content

Commit 4ca265f

Browse files
Merge pull request #84 from TransactionProcessing/task/#80_reduceeventsize
Better error handling in Worker Service
2 parents 5afc7b0 + f183973 commit 4ca265f

1 file changed

Lines changed: 7 additions & 5 deletions

File tree

Shared.EventStore/Subscriptions/SubscriptionWorker.cs

Lines changed: 7 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -188,19 +188,21 @@ protected override async Task ExecuteAsync(CancellationToken stoppingToken)
188188
/// <returns></returns>
189189
private async Task<List<SubscriptionInformation>> GetSubscriptionsList(CancellationToken cancellationToken)
190190
{
191-
List<SubscriptionInformation> subscriptionList = null;
191+
List<SubscriptionInformation> subscriptionList = new List<SubscriptionInformation>();
192192
String requestUri = $"{ConfigurationReader.GetValue("EventStoreSettings", "ConnectionString")}/subscriptions";
193-
194-
193+
195194
HttpRequestMessage requestMessage = new HttpRequestMessage(HttpMethod.Get, requestUri);
196195

197196
HttpResponseMessage responseMessage = await this.HttpClient.SendAsync(requestMessage, cancellationToken);
198-
197+
String responseData = await responseMessage.Content.ReadAsStringAsync(cancellationToken);
199198
if (responseMessage.IsSuccessStatusCode)
200199
{
201-
String responseData = await responseMessage.Content.ReadAsStringAsync(cancellationToken);
202200
subscriptionList = JsonConvert.DeserializeObject<List<SubscriptionInformation>>(responseData);
203201
}
202+
else
203+
{
204+
Logger.LogWarning($"Error getting subscription list from [{requestUri}] Http Status Code [{responseMessage.StatusCode}] Content [{responseData}]");
205+
}
204206

205207
return subscriptionList;
206208
}

0 commit comments

Comments
 (0)