diff --git a/Tutorials/Program.cs b/Tutorials/Program.cs index 402ce7076..8155da7cb 100644 --- a/Tutorials/Program.cs +++ b/Tutorials/Program.cs @@ -9,7 +9,6 @@ using System.Text.Json; using System.Threading; using System.Threading.Tasks; -using DotNet.Testcontainers.Builders; using SharpPulsar; using SharpPulsar.Auth.OAuth2; using SharpPulsar.Builder; diff --git a/Tutorials/Tutorials.csproj b/Tutorials/Tutorials.csproj index a6ea3d0e7..2d6cdf720 100644 --- a/Tutorials/Tutorials.csproj +++ b/Tutorials/Tutorials.csproj @@ -7,7 +7,7 @@ - + diff --git a/build/Build.cs b/build/Build.cs index ba15da44d..330cebfbe 100644 --- a/build/Build.cs +++ b/build/Build.cs @@ -28,7 +28,6 @@ using System.Threading.Tasks; using Nuke.Common.Tools.MSBuild; using Nuke.Common.CI.GitHubActions; -using DotNet.Testcontainers.Builders; using Testcontainers.Pulsar; //https://github.com/AvaloniaUI/Avalonia/blob/master/nukebuild/Build.cs //https://github.com/cfrenzel/Eventfully/blob/master/build/Build.cs @@ -153,7 +152,7 @@ partial class Build : NukeBuild .EnableNoBuild() .SetBlameCrash(true) .SetBlameHang(true) - .SetBlameHangTimeout("10m") + .SetBlameHangTimeout("30m") .EnableNoRestore() .When(true, _ => _ .SetLoggers("console;verbosity=detailed") diff --git a/src/SharpPulsar.Admin/SharpPulsar.Admin.csproj b/src/SharpPulsar.Admin/SharpPulsar.Admin.csproj index 90d55213a..6723e4f2c 100644 --- a/src/SharpPulsar.Admin/SharpPulsar.Admin.csproj +++ b/src/SharpPulsar.Admin/SharpPulsar.Admin.csproj @@ -7,7 +7,7 @@ - + diff --git a/src/SharpPulsar.Test/Fixture/PulsarCollection.cs b/src/SharpPulsar.Test/Fixture/PulsarCollection.cs index 65f0a86c6..c1f0f766f 100644 --- a/src/SharpPulsar.Test/Fixture/PulsarCollection.cs +++ b/src/SharpPulsar.Test/Fixture/PulsarCollection.cs @@ -2,11 +2,8 @@ namespace SharpPulsar.Test.Fixture { - using System.Threading.Tasks; - using System; using SharpPulsar.TestContainer; using Xunit; - using Xunit.Abstractions; [CollectionDefinition(nameof(PulsarCollection), DisableParallelization = true)] public class PulsarCollection : ICollectionFixture diff --git a/src/SharpPulsar.Test/MultiTopicsConsumerTest.cs b/src/SharpPulsar.Test/MultiTopicsConsumerTest.cs index cde2b38a2..29b825e4d 100644 --- a/src/SharpPulsar.Test/MultiTopicsConsumerTest.cs +++ b/src/SharpPulsar.Test/MultiTopicsConsumerTest.cs @@ -197,7 +197,7 @@ private async Task TestReadMessages(string topic, bool enableBatch) await Task.Delay(TimeSpan.FromSeconds(1)); for (var i = 0; i < numKeys; i++) { - var message = await reader.ReadNextAsync(TimeSpan.FromMicroseconds(5000)).ConfigureAwait(false); + var message = await reader.ReadNextAsync(TimeSpan.FromSeconds(60)).ConfigureAwait(false); if (message != null) { _output.WriteLine($"{message.Key}:{message.MessageId}:{Encoding.UTF8.GetString(message.Data)}"); diff --git a/src/SharpPulsar.Test/OAuthTest.cs b/src/SharpPulsar.Test/OAuthTest.cs index 5bbb3780b..9b947d733 100644 --- a/src/SharpPulsar.Test/OAuthTest.cs +++ b/src/SharpPulsar.Test/OAuthTest.cs @@ -9,7 +9,6 @@ using SharpPulsar.Interfaces; using SharpPulsar.Schemas; using SharpPulsar.Test.Fixture; -using SharpPulsar.TestContainer; using Xunit; using Xunit.Abstractions; diff --git a/src/SharpPulsar.Test/PartitionedProducerTest.cs b/src/SharpPulsar.Test/PartitionedProducerTest.cs index 65f19dad7..1468e8b7b 100644 --- a/src/SharpPulsar.Test/PartitionedProducerTest.cs +++ b/src/SharpPulsar.Test/PartitionedProducerTest.cs @@ -5,7 +5,6 @@ using System.Threading.Tasks; using SharpPulsar.Admin.v2; using SharpPulsar.Builder; -using SharpPulsar.Interfaces; using SharpPulsar.Test.Fixture; using SharpPulsar.TestContainer; using Xunit; diff --git a/src/SharpPulsar.Test/SharpPulsar.Test.csproj b/src/SharpPulsar.Test/SharpPulsar.Test.csproj index 64443c23c..95df2e016 100644 --- a/src/SharpPulsar.Test/SharpPulsar.Test.csproj +++ b/src/SharpPulsar.Test/SharpPulsar.Test.csproj @@ -7,8 +7,8 @@ - - + + diff --git a/src/SharpPulsar.Test/ZeroQueueSizeTest.cs b/src/SharpPulsar.Test/ZeroQueueSizeTest.cs index 19b4f61f5..eb2c1734e 100644 --- a/src/SharpPulsar.Test/ZeroQueueSizeTest.cs +++ b/src/SharpPulsar.Test/ZeroQueueSizeTest.cs @@ -1,6 +1,5 @@ using Akka.Actor; using Akka.Util; -using App.Metrics.Concurrency; using SharpPulsar.Messages.Consumer; using System; using System.Collections.Generic; @@ -15,7 +14,6 @@ using SharpPulsar.Test.Fixture; using SharpPulsar.TestContainer; using System.Threading.Tasks; -using System.Text.Json; /// /// Licensed to the Apache Software Foundation (ASF) under one diff --git a/src/SharpPulsar.TestContainer/PulsarFixture.cs b/src/SharpPulsar.TestContainer/PulsarFixture.cs index f67160efe..4e370c1d3 100644 --- a/src/SharpPulsar.TestContainer/PulsarFixture.cs +++ b/src/SharpPulsar.TestContainer/PulsarFixture.cs @@ -3,7 +3,6 @@ using Microsoft.Extensions.Configuration; using SharpPulsar.Builder; using SharpPulsar.Configuration; -using Xunit; namespace SharpPulsar.TestContainer { diff --git a/src/SharpPulsar.TestContainer/SharpPulsar.TestContainer.csproj b/src/SharpPulsar.TestContainer/SharpPulsar.TestContainer.csproj index 108247c30..afdee162c 100644 --- a/src/SharpPulsar.TestContainer/SharpPulsar.TestContainer.csproj +++ b/src/SharpPulsar.TestContainer/SharpPulsar.TestContainer.csproj @@ -18,7 +18,7 @@ - + diff --git a/src/SharpPulsar.Trino/SharpPulsar.Trino.csproj b/src/SharpPulsar.Trino/SharpPulsar.Trino.csproj index dec69ae9b..28303394c 100644 --- a/src/SharpPulsar.Trino/SharpPulsar.Trino.csproj +++ b/src/SharpPulsar.Trino/SharpPulsar.Trino.csproj @@ -14,7 +14,7 @@ - + diff --git a/src/SharpPulsar/Auth/OAuth2/ClientCredentialsFlow.cs b/src/SharpPulsar/Auth/OAuth2/ClientCredentialsFlow.cs index 2dd0af9c5..67a044249 100644 --- a/src/SharpPulsar/Auth/OAuth2/ClientCredentialsFlow.cs +++ b/src/SharpPulsar/Auth/OAuth2/ClientCredentialsFlow.cs @@ -1,6 +1,5 @@ using System; using System.Collections.Generic; -using System.Diagnostics; using System.IO; using System.Text.Json; using SharpPulsar.Auth.OAuth2.Protocol; diff --git a/src/SharpPulsar/Auth/OAuth2/FlowBase.cs b/src/SharpPulsar/Auth/OAuth2/FlowBase.cs index bf3a96134..1fd46a6b8 100644 --- a/src/SharpPulsar/Auth/OAuth2/FlowBase.cs +++ b/src/SharpPulsar/Auth/OAuth2/FlowBase.cs @@ -1,6 +1,5 @@ using System; using System.Collections.Generic; -using System.IO; using SharpPulsar.Auth.OAuth2.Protocol; using SharpPulsar.Exceptions; @@ -24,14 +23,14 @@ /// namespace SharpPulsar.Auth.OAuth2 { - - /// - /// An abstract OAuth 2.0 authorization flow. - /// + + /// + /// An abstract OAuth 2.0 authorization flow. + /// /// - [Serializable] + [Serializable] internal abstract class FlowBase : IFlow { public abstract void Close(); diff --git a/src/SharpPulsar/Batch/Api/IBatcherBuilder.cs b/src/SharpPulsar/Batch/Api/IBatcherBuilder.cs index 0be682321..53986c517 100644 --- a/src/SharpPulsar/Batch/Api/IBatcherBuilder.cs +++ b/src/SharpPulsar/Batch/Api/IBatcherBuilder.cs @@ -17,7 +17,6 @@ /// under the License. /// -using Akka.Event; namespace SharpPulsar.Batch.Api { diff --git a/src/SharpPulsar/Batch/BatchMessageContainer.cs b/src/SharpPulsar/Batch/BatchMessageContainer.cs index 785700bc8..2a94d912c 100644 --- a/src/SharpPulsar/Batch/BatchMessageContainer.cs +++ b/src/SharpPulsar/Batch/BatchMessageContainer.cs @@ -2,12 +2,10 @@ using System.Buffers; using System.Collections.Generic; using System.IO; -using Akka.Event; using ProtoBuf; using SharpPulsar.Common; using SharpPulsar.Exceptions; using SharpPulsar.Interfaces; -using SharpPulsar.Messages; using SharpPulsar.Protocol; using SharpPulsar.Protocol.Proto; using static SharpPulsar.Protocol.Commands; diff --git a/src/SharpPulsar/Batch/BatchMessageKeyBasedContainer.cs b/src/SharpPulsar/Batch/BatchMessageKeyBasedContainer.cs index ce2d82202..00072964f 100644 --- a/src/SharpPulsar/Batch/BatchMessageKeyBasedContainer.cs +++ b/src/SharpPulsar/Batch/BatchMessageKeyBasedContainer.cs @@ -3,7 +3,6 @@ using System.Collections.Generic; using System.IO; using System.Linq; -using Akka.Event; using DotNetty.Common.Utilities; using ProtoBuf; using SharpPulsar.Common; diff --git a/src/SharpPulsar/Batch/DefaultBatcherBuilder.cs b/src/SharpPulsar/Batch/DefaultBatcherBuilder.cs index a66fbf42f..d3d01b651 100644 --- a/src/SharpPulsar/Batch/DefaultBatcherBuilder.cs +++ b/src/SharpPulsar/Batch/DefaultBatcherBuilder.cs @@ -19,7 +19,6 @@ /// under the License. /// -using Akka.Event; using SharpPulsar.Batch.Api; namespace SharpPulsar.Batch diff --git a/src/SharpPulsar/Batch/KeyBasedBatcherBuilder.cs b/src/SharpPulsar/Batch/KeyBasedBatcherBuilder.cs index c3004cc54..70592c107 100644 --- a/src/SharpPulsar/Batch/KeyBasedBatcherBuilder.cs +++ b/src/SharpPulsar/Batch/KeyBasedBatcherBuilder.cs @@ -1,5 +1,4 @@ using System; -using Akka.Event; using SharpPulsar.Batch.Api; /// diff --git a/src/SharpPulsar/Batch/ObjectCopier.cs b/src/SharpPulsar/Batch/ObjectCopier.cs index 3ac3b6061..4808bb5ce 100644 --- a/src/SharpPulsar/Batch/ObjectCopier.cs +++ b/src/SharpPulsar/Batch/ObjectCopier.cs @@ -1,9 +1,4 @@ -using System; -using System.IO; -using System.Runtime.Serialization; -using System.Runtime.Serialization.Formatters.Binary; - -namespace SharpPulsar.Batch +namespace SharpPulsar.Batch { /// /// Reference Article http://www.codeproject.com/KB/tips/SerializedObjectCloner.aspx diff --git a/src/SharpPulsar/BinaryProtoLookupService.cs b/src/SharpPulsar/BinaryProtoLookupService.cs index ba310f9af..bb38134b2 100644 --- a/src/SharpPulsar/BinaryProtoLookupService.cs +++ b/src/SharpPulsar/BinaryProtoLookupService.cs @@ -1,7 +1,5 @@ using Akka.Actor; -using Akka.Event; using SharpPulsar.Common.Naming; -using SharpPulsar.Common.Partition; using SharpPulsar.Messages; using SharpPulsar.Messages.Requests; using SharpPulsar.Model; @@ -21,7 +19,6 @@ using SharpPulsar.ServiceName; using Mode = SharpPulsar.Protocol.Proto.CommandGetTopicsOfNamespace.Mode; using PartitionedTopicMetadata = SharpPulsar.Common.Partition.PartitionedTopicMetadata; -using ZstdNet; /// /// Licensed to the Apache Software Foundation (ASF) under one diff --git a/src/SharpPulsar/Builder/ReaderConfigBuilder.cs b/src/SharpPulsar/Builder/ReaderConfigBuilder.cs index ffaa2194b..f2af544a2 100644 --- a/src/SharpPulsar/Builder/ReaderConfigBuilder.cs +++ b/src/SharpPulsar/Builder/ReaderConfigBuilder.cs @@ -2,15 +2,12 @@ using System.Collections.Generic; using System.Linq; using Akka.Util.Internal; -using DotNetty.Common.Utilities; -using Org.BouncyCastle.Utilities; using SharpPulsar.Batch; using SharpPulsar.Common; using SharpPulsar.Common.Compression; using SharpPulsar.Configuration; using SharpPulsar.Interfaces; using SharpPulsar.Precondition; -using static System.Runtime.InteropServices.JavaScript.JSType; using Range = SharpPulsar.Common.Range; /// diff --git a/src/SharpPulsar/ClientCnx.cs b/src/SharpPulsar/ClientCnx.cs index 47b4ef399..3c64659ef 100644 --- a/src/SharpPulsar/ClientCnx.cs +++ b/src/SharpPulsar/ClientCnx.cs @@ -1,5 +1,4 @@ using Akka.Actor; -using Akka.Event; using SharpPulsar.Configuration; using SharpPulsar.Interfaces; using SharpPulsar.Model; @@ -21,7 +20,6 @@ using System.Net; using SharpPulsar.SocketImpl; using System.Threading.Tasks; -using Org.BouncyCastle.Asn1.Ocsp; namespace SharpPulsar { diff --git a/src/SharpPulsar/Configuration/ObjectMapper.cs b/src/SharpPulsar/Configuration/ObjectMapper.cs index 218a73c99..5b1daf5f3 100644 --- a/src/SharpPulsar/Configuration/ObjectMapper.cs +++ b/src/SharpPulsar/Configuration/ObjectMapper.cs @@ -1,7 +1,5 @@ using System; using System.IO; -using System.Runtime.Serialization; -using System.Runtime.Serialization.Formatters.Binary; using System.Text.Json; using Newtonsoft.Json.Linq; diff --git a/src/SharpPulsar/Configuration/ReaderConfigurationData.cs b/src/SharpPulsar/Configuration/ReaderConfigurationData.cs index 0371fe2cb..2e6365853 100644 --- a/src/SharpPulsar/Configuration/ReaderConfigurationData.cs +++ b/src/SharpPulsar/Configuration/ReaderConfigurationData.cs @@ -3,7 +3,6 @@ using System.Linq; using SharpPulsar.Common.Compression; using SharpPulsar.Interfaces; -using static System.Runtime.InteropServices.JavaScript.JSType; /// /// Licensed to the Apache Software Foundation (ASF) under one diff --git a/src/SharpPulsar/ConnectionHandler.cs b/src/SharpPulsar/ConnectionHandler.cs index a1fec6a9f..2d8249fd0 100644 --- a/src/SharpPulsar/ConnectionHandler.cs +++ b/src/SharpPulsar/ConnectionHandler.cs @@ -1,5 +1,4 @@ using Akka.Actor; -using Akka.Event; using SharpPulsar.Exceptions; using System; using System.Threading.Tasks; diff --git a/src/SharpPulsar/ConnectionPool.cs b/src/SharpPulsar/ConnectionPool.cs index f43dc61a3..004134ef0 100644 --- a/src/SharpPulsar/ConnectionPool.cs +++ b/src/SharpPulsar/ConnectionPool.cs @@ -1,5 +1,4 @@ using Akka.Actor; -using Akka.Event; using Akka.Util.Internal; using SharpPulsar.Configuration; using SharpPulsar.Extension; @@ -15,7 +14,7 @@ namespace SharpPulsar { - public class ConnectionPool : ReceiveActor, IWithUnboundedStash + public class ConnectionPool : ReceiveActor, IWithUnboundedStash { private readonly Dictionary> _pool; diff --git a/src/SharpPulsar/ConsumerActor.cs b/src/SharpPulsar/ConsumerActor.cs index 4b873a57e..985cbe734 100644 --- a/src/SharpPulsar/ConsumerActor.cs +++ b/src/SharpPulsar/ConsumerActor.cs @@ -1,6 +1,5 @@ using Akka.Actor; using Akka.Util; -using OpenTelemetry; using ProtoBuf; using SharpPulsar.Auth; using SharpPulsar.Batch; @@ -18,7 +17,6 @@ using SharpPulsar.Messages.Requests; using SharpPulsar.Messages.Transaction; using SharpPulsar.Precondition; -using SharpPulsar.Protocol; using SharpPulsar.Protocol.Proto; using SharpPulsar.Shared; using SharpPulsar.Stats.Consumer; diff --git a/src/SharpPulsar/ConsumerActorBase.cs b/src/SharpPulsar/ConsumerActorBase.cs index f659c1607..941f84b76 100644 --- a/src/SharpPulsar/ConsumerActorBase.cs +++ b/src/SharpPulsar/ConsumerActorBase.cs @@ -1,11 +1,9 @@ using Akka.Actor; using Akka.Dispatch; -using Akka.Event; using Akka.Util; using Akka.Util.Internal; using SharpPulsar.Batch.Api; using SharpPulsar.Configuration; -using SharpPulsar.EventSource.Messages; using SharpPulsar.Exceptions; using SharpPulsar.Extension; using SharpPulsar.Interfaces; @@ -17,8 +15,6 @@ using System; using System.Collections.Concurrent; using System.Collections.Generic; -using System.Diagnostics; -using System.IO; using System.Text; using System.Threading.Tasks; using System.Threading.Tasks.Dataflow; @@ -924,15 +920,15 @@ private void Push(IMessage o) { //IncomingMessages.Post(o); Context.Parent.Tell(new ReceivedMessage(o)); - _log.Info($"Pushed message with sequnceid {o.SequenceId} (topic:{Topic}) to consumer parent"); + _log.Info($"Pushed message with SequenceId {o.SequenceId} (topic:{Topic}) to consumer parent"); } else { if (IncomingMessages.Post(o)) - _log.Info($"Added message with sequnceid {o.SequenceId} (key:{o.Key}) to IncomingMessages. Message Count: {IncomingMessages.Count}"); + _log.Info($"Added message with SequenceId {o.SequenceId} (key:{o.Key}) to IncomingMessages. Message Count: {IncomingMessages.Count}"); else - _log.Info($"Failed to add message with sequnceid {o.SequenceId} to IncomingMessages"); + _log.Info($"Failed to add message with SequenceId {o.SequenceId} to IncomingMessages"); } } } diff --git a/src/SharpPulsar/ConsumerInterceptors.cs b/src/SharpPulsar/ConsumerInterceptors.cs index 07ebb4c40..5db82e8bb 100644 --- a/src/SharpPulsar/ConsumerInterceptors.cs +++ b/src/SharpPulsar/ConsumerInterceptors.cs @@ -1,7 +1,6 @@ using System; using System.Collections.Generic; using Akka.Actor; -using Akka.Event; using SharpPulsar.Interfaces; @@ -25,11 +24,11 @@ /// namespace SharpPulsar { - /// - /// A container that hold the list and wraps calls to the chain - /// of custom interceptors. - /// - public class ConsumerInterceptors : IDisposable + /// + /// A container that hold the list and wraps calls to the chain + /// of custom interceptors. + /// + public class ConsumerInterceptors : IDisposable { private readonly ILoggingAdapter _log; diff --git a/src/SharpPulsar/Crypto/MessageCrypto.cs b/src/SharpPulsar/Crypto/MessageCrypto.cs index 18cbc9560..b82eb326b 100644 --- a/src/SharpPulsar/Crypto/MessageCrypto.cs +++ b/src/SharpPulsar/Crypto/MessageCrypto.cs @@ -23,7 +23,6 @@ using System.Collections.Generic; using System.Linq; using System.Security.Cryptography; -using Akka.Event; using Org.BouncyCastle.Security; using SharpPulsar.Cache; diff --git a/src/SharpPulsar/DefaultImplementation.cs b/src/SharpPulsar/DefaultImplementation.cs index 762a969fe..07ab29422 100644 --- a/src/SharpPulsar/DefaultImplementation.cs +++ b/src/SharpPulsar/DefaultImplementation.cs @@ -9,7 +9,6 @@ using NodaTime; using SharpPulsar.Shared; using SharpPulsar.Schemas.Generic; -using Akka.Event; using SharpPulsar.Interfaces.Schema; /// diff --git a/src/SharpPulsar/EventSource/Pulsar/PulsarSourceActor.cs b/src/SharpPulsar/EventSource/Pulsar/PulsarSourceActor.cs index a787e8c49..257bae6ce 100644 --- a/src/SharpPulsar/EventSource/Pulsar/PulsarSourceActor.cs +++ b/src/SharpPulsar/EventSource/Pulsar/PulsarSourceActor.cs @@ -1,9 +1,7 @@ using System; using System.Linq; -using System.Reflection.Emit; using System.Threading.Tasks; using Akka.Actor; -using SharpPulsar.Batch; using SharpPulsar.Common; using SharpPulsar.Common.Naming; using SharpPulsar.Configuration; diff --git a/src/SharpPulsar/EventSource/Trino/Tagged/TrinoTaggedSourceActor.cs b/src/SharpPulsar/EventSource/Trino/Tagged/TrinoTaggedSourceActor.cs index 926dc8f3b..004bc1952 100644 --- a/src/SharpPulsar/EventSource/Trino/Tagged/TrinoTaggedSourceActor.cs +++ b/src/SharpPulsar/EventSource/Trino/Tagged/TrinoTaggedSourceActor.cs @@ -1,7 +1,6 @@ using System; using System.Linq; using Akka.Actor; -using Akka.Event; using SharpPulsar.EventSource.Messages; using SharpPulsar.EventSource.Messages.Presto; using SharpPulsar.Messages.Consumer; diff --git a/src/SharpPulsar/EventSource/Trino/TrinoSourceActor.cs b/src/SharpPulsar/EventSource/Trino/TrinoSourceActor.cs index 4b6a269e3..f516a8092 100644 --- a/src/SharpPulsar/EventSource/Trino/TrinoSourceActor.cs +++ b/src/SharpPulsar/EventSource/Trino/TrinoSourceActor.cs @@ -1,7 +1,6 @@ using System; using System.Linq; using Akka.Actor; -using Akka.Event; using SharpPulsar.EventSource.Messages; using SharpPulsar.Common.Naming; using System.Threading.Tasks.Dataflow; diff --git a/src/SharpPulsar/Events/SqlSource.cs b/src/SharpPulsar/Events/SqlSource.cs index c240d5842..2f4a3cc55 100644 --- a/src/SharpPulsar/Events/SqlSource.cs +++ b/src/SharpPulsar/Events/SqlSource.cs @@ -8,7 +8,6 @@ using System.Runtime.CompilerServices; using System.Threading; using System.Threading.Tasks.Dataflow; -using static System.Net.WebRequestMethods; namespace SharpPulsar.Events { diff --git a/src/SharpPulsar/Interfaces/IReaderBuilder.cs b/src/SharpPulsar/Interfaces/IReaderBuilder.cs index 7c6f80b95..2c2f66e63 100644 --- a/src/SharpPulsar/Interfaces/IReaderBuilder.cs +++ b/src/SharpPulsar/Interfaces/IReaderBuilder.cs @@ -1,7 +1,6 @@ using System; using System.Collections.Generic; using System.Threading.Tasks; -using DotNetty.Common.Utilities; using SharpPulsar.Common.Compression; /// diff --git a/src/SharpPulsar/Messages/Consumer/AcknowledgeCumulative.cs b/src/SharpPulsar/Messages/Consumer/AcknowledgeCumulative.cs index 2f2a3e3d5..f408d0698 100644 --- a/src/SharpPulsar/Messages/Consumer/AcknowledgeCumulative.cs +++ b/src/SharpPulsar/Messages/Consumer/AcknowledgeCumulative.cs @@ -2,8 +2,6 @@ using System.Collections.Generic; using System.Collections.Immutable; using Akka.Actor; -using Akka.Dispatch.SysMsg; -using Avro.Util; using SharpPulsar.Interfaces; namespace SharpPulsar.Messages.Consumer diff --git a/src/SharpPulsar/Messages/Requests/GetConnection.cs b/src/SharpPulsar/Messages/Requests/GetConnection.cs index bee2045c6..3cc2285a1 100644 --- a/src/SharpPulsar/Messages/Requests/GetConnection.cs +++ b/src/SharpPulsar/Messages/Requests/GetConnection.cs @@ -1,7 +1,4 @@ using Akka.Actor; -using Akka.Dispatch.SysMsg; -using Avro.Util; -using System; using System.Net; namespace SharpPulsar.Messages.Requests diff --git a/src/SharpPulsar/Messages/Transaction/NewTxnResponse.cs b/src/SharpPulsar/Messages/Transaction/NewTxnResponse.cs index ccf3a3cce..d2a618014 100644 --- a/src/SharpPulsar/Messages/Transaction/NewTxnResponse.cs +++ b/src/SharpPulsar/Messages/Transaction/NewTxnResponse.cs @@ -1,9 +1,5 @@ -using Akka.Dispatch.SysMsg; -using Avro.Util; -using System; -using SharpPulsar.Exceptions; +using SharpPulsar.Exceptions; using SharpPulsar.Protocol.Proto; -using SharpPulsar.Admin.v2; namespace SharpPulsar.Messages.Transaction { diff --git a/src/SharpPulsar/MultiTopicsConsumer.cs b/src/SharpPulsar/MultiTopicsConsumer.cs index f077539f0..396980e56 100644 --- a/src/SharpPulsar/MultiTopicsConsumer.cs +++ b/src/SharpPulsar/MultiTopicsConsumer.cs @@ -5,7 +5,6 @@ using SharpPulsar.Cache; using SharpPulsar.Common.Naming; using SharpPulsar.Configuration; -using SharpPulsar.EventSource.Messages; using SharpPulsar.Exceptions; using SharpPulsar.Extension; using SharpPulsar.Interfaces; diff --git a/src/SharpPulsar/MultiTopicsReader.cs b/src/SharpPulsar/MultiTopicsReader.cs index ef89cfdee..38fe91d49 100644 --- a/src/SharpPulsar/MultiTopicsReader.cs +++ b/src/SharpPulsar/MultiTopicsReader.cs @@ -110,34 +110,34 @@ public MultiTopicsReader(IActorRef state, IActorRef client, IActorRef lookup, IA await SubscribeToTopic(sub); }); Receive(m => { - _consumer.Tell(m, Sender); + _consumer.Forward(m); }); Receive>(m => { - _consumer.Tell(m, Sender); + _consumer.Forward(m); }); Receive>(m => { - _consumer.Tell(m, Sender); + _consumer.Forward(m); }); Receive(m => { - _consumer.Tell(m, Sender); + _consumer.Forward(m); }); Receive(m => { - _consumer.Tell(m, Sender); + _consumer.Forward(m); }); Receive(m => { - _consumer.Tell(m, Sender); + _consumer.Forward(m); }); Receive(m => { - _consumer.Tell(m, Sender); + _consumer.Forward(m); }); Receive(m => { - _consumer.Tell(m, Sender); + _consumer.Forward(m); }); Receive(m => { - _consumer.Tell(m, Sender); + _consumer.Forward(m); }); ReceiveAny(m => { - _consumer.Tell(m, Sender); + _consumer.Forward(m); }); } public static Props Prop(IActorRef state, IActorRef client, IActorRef lookup, IActorRef cnxPool, IActorRef idGenerator, ReaderConfigurationData readerConfiguration, ISchema schema, ClientConfigurationData clientConfigurationData, TaskCompletionSource subscribeFuture) diff --git a/src/SharpPulsar/PartitionedProducerActor.cs b/src/SharpPulsar/PartitionedProducerActor.cs index 27eaf2a45..0e59dfe7e 100644 --- a/src/SharpPulsar/PartitionedProducerActor.cs +++ b/src/SharpPulsar/PartitionedProducerActor.cs @@ -1,5 +1,4 @@ using Akka.Actor; -using Akka.Event; using Akka.Routing; using Akka.Util.Internal; using SharpPulsar.Common; @@ -22,7 +21,6 @@ using SharpPulsar.Precondition; using SharpPulsar.Common.Util; using SharpPulsar.Messages; -using SharpPulsar.Messages.Requests; /// /// Licensed to the Apache Software Foundation (ASF) under one diff --git a/src/SharpPulsar/PatternMultiTopicsConsumer.cs b/src/SharpPulsar/PatternMultiTopicsConsumer.cs index 65ac025cc..c99b1f79c 100644 --- a/src/SharpPulsar/PatternMultiTopicsConsumer.cs +++ b/src/SharpPulsar/PatternMultiTopicsConsumer.cs @@ -1,6 +1,4 @@ using Akka.Actor; -using Akka.Dispatch.SysMsg; -using Akka.IO; using Akka.Util.Internal; using SharpPulsar.Common; using SharpPulsar.Common.Naming; diff --git a/src/SharpPulsar/ProducerActor.cs b/src/SharpPulsar/ProducerActor.cs index 38629ea91..4df084eb6 100644 --- a/src/SharpPulsar/ProducerActor.cs +++ b/src/SharpPulsar/ProducerActor.cs @@ -1,5 +1,4 @@ using Akka.Actor; -using Akka.Event; using Akka.Util; using App.Metrics.Concurrency; using DotNetty.Common.Utilities; diff --git a/src/SharpPulsar/ProducerInterceptors.cs b/src/SharpPulsar/ProducerInterceptors.cs index 024c6bf43..7fce4cccd 100644 --- a/src/SharpPulsar/ProducerInterceptors.cs +++ b/src/SharpPulsar/ProducerInterceptors.cs @@ -1,5 +1,4 @@ using Akka.Actor; -using Akka.Event; using SharpPulsar.Interfaces; using SharpPulsar.Interfaces.Interceptor; using System; @@ -27,11 +26,11 @@ namespace SharpPulsar { - /// - /// A container that holds the list - /// and wraps calls to the chain of custom interceptors. - /// - public class ProducerInterceptors : IDisposable + /// + /// A container that holds the list + /// and wraps calls to the chain of custom interceptors. + /// + public class ProducerInterceptors : IDisposable { private readonly ILoggingAdapter _log; diff --git a/src/SharpPulsar/PulsarClient.cs b/src/SharpPulsar/PulsarClient.cs index 0c8286312..b735446c5 100644 --- a/src/SharpPulsar/PulsarClient.cs +++ b/src/SharpPulsar/PulsarClient.cs @@ -2,12 +2,9 @@ using System.Collections.Concurrent; using System.Collections.Generic; using System.Collections.Immutable; -using System.Diagnostics; using System.Linq; -using System.Reflection.Emit; using System.Threading.Tasks; using Akka.Actor; -using Akka.Event; using Akka.Util; using SharpPulsar.Builder; using SharpPulsar.Cache; @@ -19,7 +16,6 @@ using SharpPulsar.Exceptions; using SharpPulsar.Interfaces; using SharpPulsar.Interfaces.Schema; -using SharpPulsar.Messages; using SharpPulsar.Messages.Client; using SharpPulsar.Messages.Consumer; using SharpPulsar.Messages.Producer; @@ -28,7 +24,6 @@ using SharpPulsar.Schemas; using SharpPulsar.Schemas.Generic; using SharpPulsar.Table; -using SharpPulsar.Table.Messages; using SharpPulsar.TransactionImpl; using SharpPulsar.Utils; using static SharpPulsar.Protocol.Proto.CommandGetTopicsOfNamespace; diff --git a/src/SharpPulsar/PulsarClientActor.cs b/src/SharpPulsar/PulsarClientActor.cs index 0c5eb4155..425a7a54f 100644 --- a/src/SharpPulsar/PulsarClientActor.cs +++ b/src/SharpPulsar/PulsarClientActor.cs @@ -1,5 +1,4 @@ using Akka.Actor; -using Akka.Event; using SharpPulsar.Auth; using SharpPulsar.Configuration; using SharpPulsar.Exceptions; diff --git a/src/SharpPulsar/PulsarSystem.cs b/src/SharpPulsar/PulsarSystem.cs index 9c3f35d82..e44b37c1e 100644 --- a/src/SharpPulsar/PulsarSystem.cs +++ b/src/SharpPulsar/PulsarSystem.cs @@ -1,6 +1,5 @@ using Akka.Actor; using Akka.Configuration; -using Akka.Logger.Serilog; using Serilog; using SharpPulsar.Configuration; using SharpPulsar.Messages.Client; diff --git a/src/SharpPulsar/ReaderActor.cs b/src/SharpPulsar/ReaderActor.cs index 2ac735e66..4693dc250 100644 --- a/src/SharpPulsar/ReaderActor.cs +++ b/src/SharpPulsar/ReaderActor.cs @@ -100,34 +100,34 @@ public ReaderActor(long consumerId, IActorRef stateActor, IActorRef client, IAct consumerConfiguration.Interceptors = consumerInterceptors; _consumer = Context.ActorOf(ConsumerActor.Prop(consumerId, stateActor, client, lookup, cnxPool, _generator, readerConfiguration.TopicName, consumerConfiguration, partitionIdx, false, false, readerConfiguration.StartMessageId, readerConfiguration.StartMessageFromRollbackDurationInSec, schema, true, clientConfigurationData, subscribeFuture)); Receive(m => { - _consumer.Tell(m, Sender); + _consumer.Forward(m); }); Receive> (m => { - _consumer.Tell(m, Sender); + _consumer.Forward(m); }); Receive (m => { - _consumer.Tell(m, Sender); + _consumer.Forward(m); }); Receive (m => { - _consumer.Tell(m, Sender); + _consumer.Forward(m); }); Receive> (m => { - _consumer.Tell(m, Sender); + _consumer.Forward(m); }); Receive (m => { - _consumer.Tell(m, Sender); + _consumer.Forward(m); }); Receive (m => { - _consumer.Tell(m, Sender); + _consumer.Forward(m); }); Receive (m => { - _consumer.Tell(m, Sender); + _consumer.Forward(m); }); Receive (m => { - _consumer.Tell(m, Sender); + _consumer.Forward(m); }); Receive (m => { - _consumer.Tell(m, Sender); + _consumer.Forward(m); }); } diff --git a/src/SharpPulsar/Schemas/Generic/MultiVersionSchemaInfoProvider.cs b/src/SharpPulsar/Schemas/Generic/MultiVersionSchemaInfoProvider.cs index cb3ed5bb1..56174a527 100644 --- a/src/SharpPulsar/Schemas/Generic/MultiVersionSchemaInfoProvider.cs +++ b/src/SharpPulsar/Schemas/Generic/MultiVersionSchemaInfoProvider.cs @@ -1,7 +1,6 @@ using SharpPulsar.Common; using SharpPulsar.Common.Naming; using SharpPulsar.Protocol.Schema; -using Akka.Event; using Akka.Actor; using SharpPulsar.Messages.Requests; using SharpPulsar.Cache; diff --git a/src/SharpPulsar/ServiceName/PulsarServiceNameResolver.cs b/src/SharpPulsar/ServiceName/PulsarServiceNameResolver.cs index 86fe52dd6..d0130590f 100644 --- a/src/SharpPulsar/ServiceName/PulsarServiceNameResolver.cs +++ b/src/SharpPulsar/ServiceName/PulsarServiceNameResolver.cs @@ -2,7 +2,6 @@ using System; using System.Collections.Generic; using DotNetty.Common.Internal; -using Akka.Event; using System.Net; /// diff --git a/src/SharpPulsar/ServiceProvider/AutoClusterFailoverActor.cs b/src/SharpPulsar/ServiceProvider/AutoClusterFailoverActor.cs index 0f7c124ef..84dd6815b 100644 --- a/src/SharpPulsar/ServiceProvider/AutoClusterFailoverActor.cs +++ b/src/SharpPulsar/ServiceProvider/AutoClusterFailoverActor.cs @@ -1,7 +1,6 @@ using System; using System.Collections.Generic; using Akka.Actor; -using Akka.Event; using SharpPulsar.Interfaces; using SharpPulsar.ServiceName; using System.Net.Sockets; diff --git a/src/SharpPulsar/ServiceProvider/ControlledClusterFailoverActor.cs b/src/SharpPulsar/ServiceProvider/ControlledClusterFailoverActor.cs index 511d25201..b68029511 100644 --- a/src/SharpPulsar/ServiceProvider/ControlledClusterFailoverActor.cs +++ b/src/SharpPulsar/ServiceProvider/ControlledClusterFailoverActor.cs @@ -4,7 +4,6 @@ using System.Text.Json; using Akka.Actor; using Akka.Annotations; -using Akka.Event; using Akka.Util.Internal; using SharpPulsar.Auth; using SharpPulsar.Builder; diff --git a/src/SharpPulsar/SharpPulsar.csproj b/src/SharpPulsar/SharpPulsar.csproj index 2b56e2c44..a2f9724d4 100644 --- a/src/SharpPulsar/SharpPulsar.csproj +++ b/src/SharpPulsar/SharpPulsar.csproj @@ -14,20 +14,20 @@ - - + + - + - + all runtime; build; native; contentfiles; analyzers; buildtransitive @@ -36,7 +36,7 @@ - + @@ -46,7 +46,7 @@ - + diff --git a/src/SharpPulsar/SocketImpl/Heartbeat.cs b/src/SharpPulsar/SocketImpl/Heartbeat.cs index d70b20fdd..5eda9fc57 100644 --- a/src/SharpPulsar/SocketImpl/Heartbeat.cs +++ b/src/SharpPulsar/SocketImpl/Heartbeat.cs @@ -1,5 +1,4 @@ -using Akka.Event; -using System; +using System; using System.Net.Sockets; using System.Reactive.Disposables; using System.Reactive.Linq; diff --git a/src/SharpPulsar/SocketImpl/SocketClient.cs b/src/SharpPulsar/SocketImpl/SocketClient.cs index a586689ac..6eaececf2 100644 --- a/src/SharpPulsar/SocketImpl/SocketClient.cs +++ b/src/SharpPulsar/SocketImpl/SocketClient.cs @@ -1,5 +1,4 @@ -using Akka.Event; -using SharpPulsar.Common; +using SharpPulsar.Common; using SharpPulsar.Configuration; using SharpPulsar.Extension; using SharpPulsar.Protocol.Proto; diff --git a/src/SharpPulsar/Stats/Consumer/ConsumerStatsRecorder.cs b/src/SharpPulsar/Stats/Consumer/ConsumerStatsRecorder.cs index 8e96e2df8..3cd229276 100644 --- a/src/SharpPulsar/Stats/Consumer/ConsumerStatsRecorder.cs +++ b/src/SharpPulsar/Stats/Consumer/ConsumerStatsRecorder.cs @@ -3,7 +3,6 @@ using System.IO; using System.Text.Json; using Akka.Actor; -using Akka.Event; using App.Metrics.Concurrency; using SharpPulsar.Configuration; using SharpPulsar.Stats.Consumer.Api; diff --git a/src/SharpPulsar/Stats/Producer/ProducerStatsRecorder.cs b/src/SharpPulsar/Stats/Producer/ProducerStatsRecorder.cs index 50b942e4f..9a12811b5 100644 --- a/src/SharpPulsar/Stats/Producer/ProducerStatsRecorder.cs +++ b/src/SharpPulsar/Stats/Producer/ProducerStatsRecorder.cs @@ -5,7 +5,6 @@ using System.Linq; using System.Text.Json; using Akka.Actor; -using Akka.Event; using App.Metrics.Concurrency; using SharpPulsar.Configuration; @@ -31,7 +30,7 @@ /// namespace SharpPulsar.Stats.Producer { - + public sealed class ProducerStatsRecorder : IProducerStatsRecorder { internal ICancelable StatTimeout { get; set; } diff --git a/src/SharpPulsar/Table/PartitionReader.cs b/src/SharpPulsar/Table/PartitionReader.cs index 28def1bed..6993eb7a7 100644 --- a/src/SharpPulsar/Table/PartitionReader.cs +++ b/src/SharpPulsar/Table/PartitionReader.cs @@ -1,7 +1,6 @@ using System; using System.Threading.Tasks; using Akka.Actor; -using Akka.Event; using App.Metrics.Concurrency; using SharpPulsar.Table.Messages; diff --git a/src/SharpPulsar/Table/TableViewActor.cs b/src/SharpPulsar/Table/TableViewActor.cs index b8772d14a..0545a1e7f 100644 --- a/src/SharpPulsar/Table/TableViewActor.cs +++ b/src/SharpPulsar/Table/TableViewActor.cs @@ -3,9 +3,7 @@ using System.Collections.Generic; using System.Threading.Tasks; using Akka.Actor; -using Akka.Event; using Akka.Util.Internal; -using DotNetty.Common.Utilities; using SharpPulsar.Builder; using SharpPulsar.Common.Naming; using SharpPulsar.Interfaces; diff --git a/src/SharpPulsar/Telemetry/Trace/ConsumerOTelInterceptor.cs b/src/SharpPulsar/Telemetry/Trace/ConsumerOTelInterceptor.cs index 399c10a21..19240d21f 100644 --- a/src/SharpPulsar/Telemetry/Trace/ConsumerOTelInterceptor.cs +++ b/src/SharpPulsar/Telemetry/Trace/ConsumerOTelInterceptor.cs @@ -3,7 +3,6 @@ using System.Diagnostics; using System.Linq; using Akka.Actor; -using Akka.Event; using Akka.Util.Internal; using OpenTelemetry.Context.Propagation; using SharpPulsar.Common.Naming; diff --git a/src/SharpPulsar/Telemetry/Trace/ProducerOTelInterceptor.cs b/src/SharpPulsar/Telemetry/Trace/ProducerOTelInterceptor.cs index 819ed0ddd..58b21cdec 100644 --- a/src/SharpPulsar/Telemetry/Trace/ProducerOTelInterceptor.cs +++ b/src/SharpPulsar/Telemetry/Trace/ProducerOTelInterceptor.cs @@ -2,7 +2,6 @@ using System.Collections.Generic; using System.Diagnostics; using Akka.Actor; -using Akka.Event; using Akka.Util.Internal; using OpenTelemetry; using OpenTelemetry.Context.Propagation; diff --git a/src/SharpPulsar/Tls/TlsHostnameVerifier.cs b/src/SharpPulsar/Tls/TlsHostnameVerifier.cs index f1aeeb801..ae040c75e 100644 --- a/src/SharpPulsar/Tls/TlsHostnameVerifier.cs +++ b/src/SharpPulsar/Tls/TlsHostnameVerifier.cs @@ -1,5 +1,4 @@ -using Akka.Event; -using Nager.PublicSuffix; +using Nager.PublicSuffix; using SharpPulsar.Common; using System; using System.Collections.Generic; diff --git a/src/SharpPulsar/TopicListWatcherActor.cs b/src/SharpPulsar/TopicListWatcherActor.cs index fbc5f0a25..00a959914 100644 --- a/src/SharpPulsar/TopicListWatcherActor.cs +++ b/src/SharpPulsar/TopicListWatcherActor.cs @@ -10,7 +10,6 @@ using SharpPulsar.Messages.Requests; using SharpPulsar.Protocol.Proto; using SharpPulsar.Protocol; -using Akka.Event; using SharpPulsar.Messages.Client; using SharpPulsar.Messages.Consumer; using SharpPulsar.Messages.Transaction; diff --git a/src/SharpPulsar/Tracker/NegativeAcksTracker.cs b/src/SharpPulsar/Tracker/NegativeAcksTracker.cs index 8efe74834..0923b7c8b 100644 --- a/src/SharpPulsar/Tracker/NegativeAcksTracker.cs +++ b/src/SharpPulsar/Tracker/NegativeAcksTracker.cs @@ -28,8 +28,6 @@ using SharpPulsar.Interfaces; using SharpPulsar.Messages.Consumer; using System.Threading.Tasks; -using Akka.Event; -using System.Threading; namespace SharpPulsar.Tracker { diff --git a/src/SharpPulsar/Tracker/UnAckedMessageRedeliveryTracker.cs b/src/SharpPulsar/Tracker/UnAckedMessageRedeliveryTracker.cs index 340430ea6..6898d9827 100644 --- a/src/SharpPulsar/Tracker/UnAckedMessageRedeliveryTracker.cs +++ b/src/SharpPulsar/Tracker/UnAckedMessageRedeliveryTracker.cs @@ -1,7 +1,6 @@ using System; using System.Collections.Generic; using Akka.Actor; -using Akka.Event; using Akka.Util.Internal; using SharpPulsar.Configuration; using SharpPulsar.Extension; diff --git a/src/SharpPulsar/Tracker/UnAckedMessageTracker.cs b/src/SharpPulsar/Tracker/UnAckedMessageTracker.cs index 3949ad52b..e98782c9a 100644 --- a/src/SharpPulsar/Tracker/UnAckedMessageTracker.cs +++ b/src/SharpPulsar/Tracker/UnAckedMessageTracker.cs @@ -24,7 +24,6 @@ using System.Linq; using System.Threading.Tasks; using Akka.Actor; -using Akka.Event; using Akka.Util.Internal; using SharpPulsar.Configuration; using SharpPulsar.Extension; diff --git a/src/SharpPulsar/Tracker/UnAckedMessageTrackerDisabled.cs b/src/SharpPulsar/Tracker/UnAckedMessageTrackerDisabled.cs index bed3ffb9f..e15353040 100644 --- a/src/SharpPulsar/Tracker/UnAckedMessageTrackerDisabled.cs +++ b/src/SharpPulsar/Tracker/UnAckedMessageTrackerDisabled.cs @@ -1,5 +1,4 @@ using Akka.Actor; -using Akka.Event; using SharpPulsar.Tracker.Messages; namespace SharpPulsar.Tracker diff --git a/src/SharpPulsar/TransactionImpl/TransactionActor.cs b/src/SharpPulsar/TransactionImpl/TransactionActor.cs index 69cb7d9b2..77f0036e9 100644 --- a/src/SharpPulsar/TransactionImpl/TransactionActor.cs +++ b/src/SharpPulsar/TransactionImpl/TransactionActor.cs @@ -1,12 +1,10 @@ using Akka.Actor; -using Akka.Event; using Akka.Util.Internal; using SharpPulsar.Interfaces; using SharpPulsar.Messages; using SharpPulsar.Messages.Consumer; using SharpPulsar.Messages.Requests; using SharpPulsar.Messages.Transaction; -using System; using System.Collections.Generic; using static SharpPulsar.Exceptions.TransactionCoordinatorClientException; diff --git a/src/SharpPulsar/TransactionImpl/TransactionBuilder.cs b/src/SharpPulsar/TransactionImpl/TransactionBuilder.cs index 2a1be9c49..c83f86af9 100644 --- a/src/SharpPulsar/TransactionImpl/TransactionBuilder.cs +++ b/src/SharpPulsar/TransactionImpl/TransactionBuilder.cs @@ -1,5 +1,4 @@ using Akka.Actor; -using Akka.Event; using SharpPulsar.Interfaces.Transaction; using SharpPulsar.Messages; using SharpPulsar.Messages.Consumer; diff --git a/src/SharpPulsar/TransactionImpl/TransactionCoordinatorClient.cs b/src/SharpPulsar/TransactionImpl/TransactionCoordinatorClient.cs index 73fe63164..c73eec6b3 100644 --- a/src/SharpPulsar/TransactionImpl/TransactionCoordinatorClient.cs +++ b/src/SharpPulsar/TransactionImpl/TransactionCoordinatorClient.cs @@ -1,5 +1,4 @@ using Akka.Actor; -using Akka.Event; using SharpPulsar.Common.Naming; using SharpPulsar.Common.Partition; using SharpPulsar.Configuration; diff --git a/src/SharpPulsar/TransactionMetaStoreHandler.cs b/src/SharpPulsar/TransactionMetaStoreHandler.cs index f93decf46..e258b3c61 100644 --- a/src/SharpPulsar/TransactionMetaStoreHandler.cs +++ b/src/SharpPulsar/TransactionMetaStoreHandler.cs @@ -1,5 +1,4 @@ using Akka.Actor; -using Akka.Event; using SharpPulsar.Configuration; using SharpPulsar.Exceptions; using SharpPulsar.Messages; diff --git a/src/SharpPulsar/UtilityActor.cs b/src/SharpPulsar/UtilityActor.cs index 9aec74bc7..888f25c33 100644 --- a/src/SharpPulsar/UtilityActor.cs +++ b/src/SharpPulsar/UtilityActor.cs @@ -9,7 +9,6 @@ // modifications are permitted. using Akka.Actor; -using Akka.Event; using System.Text; namespace SharpPulsar diff --git a/src/SharpPulsar/ZeroQueueConsumer.cs b/src/SharpPulsar/ZeroQueueConsumer.cs index b67ae0452..b35e704e9 100644 --- a/src/SharpPulsar/ZeroQueueConsumer.cs +++ b/src/SharpPulsar/ZeroQueueConsumer.cs @@ -3,12 +3,10 @@ using SharpPulsar.Exceptions; using SharpPulsar.Extension; using SharpPulsar.Interfaces; -using SharpPulsar.Messages.Consumer; using SharpPulsar.Precondition; using SharpPulsar.Protocol.Proto; using System; using System.Collections.Generic; -using System.Text.RegularExpressions; using System.Threading.Tasks; using System.Threading.Tasks.Dataflow; diff --git a/src/Testcontainers.Pulsar/Testcontainers.Pulsar.csproj b/src/Testcontainers.Pulsar/Testcontainers.Pulsar.csproj index bd2494829..ae95112e9 100644 --- a/src/Testcontainers.Pulsar/Testcontainers.Pulsar.csproj +++ b/src/Testcontainers.Pulsar/Testcontainers.Pulsar.csproj @@ -7,7 +7,7 @@ - + diff --git a/src/Testcontainers.Pulsar/Usings.cs b/src/Testcontainers.Pulsar/Usings.cs index 4598dccc7..976749643 100644 --- a/src/Testcontainers.Pulsar/Usings.cs +++ b/src/Testcontainers.Pulsar/Usings.cs @@ -1,5 +1,4 @@ -global using System; -global using System.Text; +global using System.Text; global using Docker.DotNet.Models; global using DotNet.Testcontainers.Builders; global using DotNet.Testcontainers.Configurations;