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 8c1c98a Updated the version of Pulsar used for testing to 3.1.0
Updated NuGet package Updated the changelog
8c1c98a is described below
commit 8c1c98a5e9e8f7df3974a053f687a8d432884c9e
Author: Daniel Blankensteiner <[email protected]>
AuthorDate: Thu Aug 24 23:05:27 2023 +0200
Updated the version of Pulsar used for testing to 3.1.0
Updated NuGet package
Updated the changelog
---
CHANGELOG.md | 1 +
src/DotPulsar/Abstractions/IPulsarClientBuilder.cs | 2 +-
src/DotPulsar/Internal/ConnectionPool.cs | 4 ++--
tests/DotPulsar.Tests/DotPulsar.Tests.csproj | 2 +-
tests/DotPulsar.Tests/IntegrationFixture.cs | 2 +-
5 files changed, 6 insertions(+), 5 deletions(-)
diff --git a/CHANGELOG.md b/CHANGELOG.md
index 1b9b5ae..69cc145 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -25,6 +25,7 @@ The format is based on [Keep a
Changelog](https://keepachangelog.com/en/1.1.0/)
- The 'Partition' in 'MessageId' will now be set to the correct partition when
producing to partitioned topics
- The OnStateChangeFrom extension method with delay functionality returned the
inputted state but should return the current state
- The DelayedStateMonitor extension method invoked onStateLeft with the
inputted state but should have invoked it with the current state
+- Consumers, Producers, and Readers will now disconnect if the server does not
reply to a ping
### Deprecated
diff --git a/src/DotPulsar/Abstractions/IPulsarClientBuilder.cs
b/src/DotPulsar/Abstractions/IPulsarClientBuilder.cs
index c9aad89..87be0eb 100644
--- a/src/DotPulsar/Abstractions/IPulsarClientBuilder.cs
+++ b/src/DotPulsar/Abstractions/IPulsarClientBuilder.cs
@@ -89,7 +89,7 @@ public interface IPulsarClientBuilder
IPulsarClientBuilder VerifyCertificateName(bool verifyCertificateName);
/// <summary>
- /// The time to wait before checking for inactive connections that can be
closed. The default is 60 seconds.
+ /// The time to wait before closing inactive connections. The default is
60 seconds.
/// </summary>
IPulsarClientBuilder CloseInactiveConnectionsInterval(TimeSpan interval);
diff --git a/src/DotPulsar/Internal/ConnectionPool.cs
b/src/DotPulsar/Internal/ConnectionPool.cs
index 3ea5a2f..6631f5f 100644
--- a/src/DotPulsar/Internal/ConnectionPool.cs
+++ b/src/DotPulsar/Internal/ConnectionPool.cs
@@ -1,4 +1,4 @@
-/*
+/*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
@@ -206,7 +206,7 @@ public sealed class ConnectionPool : IConnectionPool
{
try
{
- await Task.Delay(interval, cancellationToken);
+ await Task.Delay(interval,
cancellationToken).ConfigureAwait(false);
using (await
_lock.Lock(cancellationToken).ConfigureAwait(false))
{
diff --git a/tests/DotPulsar.Tests/DotPulsar.Tests.csproj
b/tests/DotPulsar.Tests/DotPulsar.Tests.csproj
index 3030ecc..0cf175e 100644
--- a/tests/DotPulsar.Tests/DotPulsar.Tests.csproj
+++ b/tests/DotPulsar.Tests/DotPulsar.Tests.csproj
@@ -11,7 +11,7 @@
<PackageReference Include="AutoFixture.Xunit2" Version="4.18.0" />
<PackageReference Include="DotNetZip" Version="1.16.0" />
<PackageReference Include="Ductus.FluentDocker" Version="2.10.59" />
- <PackageReference Include="FluentAssertions" Version="6.11.0" />
+ <PackageReference Include="FluentAssertions" Version="6.12.0" />
<PackageReference Include="IronSnappy" Version="1.3.1" />
<PackageReference Include="K4os.Compression.LZ4" Version="1.3.6" />
<PackageReference Include="NSubstitute" Version="5.0.0" />
diff --git a/tests/DotPulsar.Tests/IntegrationFixture.cs
b/tests/DotPulsar.Tests/IntegrationFixture.cs
index 5879dbe..e17c26b 100644
--- a/tests/DotPulsar.Tests/IntegrationFixture.cs
+++ b/tests/DotPulsar.Tests/IntegrationFixture.cs
@@ -62,7 +62,7 @@ public class IntegrationFixture : IAsyncLifetime
_cluster = new Builder()
.UseContainer()
- .UseImage("apachepulsar/pulsar:2.11.0")
+ .UseImage("apachepulsar/pulsar:3.1.0")
.WithEnvironment(environmentVariables)
.ExposePort(Port)
.Command("/bin/bash -c", arguments)