Skip to content

Commit

Permalink
Merge pull request #260 from Project-MONAI/nds-upping-messaging
Browse files Browse the repository at this point in the history
upped messaging version
  • Loading branch information
neildsouth authored Nov 16, 2022
2 parents 9a0a705 + c9dd62b commit cd14949
Show file tree
Hide file tree
Showing 6 changed files with 12 additions and 12 deletions.
8 changes: 4 additions & 4 deletions doc/dependency_decisions.yml
Original file line number Diff line number Diff line change
Expand Up @@ -788,17 +788,17 @@
:when: 2022-08-16 23:06:20.598551507 Z
- - :approve
- Monai.Deploy.Messaging
- :who: mocsharp
- :who: neilsouth
:why: Apache-2.0 (https://github.com/Project-MONAI/monai-deploy-messaging/raw/main/LICENSE)
:versions:
- 0.1.11
- 0.1.17-rc0020
:when: 2022-08-16 23:06:21.051573547 Z
- - :approve
- Monai.Deploy.Messaging.RabbitMQ
- :who: mocsharp
- :who: neilsouth
:why: Apache-2.0 (https://github.com/Project-MONAI/monai-deploy-messaging/raw/main/LICENSE)
:versions:
- 0.1.11
- 0.1.17-rc0020
:when: 2022-08-16 23:06:21.511789690 Z
- - :approve
- Monai.Deploy.Storage
Expand Down
2 changes: 1 addition & 1 deletion src/Api/Monai.Deploy.InformaticsGateway.Api.csproj
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,7 @@
</PackageReference>
<PackageReference Include="Macross.Json.Extensions" Version="3.0.0" />
<PackageReference Include="Microsoft.EntityFrameworkCore.Abstractions" Version="6.0.10" />
<PackageReference Include="Monai.Deploy.Messaging" Version="0.1.11" />
<PackageReference Include="Monai.Deploy.Messaging" Version="0.1.17-rc0020" />
<PackageReference Include="Monai.Deploy.Storage" Version="0.2.10" />
</ItemGroup>

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,7 @@
</PackageReference>
<PackageReference Include="Microsoft.Extensions.Logging.Abstractions" Version="6.0.2" />
<PackageReference Include="Microsoft.Extensions.Options" Version="6.0.0" />
<PackageReference Include="Monai.Deploy.Messaging" Version="0.1.11" />
<PackageReference Include="Monai.Deploy.Messaging" Version="0.1.17-rc0020" />
<PackageReference Include="Monai.Deploy.Storage" Version="0.2.10" />
<PackageReference Include="System.IO.Abstractions" Version="17.2.3" />
</ItemGroup>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -48,7 +48,7 @@
<PackageReference Include="Microsoft.Extensions.Logging" Version="6.0.0" />
<PackageReference Include="Microsoft.Extensions.Logging.Console" Version="6.0.0" />
<PackageReference Include="Microsoft.Extensions.Options" Version="6.0.0" />
<PackageReference Include="Monai.Deploy.Messaging.RabbitMQ" Version="0.1.11" />
<PackageReference Include="Monai.Deploy.Messaging.RabbitMQ" Version="0.1.17-rc0020" />
<PackageReference Include="Monai.Deploy.Storage" Version="0.2.10" />
<PackageReference Include="Monai.Deploy.Storage.MinIO" Version="0.2.10" />
<PackageReference Include="NLog.Web.AspNetCore" Version="5.1.5" />
Expand Down
6 changes: 3 additions & 3 deletions src/InformaticsGateway/Services/Export/ExportServiceBase.cs
Original file line number Diff line number Diff line change
Expand Up @@ -99,7 +99,7 @@ protected ExportServiceBase(

_messageSubscriber.OnConnectionError += (sender, args) =>
{
_logger.MessagingServiceErrorRecover(args.ShutdownEventArguments.ToString());
_logger.MessagingServiceErrorRecover(args.ErrorMessage);
SetupPolling();
};
}
Expand Down Expand Up @@ -204,7 +204,7 @@ private void OnMessageReceivedCallback(MessageReceivedEventArgs eventArgs)
private IEnumerable<ExportRequestDataMessage> DownloadPayloadActionCallback(ExportRequestEventDetails exportRequest, CancellationToken cancellationToken)
{
Guard.Against.Null(exportRequest, nameof(exportRequest));
using var loggerScope = _logger.BeginScope(new LoggingDataDictionary<string, object> { { "ExportTaskId", exportRequest.ExportTaskId }, { "CorrelationId", exportRequest.CorrelationId } });
using var loggerScope = _logger.BeginScope(new Api.LoggingDataDictionary<string, object> { { "ExportTaskId", exportRequest.ExportTaskId }, { "CorrelationId", exportRequest.CorrelationId } });
var scope = _serviceScopeFactory.CreateScope();
var storageService = scope.ServiceProvider.GetRequiredService<IStorageService>();

Expand Down Expand Up @@ -245,7 +245,7 @@ private IEnumerable<ExportRequestDataMessage> DownloadPayloadActionCallback(Expo

private void ReportingActionBlock(ExportRequestDataMessage exportRequestData)
{
using var loggerScope = _logger.BeginScope(new LoggingDataDictionary<string, object> { { "ExportTaskId", exportRequestData.ExportTaskId }, { "CorrelationId", exportRequestData.CorrelationId } });
using var loggerScope = _logger.BeginScope(new Api.LoggingDataDictionary<string, object> { { "ExportTaskId", exportRequestData.ExportTaskId }, { "CorrelationId", exportRequestData.CorrelationId } });

var exportRequest = _exportRequests[exportRequestData.ExportTaskId];
lock (SyncRoot)
Expand Down
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
<!--
<!--
~ Copyright 2022 MONAI Consortium
~
~ Licensed under the Apache License, Version 2.0 (the "License");
Expand Down Expand Up @@ -33,7 +33,7 @@
<PackageReference Include="Microsoft.Extensions.Configuration.Json" Version="6.0.0" />
<PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.4.0" />
<PackageReference Include="Minio" Version="4.0.6" />
<PackageReference Include="Monai.Deploy.Messaging.RabbitMQ" Version="0.1.11" />
<PackageReference Include="Monai.Deploy.Messaging.RabbitMQ" Version="0.1.17-rc0020" />
<PackageReference Include="Monai.Deploy.Storage.MinIO" Version="0.2.10" />
<PackageReference Include="Moq" Version="4.18.2" />
<PackageReference Include="Polly" Version="7.2.3" />
Expand Down

0 comments on commit cd14949

Please sign in to comment.