This is an automated email from the ASF dual-hosted git repository.
blankensteiner pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar-dotpulsar.git
The following commit(s) were added to refs/heads/master by this push:
new bd3d5c1 Merry Christmas DotPulsar! I got you some NuGet package
updates. Hope you like them :-)
bd3d5c1 is described below
commit bd3d5c18f54b79ed8a0ea2caf9399bf140fba1f3
Author: Daniel Blankensteiner <[email protected]>
AuthorDate: Sun Dec 24 11:00:46 2023 +0100
Merry Christmas DotPulsar!
I got you some NuGet package updates. Hope you like them :-)
---
src/DotPulsar/Internal/Consumer.cs | 6 ++----
tests/DotPulsar.Tests/DotPulsar.Tests.csproj | 4 ++--
2 files changed, 4 insertions(+), 6 deletions(-)
diff --git a/src/DotPulsar/Internal/Consumer.cs
b/src/DotPulsar/Internal/Consumer.cs
index e5be65b..ba441e4 100644
--- a/src/DotPulsar/Internal/Consumer.cs
+++ b/src/DotPulsar/Internal/Consumer.cs
@@ -400,13 +400,11 @@ public sealed class Consumer<TMessage> :
IConsumer<TMessage>
var messageFactory = new
MessageFactory<TMessage>(_consumerOptions.Schema);
var batchHandler = new BatchHandler<TMessage>(true, messageFactory);
var decompressorFactories =
CompressionFactories.DecompressorFactories();
- var consumerChannelFactory = new
ConsumerChannelFactory<TMessage>(correlationId, _processManager,
_connectionPool, subscribe,
- messagePrefetchCount, batchHandler, messageFactory,
decompressorFactories, topic);
+ var consumerChannelFactory = new
ConsumerChannelFactory<TMessage>(correlationId, _processManager,
_connectionPool, subscribe, messagePrefetchCount, batchHandler, messageFactory,
decompressorFactories, topic);
var stateManager = CreateStateManager();
var initialChannel = new NotReadyChannel<TMessage>();
var executor = new Executor(correlationId, _processManager,
_exceptionHandler);
- var subConsumer = new SubConsumer<TMessage>(correlationId, ServiceUrl,
_consumerOptions.SubscriptionName, topic,
- _processManager, initialChannel, executor, stateManager,
consumerChannelFactory);
+ var subConsumer = new SubConsumer<TMessage>(correlationId, ServiceUrl,
_consumerOptions.SubscriptionName, topic, _processManager, initialChannel,
executor, stateManager, consumerChannelFactory);
var process = new ConsumerProcess(correlationId, stateManager,
subConsumer, _consumerOptions.SubscriptionType == SubscriptionType.Failover);
_processManager.Add(process);
process.Start();
diff --git a/tests/DotPulsar.Tests/DotPulsar.Tests.csproj
b/tests/DotPulsar.Tests/DotPulsar.Tests.csproj
index 9ee0ddf..8946c9d 100644
--- a/tests/DotPulsar.Tests/DotPulsar.Tests.csproj
+++ b/tests/DotPulsar.Tests/DotPulsar.Tests.csproj
@@ -25,8 +25,8 @@
<PackageReference Include="NSubstitute" Version="5.1.0" />
<PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.8.0" />
<PackageReference Include="Testcontainers" Version="3.6.0" />
- <PackageReference Include="xunit" Version="2.6.3" />
- <PackageReference Include="xunit.runner.visualstudio" Version="2.5.5">
+ <PackageReference Include="xunit" Version="2.6.4" />
+ <PackageReference Include="xunit.runner.visualstudio" Version="2.5.6">
<PrivateAssets>all</PrivateAssets>
<IncludeAssets>runtime; build; native; contentfiles; analyzers;
buildtransitive</IncludeAssets>
</PackageReference>
