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)

Reply via email to