(pulsar-dotpulsar) branch master updated: Minor stuff and updated toxiproxy from 2.9.0 to 2.11.0

[blankensteiner]

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 7d896ae  Minor stuff and updated toxiproxy from 2.9.0 to 2.11.0
7d896ae is described below

commit 7d896ae584c3862fdd42ceab3c84b01c7a217f9f
Author: Daniel Blankensteiner <d...@vmail.dk>
AuthorDate: Fri Feb 7 17:29:43 2025 +0100

    Minor stuff and updated toxiproxy from 2.9.0 to 2.11.0
---
 src/DotPulsar/Internal/DotPulsarActivitySource.cs | 2 +-
 src/DotPulsar/Internal/Producer.cs                | 2 +-
 src/DotPulsar/Internal/Reader.cs                  | 4 ++--
 tests/DotPulsar.Tests/IntegrationFixture.cs       | 2 +-
 4 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/src/DotPulsar/Internal/DotPulsarActivitySource.cs 
b/src/DotPulsar/Internal/DotPulsarActivitySource.cs
index 01a52b4..5e7f252 100644
--- a/src/DotPulsar/Internal/DotPulsarActivitySource.cs
+++ b/src/DotPulsar/Internal/DotPulsarActivitySource.cs
@@ -39,7 +39,7 @@ public static class DotPulsarActivitySource
         {
             var activityLink = GetActivityLink(message);
             if (activityLink is not null)
-                activityLinks = new ActivityLink[] { activityLink.Value };
+                activityLinks = [activityLink.Value];
         }
 
         return StartActivity(operationName, ActivityKind.Consumer, tags, 
activityLinks, message.GetConversationId());
diff --git a/src/DotPulsar/Internal/Producer.cs 
b/src/DotPulsar/Internal/Producer.cs
index 0f7534d..aebf72f 100644
--- a/src/DotPulsar/Internal/Producer.cs
+++ b/src/DotPulsar/Internal/Producer.cs
@@ -37,7 +37,7 @@ public sealed class Producer<TMessage> : IProducer<TMessage>, 
IRegisterEvent
     private readonly ConcurrentDictionary<int, SubProducer> _producers;
     private readonly IMessageRouter _messageRouter;
     private readonly CancellationTokenSource _cts;
-    private readonly IExecute _executor;
+    private readonly Executor _executor;
     private int _isDisposed;
     private int _producerCount;
     private Exception? _faultException;
diff --git a/src/DotPulsar/Internal/Reader.cs b/src/DotPulsar/Internal/Reader.cs
index ed84add..1ea0f2c 100644
--- a/src/DotPulsar/Internal/Reader.cs
+++ b/src/DotPulsar/Internal/Reader.cs
@@ -28,7 +28,7 @@ public sealed class Reader<TMessage> : IReader<TMessage>
     private readonly IConnectionPool _connectionPool;
     private readonly ProcessManager _processManager;
     private readonly CancellationTokenSource _cts;
-    private readonly IExecute _executor;
+    private readonly Executor _executor;
     private readonly StateManager<ReaderState> _state;
     private readonly SemaphoreSlim _semaphoreSlim;
     private readonly AsyncLock _lock;
@@ -146,7 +146,7 @@ public sealed class Reader<TMessage> : IReader<TMessage>
         await Guard(cancellationToken).ConfigureAwait(false);
 
         if (!_isPartitionedTopic)
-            return new[] { await 
_subReaders[_subReaderIndex].GetLastMessageId(cancellationToken).ConfigureAwait(false)
 };
+            return [await 
_subReaders[_subReaderIndex].GetLastMessageId(cancellationToken).ConfigureAwait(false)];
 
         var getLastMessageIdsTasks = new 
List<Task<MessageId>>(_numberOfPartitions);
 
diff --git a/tests/DotPulsar.Tests/IntegrationFixture.cs 
b/tests/DotPulsar.Tests/IntegrationFixture.cs
index 1d1f126..94d3886 100644
--- a/tests/DotPulsar.Tests/IntegrationFixture.cs
+++ b/tests/DotPulsar.Tests/IntegrationFixture.cs
@@ -48,7 +48,7 @@ public class IntegrationFixture : IAsyncLifetime
             .Build();
 
         _toxiProxy = new ContainerBuilder()
-            .WithImage("ghcr.io/shopify/toxiproxy:2.9.0")
+            .WithImage("ghcr.io/shopify/toxiproxy:2.11.0")
             .WithPortBinding(ToxiProxyControlPort, true)
             .WithPortBinding(ToxiProxyPort, true)
             .WithHostname("toxiproxy")