Skip to content

GitAuto: [FEATURE] Upgrade RabbitMQ Client Library to Version 7.0.0 #639

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
gitauto-ai wants to merge 10 commits into from
Closed

GitAuto: [FEATURE] Upgrade RabbitMQ Client Library to Version 7.0.0 #639

Show file tree
Hide file tree
Changes from 8 commits
Commits
Show all changes
10 commits
Select commit Hold shift + click to select a range
3fc2445
Update Src/CrispyWaffle.RabbitMQ/CrispyWaffle.RabbitMQ.csproj
gitauto-ai[bot] Jan 6, 2025
6d7f676
Update Directory.Packages.props
gitauto-ai[bot] Jan 6, 2025
706debc
Update Src/CrispyWaffle.RabbitMQ/CrispyWaffle.RabbitMQ.csproj
gitauto-ai[bot] Jan 6, 2025
da3a27d
Update CrispyWaffle.RabbitMQ.csproj
guibranco Jan 8, 2025
e1ce61b
Merge branch 'main' into gitauto/issue-596-20250106-020847
gstraccini[bot] Jan 8, 2025
6863063
Update RabbitMQLogProvider.cs
guibranco Jan 8, 2025
0731561
Update RabbitMQLogProvider.cs
guibranco Jan 8, 2025
31dcd14
Merge branch 'main' into gitauto/issue-596-20250106-020847
guibranco Jan 22, 2025
fb4e5c8
CSharpier format
gstraccini[bot] Jan 22, 2025
e79e030
Merge branch 'main' into gitauto/issue-596-20250106-020847
guibranco Jan 29, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 2 additions & 2 deletions Directory.Packages.props
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,7 @@
<PackageVersion Include="NEST" Version="7.17.5" />
<PackageVersion Include="Newtonsoft.Json" Version="13.0.3" />
<PackageVersion Include="NSubstitute" Version="5.3.0" />
<PackageVersion Include="RabbitMQ.Client" Version="6.8.1" />
<PackageVersion Include="RabbitMQ.Client" Version="7.0.0" />
<PackageVersion Include="SonarAnalyzer.CSharp" Version="10.5.0.109200" />
<PackageVersion Include="StackExchange.Redis" Version="2.8.24" />
<PackageVersion Include="StackExchange.Redis.Extensions.Core" Version="9.1.0" />
Expand All @@ -33,4 +33,4 @@
<IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
</PackageVersion>
</ItemGroup>
</Project>
</Project>
6 changes: 3 additions & 3 deletions Src/CrispyWaffle.RabbitMQ/Log/RabbitMQLogProvider.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -34,7 +34,7 @@
/// <summary>
/// The channel.
/// </summary>
private readonly IModel _channel;
private readonly IChannel _channel;

/// <summary>
/// The cancellation token.
Expand All @@ -55,8 +55,8 @@
public RabbitMQLogProvider(RabbitMQConnector connector, CancellationToken cancellationToken)
{
_connector = connector ?? throw new ArgumentNullException(nameof(connector));
_channel = _connector.ConnectionFactory.CreateConnection().CreateModel();
_channel.ExchangeDeclare(_connector.DefaultExchangeName, ExchangeType.Fanout, true);
_channel = _connector.ConnectionFactory.CreateConnectionAsync().GetAwaiter().GetResult().CreateModelAsync().GetAwaiter().GetResult();

Check failure on line 58 in Src/CrispyWaffle.RabbitMQ/Log/RabbitMQLogProvider.cs

View workflow job for this annotation

GitHub Actions / Analyze (csharp) 

'IConnection' does not contain a definition for 'CreateModelAsync' and no accessible extension method 'CreateModelAsync' accepting a first argument of type 'IConnection' could be found (are you missing a using directive or an assembly reference?)

Check failure on line 58 in Src/CrispyWaffle.RabbitMQ/Log/RabbitMQLogProvider.cs

View workflow job for this annotation

GitHub Actions / Analyze (csharp) 

'IConnection' does not contain a definition for 'CreateModelAsync' and no accessible extension method 'CreateModelAsync' accepting a first argument of type 'IConnection' could be found (are you missing a using directive or an assembly reference?)
_channel.ExchangeDeclareAsync(_connector.DefaultExchangeName, ExchangeType.Fanout, true).GetAwaiter().GetResult();
_cancellationToken = cancellationToken;
_queue = new ConcurrentQueue<string>();
var thread = new Thread(Worker);
Expand Down Expand Up @@ -107,7 +107,7 @@
try
{
var body = Encoding.UTF8.GetBytes(message);
_channel.BasicPublish(_connector.DefaultExchangeName, string.Empty, null, body);

Check failure on line 110 in Src/CrispyWaffle.RabbitMQ/Log/RabbitMQLogProvider.cs

View workflow job for this annotation

GitHub Actions / Analyze (csharp) 

'IChannel' does not contain a definition for 'BasicPublish' and no accessible extension method 'BasicPublish' accepting a first argument of type 'IChannel' could be found (are you missing a using directive or an assembly reference?)
}
catch (Exception e)
{
Expand All @@ -126,7 +126,7 @@
return;
}

_channel.Close();

Check failure on line 129 in Src/CrispyWaffle.RabbitMQ/Log/RabbitMQLogProvider.cs

View workflow job for this annotation

GitHub Actions / Analyze (csharp) 

'IChannel' does not contain a definition for 'Close' and no accessible extension method 'Close' accepting a first argument of type 'IChannel' could be found (are you missing a using directive or an assembly reference?)
}

/// <summary>
Expand Down
Loading