diff --git a/Directory.Packages.props b/Directory.Packages.props
index 434d39d..6388cd9 100644
--- a/Directory.Packages.props
+++ b/Directory.Packages.props
@@ -5,18 +5,14 @@
-
-
-
-
-
-
+
+
@@ -30,4 +26,9 @@
-
\ No newline at end of file
+
+
+
+
+
+
diff --git a/RabbitMQ.AMQP.Client/IConsumer.cs b/RabbitMQ.AMQP.Client/IConsumer.cs
index 38831fd..f6e0465 100644
--- a/RabbitMQ.AMQP.Client/IConsumer.cs
+++ b/RabbitMQ.AMQP.Client/IConsumer.cs
@@ -2,7 +2,6 @@
namespace RabbitMQ.AMQP.Client;
-
public class ConsumerException(string message) : Exception(message);
public delegate void MessageHandler(IContext context, IMessage message);
diff --git a/RabbitMQ.AMQP.Client/PublicAPI.Shipped.txt b/RabbitMQ.AMQP.Client/PublicAPI.Shipped.txt
new file mode 100644
index 0000000..074c6ad
--- /dev/null
+++ b/RabbitMQ.AMQP.Client/PublicAPI.Shipped.txt
@@ -0,0 +1,2 @@
+#nullable enable
+
diff --git a/RabbitMQ.AMQP.Client/PublicAPI.Unshipped.txt b/RabbitMQ.AMQP.Client/PublicAPI.Unshipped.txt
new file mode 100644
index 0000000..8d24975
--- /dev/null
+++ b/RabbitMQ.AMQP.Client/PublicAPI.Unshipped.txt
@@ -0,0 +1,546 @@
+#nullable enable
+abstract RabbitMQ.AMQP.Client.Impl.AbstractLifeCycle.CloseAsync() -> System.Threading.Tasks.Task!
+const RabbitMQ.AMQP.Client.Impl.Consts.Bindings = "bindings" -> string!
+const RabbitMQ.AMQP.Client.Impl.Consts.Exchanges = "exchanges" -> string!
+const RabbitMQ.AMQP.Client.Impl.Consts.Key = "key" -> string!
+const RabbitMQ.AMQP.Client.Impl.Consts.Queues = "queues" -> string!
+override RabbitMQ.AMQP.Client.Error.ToString() -> string!
+override RabbitMQ.AMQP.Client.Impl.AmqpConnection.CloseAsync() -> System.Threading.Tasks.Task!
+override RabbitMQ.AMQP.Client.Impl.AmqpConnection.ToString() -> string!
+override RabbitMQ.AMQP.Client.Impl.AmqpConsumer.CloseAsync() -> System.Threading.Tasks.Task!
+override RabbitMQ.AMQP.Client.Impl.AmqpConsumer.ToString() -> string!
+override RabbitMQ.AMQP.Client.Impl.AmqpManagement.CloseAsync() -> System.Threading.Tasks.Task!
+override RabbitMQ.AMQP.Client.Impl.AmqpManagement.OpenAsync() -> System.Threading.Tasks.Task!
+override RabbitMQ.AMQP.Client.Impl.AmqpManagement.ToString() -> string!
+override RabbitMQ.AMQP.Client.Impl.AmqpPublisher.CloseAsync() -> System.Threading.Tasks.Task!
+override RabbitMQ.AMQP.Client.Impl.AmqpPublisher.ToString() -> string!
+override RabbitMQ.AMQP.Client.Impl.BackOffDelayPolicy.ToString() -> string!
+override RabbitMQ.AMQP.Client.Impl.ConnectionSettings.Equals(object? obj) -> bool
+override RabbitMQ.AMQP.Client.Impl.ConnectionSettings.GetHashCode() -> int
+override RabbitMQ.AMQP.Client.Impl.ConnectionSettings.ToString() -> string!
+override RabbitMQ.AMQP.Client.Impl.RecoveryConfiguration.ToString() -> string!
+override RabbitMQ.AMQP.Client.SaslMechanism.Equals(object? obj) -> bool
+override RabbitMQ.AMQP.Client.SaslMechanism.GetHashCode() -> int
+override sealed RabbitMQ.AMQP.Client.Impl.AmqpConsumer.OpenAsync() -> System.Threading.Tasks.Task!
+override sealed RabbitMQ.AMQP.Client.Impl.AmqpPublisher.OpenAsync() -> System.Threading.Tasks.Task!
+RabbitMQ.AMQP.Client.ByteCapacity
+RabbitMQ.AMQP.Client.ByteCapacity.Equals(RabbitMQ.AMQP.Client.ByteCapacity? other) -> bool
+RabbitMQ.AMQP.Client.ByteCapacity.ToBytes() -> long
+RabbitMQ.AMQP.Client.ClassicQueueMode
+RabbitMQ.AMQP.Client.ClassicQueueMode.Default = 0 -> RabbitMQ.AMQP.Client.ClassicQueueMode
+RabbitMQ.AMQP.Client.ClassicQueueMode.Lazy = 1 -> RabbitMQ.AMQP.Client.ClassicQueueMode
+RabbitMQ.AMQP.Client.ClassicQueueVersion
+RabbitMQ.AMQP.Client.ClassicQueueVersion.V1 = 0 -> RabbitMQ.AMQP.Client.ClassicQueueVersion
+RabbitMQ.AMQP.Client.ClassicQueueVersion.V2 = 1 -> RabbitMQ.AMQP.Client.ClassicQueueVersion
+RabbitMQ.AMQP.Client.ConnectionException
+RabbitMQ.AMQP.Client.ConnectionException.ConnectionException(string! message) -> void
+RabbitMQ.AMQP.Client.ConnectionException.ConnectionException(string! message, System.Exception! innerException) -> void
+RabbitMQ.AMQP.Client.ConsumerException
+RabbitMQ.AMQP.Client.ConsumerException.ConsumerException(string! message) -> void
+RabbitMQ.AMQP.Client.Error
+RabbitMQ.AMQP.Client.Error.Description.get -> string?
+RabbitMQ.AMQP.Client.Error.Error(string? errorCode, string? description) -> void
+RabbitMQ.AMQP.Client.Error.ErrorCode.get -> string?
+RabbitMQ.AMQP.Client.ExchangeType
+RabbitMQ.AMQP.Client.ExchangeType.DIRECT = 0 -> RabbitMQ.AMQP.Client.ExchangeType
+RabbitMQ.AMQP.Client.ExchangeType.FANOUT = 1 -> RabbitMQ.AMQP.Client.ExchangeType
+RabbitMQ.AMQP.Client.ExchangeType.HEADERS = 3 -> RabbitMQ.AMQP.Client.ExchangeType
+RabbitMQ.AMQP.Client.ExchangeType.TOPIC = 2 -> RabbitMQ.AMQP.Client.ExchangeType
+RabbitMQ.AMQP.Client.IAddressBuilder
+RabbitMQ.AMQP.Client.IAddressBuilder.Exchange(string! exchange) -> T
+RabbitMQ.AMQP.Client.IAddressBuilder.Key(string! key) -> T
+RabbitMQ.AMQP.Client.IAddressBuilder.Queue(string! queue) -> T
+RabbitMQ.AMQP.Client.IBackOffDelayPolicy
+RabbitMQ.AMQP.Client.IBackOffDelayPolicy.CurrentAttempt.get -> int
+RabbitMQ.AMQP.Client.IBackOffDelayPolicy.Delay() -> int
+RabbitMQ.AMQP.Client.IBackOffDelayPolicy.IsActive() -> bool
+RabbitMQ.AMQP.Client.IBackOffDelayPolicy.Reset() -> void
+RabbitMQ.AMQP.Client.IBindingSpecification
+RabbitMQ.AMQP.Client.IBindingSpecification.Argument(string! key, object! value) -> RabbitMQ.AMQP.Client.IBindingSpecification!
+RabbitMQ.AMQP.Client.IBindingSpecification.Arguments(System.Collections.Generic.Dictionary! arguments) -> RabbitMQ.AMQP.Client.IBindingSpecification!
+RabbitMQ.AMQP.Client.IBindingSpecification.Bind() -> System.Threading.Tasks.Task!
+RabbitMQ.AMQP.Client.IBindingSpecification.DestinationExchange(string! exchange) -> RabbitMQ.AMQP.Client.IBindingSpecification!
+RabbitMQ.AMQP.Client.IBindingSpecification.DestinationQueue(string! queue) -> RabbitMQ.AMQP.Client.IBindingSpecification!
+RabbitMQ.AMQP.Client.IBindingSpecification.Key(string! key) -> RabbitMQ.AMQP.Client.IBindingSpecification!
+RabbitMQ.AMQP.Client.IBindingSpecification.SourceExchange(string! exchange) -> RabbitMQ.AMQP.Client.IBindingSpecification!
+RabbitMQ.AMQP.Client.IBindingSpecification.Unbind() -> System.Threading.Tasks.Task!
+RabbitMQ.AMQP.Client.IClassicQueueSpecification
+RabbitMQ.AMQP.Client.IClassicQueueSpecification.MaxPriority(int maxPriority) -> RabbitMQ.AMQP.Client.IClassicQueueSpecification!
+RabbitMQ.AMQP.Client.IClassicQueueSpecification.Mode(RabbitMQ.AMQP.Client.ClassicQueueMode mode) -> RabbitMQ.AMQP.Client.IClassicQueueSpecification!
+RabbitMQ.AMQP.Client.IClassicQueueSpecification.Queue() -> RabbitMQ.AMQP.Client.IQueueSpecification!
+RabbitMQ.AMQP.Client.IClassicQueueSpecification.Version(RabbitMQ.AMQP.Client.ClassicQueueVersion version) -> RabbitMQ.AMQP.Client.IClassicQueueSpecification!
+RabbitMQ.AMQP.Client.IConnection
+RabbitMQ.AMQP.Client.IConnection.ConsumerBuilder() -> RabbitMQ.AMQP.Client.IConsumerBuilder!
+RabbitMQ.AMQP.Client.IConnection.GetPublishers() -> System.Collections.ObjectModel.ReadOnlyCollection!
+RabbitMQ.AMQP.Client.IConnection.Management() -> RabbitMQ.AMQP.Client.IManagement!
+RabbitMQ.AMQP.Client.IConnection.PublisherBuilder() -> RabbitMQ.AMQP.Client.IPublisherBuilder!
+RabbitMQ.AMQP.Client.IConnectionSettings
+RabbitMQ.AMQP.Client.IConnectionSettings.ConnectionName.get -> string!
+RabbitMQ.AMQP.Client.IConnectionSettings.Host.get -> string!
+RabbitMQ.AMQP.Client.IConnectionSettings.Password.get -> string?
+RabbitMQ.AMQP.Client.IConnectionSettings.Path.get -> string!
+RabbitMQ.AMQP.Client.IConnectionSettings.Port.get -> int
+RabbitMQ.AMQP.Client.IConnectionSettings.SaslMechanism.get -> RabbitMQ.AMQP.Client.SaslMechanism!
+RabbitMQ.AMQP.Client.IConnectionSettings.Scheme.get -> string!
+RabbitMQ.AMQP.Client.IConnectionSettings.TlsSettings.get -> RabbitMQ.AMQP.Client.ITlsSettings?
+RabbitMQ.AMQP.Client.IConnectionSettings.User.get -> string?
+RabbitMQ.AMQP.Client.IConnectionSettings.UseSsl.get -> bool
+RabbitMQ.AMQP.Client.IConnectionSettings.VirtualHost.get -> string!
+RabbitMQ.AMQP.Client.IConsumer
+RabbitMQ.AMQP.Client.IConsumer.Pause() -> void
+RabbitMQ.AMQP.Client.IConsumer.Unpause() -> void
+RabbitMQ.AMQP.Client.IConsumer.UnsettledMessageCount() -> long
+RabbitMQ.AMQP.Client.IConsumerBuilder
+RabbitMQ.AMQP.Client.IConsumerBuilder.Build() -> RabbitMQ.AMQP.Client.IConsumer!
+RabbitMQ.AMQP.Client.IConsumerBuilder.InitialCredits(int initialCredits) -> RabbitMQ.AMQP.Client.IConsumerBuilder!
+RabbitMQ.AMQP.Client.IConsumerBuilder.IStreamOptions
+RabbitMQ.AMQP.Client.IConsumerBuilder.IStreamOptions.Builder() -> RabbitMQ.AMQP.Client.IConsumerBuilder!
+RabbitMQ.AMQP.Client.IConsumerBuilder.IStreamOptions.FilterMatchUnfiltered(bool matchUnfiltered) -> RabbitMQ.AMQP.Client.IConsumerBuilder.IStreamOptions!
+RabbitMQ.AMQP.Client.IConsumerBuilder.IStreamOptions.FilterValues(string![]! values) -> RabbitMQ.AMQP.Client.IConsumerBuilder.IStreamOptions!
+RabbitMQ.AMQP.Client.IConsumerBuilder.IStreamOptions.Offset(long offset) -> RabbitMQ.AMQP.Client.IConsumerBuilder.IStreamOptions!
+RabbitMQ.AMQP.Client.IConsumerBuilder.IStreamOptions.Offset(RabbitMQ.AMQP.Client.StreamOffsetSpecification specification) -> RabbitMQ.AMQP.Client.IConsumerBuilder.IStreamOptions!
+RabbitMQ.AMQP.Client.IConsumerBuilder.IStreamOptions.Offset(string! interval) -> RabbitMQ.AMQP.Client.IConsumerBuilder.IStreamOptions!
+RabbitMQ.AMQP.Client.IConsumerBuilder.MessageHandler(RabbitMQ.AMQP.Client.MessageHandler! handler) -> RabbitMQ.AMQP.Client.IConsumerBuilder!
+RabbitMQ.AMQP.Client.IConsumerBuilder.Queue(string! queue) -> RabbitMQ.AMQP.Client.IConsumerBuilder!
+RabbitMQ.AMQP.Client.IConsumerBuilder.Stream() -> RabbitMQ.AMQP.Client.IConsumerBuilder.IStreamOptions!
+RabbitMQ.AMQP.Client.IContext
+RabbitMQ.AMQP.Client.IContext.Accept() -> void
+RabbitMQ.AMQP.Client.IContext.Discard() -> void
+RabbitMQ.AMQP.Client.IContext.Requeue() -> void
+RabbitMQ.AMQP.Client.IEntityDeclaration
+RabbitMQ.AMQP.Client.IEntityDeclaration.Declare() -> System.Threading.Tasks.Task!
+RabbitMQ.AMQP.Client.IEntityInfo
+RabbitMQ.AMQP.Client.IEntityInfoDeclaration
+RabbitMQ.AMQP.Client.IEntityInfoDeclaration.Declare() -> System.Threading.Tasks.Task!
+RabbitMQ.AMQP.Client.IExchangeDeletion
+RabbitMQ.AMQP.Client.IExchangeDeletion.Delete(string! name) -> System.Threading.Tasks.Task!
+RabbitMQ.AMQP.Client.IExchangeSpecification
+RabbitMQ.AMQP.Client.IExchangeSpecification.Argument(string! key, object! value) -> RabbitMQ.AMQP.Client.IExchangeSpecification!
+RabbitMQ.AMQP.Client.IExchangeSpecification.AutoDelete(bool autoDelete) -> RabbitMQ.AMQP.Client.IExchangeSpecification!
+RabbitMQ.AMQP.Client.IExchangeSpecification.Name(string! name) -> RabbitMQ.AMQP.Client.IExchangeSpecification!
+RabbitMQ.AMQP.Client.IExchangeSpecification.Type(RabbitMQ.AMQP.Client.ExchangeType type) -> RabbitMQ.AMQP.Client.IExchangeSpecification!
+RabbitMQ.AMQP.Client.IExchangeSpecification.Type(string! type) -> RabbitMQ.AMQP.Client.IExchangeSpecification!
+RabbitMQ.AMQP.Client.ILifeCycle
+RabbitMQ.AMQP.Client.ILifeCycle.ChangeState -> RabbitMQ.AMQP.Client.LifeCycleCallBack!
+RabbitMQ.AMQP.Client.ILifeCycle.CloseAsync() -> System.Threading.Tasks.Task!
+RabbitMQ.AMQP.Client.ILifeCycle.State.get -> RabbitMQ.AMQP.Client.State
+RabbitMQ.AMQP.Client.IManagement
+RabbitMQ.AMQP.Client.IManagement.Binding() -> RabbitMQ.AMQP.Client.IBindingSpecification!
+RabbitMQ.AMQP.Client.IManagement.Exchange() -> RabbitMQ.AMQP.Client.IExchangeSpecification!
+RabbitMQ.AMQP.Client.IManagement.Exchange(string! name) -> RabbitMQ.AMQP.Client.IExchangeSpecification!
+RabbitMQ.AMQP.Client.IManagement.ExchangeDeletion() -> RabbitMQ.AMQP.Client.IExchangeDeletion!
+RabbitMQ.AMQP.Client.IManagement.Queue() -> RabbitMQ.AMQP.Client.IQueueSpecification!
+RabbitMQ.AMQP.Client.IManagement.Queue(string! name) -> RabbitMQ.AMQP.Client.IQueueSpecification!
+RabbitMQ.AMQP.Client.IManagement.QueueDeletion() -> RabbitMQ.AMQP.Client.IQueueDeletion!
+RabbitMQ.AMQP.Client.IManagement.TopologyListener() -> RabbitMQ.AMQP.Client.ITopologyListener!
+RabbitMQ.AMQP.Client.IMessage
+RabbitMQ.AMQP.Client.IMessage.Annotation(string! key) -> object!
+RabbitMQ.AMQP.Client.IMessage.Annotation(string! key, object! value) -> RabbitMQ.AMQP.Client.IMessage!
+RabbitMQ.AMQP.Client.IMessage.Body() -> object!
+RabbitMQ.AMQP.Client.IMessage.CorrelationId() -> string!
+RabbitMQ.AMQP.Client.IMessage.CorrelationId(string! id) -> RabbitMQ.AMQP.Client.IMessage!
+RabbitMQ.AMQP.Client.IMessage.MessageId() -> string!
+RabbitMQ.AMQP.Client.IMessage.MessageId(string! id) -> RabbitMQ.AMQP.Client.IMessage!
+RabbitMQ.AMQP.Client.IMessage.ReplyTo() -> string!
+RabbitMQ.AMQP.Client.IMessage.ReplyTo(string! id) -> RabbitMQ.AMQP.Client.IMessage!
+RabbitMQ.AMQP.Client.IMessage.Subject() -> string!
+RabbitMQ.AMQP.Client.IMessage.Subject(string! subject) -> RabbitMQ.AMQP.Client.IMessage!
+RabbitMQ.AMQP.Client.IMessageHandler
+RabbitMQ.AMQP.Client.IMessageHandler.Handle(Amqp.Listener.Context! context, RabbitMQ.AMQP.Client.IMessage! message) -> void
+RabbitMQ.AMQP.Client.Impl.AbstractLifeCycle
+RabbitMQ.AMQP.Client.Impl.AbstractLifeCycle.AbstractLifeCycle() -> void
+RabbitMQ.AMQP.Client.Impl.AbstractLifeCycle.ChangeState -> RabbitMQ.AMQP.Client.LifeCycleCallBack?
+RabbitMQ.AMQP.Client.Impl.AbstractLifeCycle.OnNewStatus(RabbitMQ.AMQP.Client.State newState, RabbitMQ.AMQP.Client.Error? error) -> void
+RabbitMQ.AMQP.Client.Impl.AbstractLifeCycle.State.get -> RabbitMQ.AMQP.Client.State
+RabbitMQ.AMQP.Client.Impl.AbstractLifeCycle.ThrowIfClosed() -> void
+RabbitMQ.AMQP.Client.Impl.AbstractReconnectLifeCycle
+RabbitMQ.AMQP.Client.Impl.AbstractReconnectLifeCycle.AbstractReconnectLifeCycle() -> void
+RabbitMQ.AMQP.Client.Impl.AddressBuilder
+RabbitMQ.AMQP.Client.Impl.AddressBuilder.Address() -> string!
+RabbitMQ.AMQP.Client.Impl.AddressBuilder.AddressBuilder() -> void
+RabbitMQ.AMQP.Client.Impl.AddressBuilder.Exchange(string? exchange) -> RabbitMQ.AMQP.Client.Impl.AddressBuilder!
+RabbitMQ.AMQP.Client.Impl.AddressBuilder.Key(string? key) -> RabbitMQ.AMQP.Client.Impl.AddressBuilder!
+RabbitMQ.AMQP.Client.Impl.AddressBuilder.Queue(string? queue) -> RabbitMQ.AMQP.Client.Impl.AddressBuilder!
+RabbitMQ.AMQP.Client.Impl.AmqpBindingSpecification
+RabbitMQ.AMQP.Client.Impl.AmqpBindingSpecification.AmqpBindingSpecification(RabbitMQ.AMQP.Client.Impl.AmqpManagement! management) -> void
+RabbitMQ.AMQP.Client.Impl.AmqpBindingSpecification.Argument(string! key, object! value) -> RabbitMQ.AMQP.Client.IBindingSpecification!
+RabbitMQ.AMQP.Client.Impl.AmqpBindingSpecification.Arguments(System.Collections.Generic.Dictionary! arguments) -> RabbitMQ.AMQP.Client.IBindingSpecification!
+RabbitMQ.AMQP.Client.Impl.AmqpBindingSpecification.Bind() -> System.Threading.Tasks.Task!
+RabbitMQ.AMQP.Client.Impl.AmqpBindingSpecification.DestinationExchange(string! exchange) -> RabbitMQ.AMQP.Client.IBindingSpecification!
+RabbitMQ.AMQP.Client.Impl.AmqpBindingSpecification.DestinationQueue(string! queue) -> RabbitMQ.AMQP.Client.IBindingSpecification!
+RabbitMQ.AMQP.Client.Impl.AmqpBindingSpecification.Key(string! key) -> RabbitMQ.AMQP.Client.IBindingSpecification!
+RabbitMQ.AMQP.Client.Impl.AmqpBindingSpecification.SourceExchange(string! exchange) -> RabbitMQ.AMQP.Client.IBindingSpecification!
+RabbitMQ.AMQP.Client.Impl.AmqpBindingSpecification.Unbind() -> System.Threading.Tasks.Task!
+RabbitMQ.AMQP.Client.Impl.AmqpClassicSpecification
+RabbitMQ.AMQP.Client.Impl.AmqpClassicSpecification.AmqpClassicSpecification(RabbitMQ.AMQP.Client.Impl.AmqpQueueSpecification! parent) -> void
+RabbitMQ.AMQP.Client.Impl.AmqpClassicSpecification.MaxPriority(int maxPriority) -> RabbitMQ.AMQP.Client.IClassicQueueSpecification!
+RabbitMQ.AMQP.Client.Impl.AmqpClassicSpecification.Mode(RabbitMQ.AMQP.Client.ClassicQueueMode mode) -> RabbitMQ.AMQP.Client.IClassicQueueSpecification!
+RabbitMQ.AMQP.Client.Impl.AmqpClassicSpecification.Queue() -> RabbitMQ.AMQP.Client.IQueueSpecification!
+RabbitMQ.AMQP.Client.Impl.AmqpClassicSpecification.Version(RabbitMQ.AMQP.Client.ClassicQueueVersion version) -> RabbitMQ.AMQP.Client.IClassicQueueSpecification!
+RabbitMQ.AMQP.Client.Impl.AmqpConnection
+RabbitMQ.AMQP.Client.Impl.AmqpConnection.ConsumerBuilder() -> RabbitMQ.AMQP.Client.IConsumerBuilder!
+RabbitMQ.AMQP.Client.Impl.AmqpConnection.GetPublishers() -> System.Collections.ObjectModel.ReadOnlyCollection!
+RabbitMQ.AMQP.Client.Impl.AmqpConnection.Management() -> RabbitMQ.AMQP.Client.IManagement!
+RabbitMQ.AMQP.Client.Impl.AmqpConnection.PublisherBuilder() -> RabbitMQ.AMQP.Client.IPublisherBuilder!
+RabbitMQ.AMQP.Client.Impl.AmqpConsumer
+RabbitMQ.AMQP.Client.Impl.AmqpConsumer.AmqpConsumer(RabbitMQ.AMQP.Client.Impl.AmqpConnection! connection, string! address, RabbitMQ.AMQP.Client.MessageHandler! messageHandler, int initialCredits, Amqp.Types.Map! filters) -> void
+RabbitMQ.AMQP.Client.Impl.AmqpConsumer.Pause() -> void
+RabbitMQ.AMQP.Client.Impl.AmqpConsumer.Unpause() -> void
+RabbitMQ.AMQP.Client.Impl.AmqpConsumer.UnsettledMessageCount() -> long
+RabbitMQ.AMQP.Client.Impl.AmqpConsumerBuilder
+RabbitMQ.AMQP.Client.Impl.AmqpConsumerBuilder.AmqpConsumerBuilder(RabbitMQ.AMQP.Client.Impl.AmqpConnection! connection) -> void
+RabbitMQ.AMQP.Client.Impl.AmqpConsumerBuilder.Build() -> RabbitMQ.AMQP.Client.IConsumer!
+RabbitMQ.AMQP.Client.Impl.AmqpConsumerBuilder.InitialCredits(int initialCredits) -> RabbitMQ.AMQP.Client.IConsumerBuilder!
+RabbitMQ.AMQP.Client.Impl.AmqpConsumerBuilder.MessageHandler(RabbitMQ.AMQP.Client.MessageHandler! handler) -> RabbitMQ.AMQP.Client.IConsumerBuilder!
+RabbitMQ.AMQP.Client.Impl.AmqpConsumerBuilder.Queue(string! queue) -> RabbitMQ.AMQP.Client.IConsumerBuilder!
+RabbitMQ.AMQP.Client.Impl.AmqpConsumerBuilder.Stream() -> RabbitMQ.AMQP.Client.IConsumerBuilder.IStreamOptions!
+RabbitMQ.AMQP.Client.Impl.AmqpExchangeDeletion
+RabbitMQ.AMQP.Client.Impl.AmqpExchangeDeletion.AmqpExchangeDeletion(RabbitMQ.AMQP.Client.Impl.AmqpManagement! management) -> void
+RabbitMQ.AMQP.Client.Impl.AmqpExchangeDeletion.Delete(string! name) -> System.Threading.Tasks.Task!
+RabbitMQ.AMQP.Client.Impl.AmqpExchangeSpecification
+RabbitMQ.AMQP.Client.Impl.AmqpExchangeSpecification.AmqpExchangeSpecification(RabbitMQ.AMQP.Client.Impl.AmqpManagement! management) -> void
+RabbitMQ.AMQP.Client.Impl.AmqpExchangeSpecification.Argument(string! key, object! value) -> RabbitMQ.AMQP.Client.IExchangeSpecification!
+RabbitMQ.AMQP.Client.Impl.AmqpExchangeSpecification.AutoDelete(bool autoDelete) -> RabbitMQ.AMQP.Client.IExchangeSpecification!
+RabbitMQ.AMQP.Client.Impl.AmqpExchangeSpecification.Declare() -> System.Threading.Tasks.Task!
+RabbitMQ.AMQP.Client.Impl.AmqpExchangeSpecification.Name(string! name) -> RabbitMQ.AMQP.Client.IExchangeSpecification!
+RabbitMQ.AMQP.Client.Impl.AmqpExchangeSpecification.Type(RabbitMQ.AMQP.Client.ExchangeType type) -> RabbitMQ.AMQP.Client.IExchangeSpecification!
+RabbitMQ.AMQP.Client.Impl.AmqpExchangeSpecification.Type(string! type) -> RabbitMQ.AMQP.Client.IExchangeSpecification!
+RabbitMQ.AMQP.Client.Impl.AmqpManagement
+RabbitMQ.AMQP.Client.Impl.AmqpManagement.AmqpManagement(RabbitMQ.AMQP.Client.Impl.AmqpManagementParameters! parameters) -> void
+RabbitMQ.AMQP.Client.Impl.AmqpManagement.Binding() -> RabbitMQ.AMQP.Client.IBindingSpecification!
+RabbitMQ.AMQP.Client.Impl.AmqpManagement.Exchange() -> RabbitMQ.AMQP.Client.IExchangeSpecification!
+RabbitMQ.AMQP.Client.Impl.AmqpManagement.Exchange(string! name) -> RabbitMQ.AMQP.Client.IExchangeSpecification!
+RabbitMQ.AMQP.Client.Impl.AmqpManagement.ExchangeDeletion() -> RabbitMQ.AMQP.Client.IExchangeDeletion!
+RabbitMQ.AMQP.Client.Impl.AmqpManagement.HandleResponseMessage(Amqp.Message! msg) -> void
+RabbitMQ.AMQP.Client.Impl.AmqpManagement.Queue() -> RabbitMQ.AMQP.Client.IQueueSpecification!
+RabbitMQ.AMQP.Client.Impl.AmqpManagement.Queue(RabbitMQ.AMQP.Client.Impl.QueueSpec! spec) -> RabbitMQ.AMQP.Client.IQueueSpecification!
+RabbitMQ.AMQP.Client.Impl.AmqpManagement.Queue(string! name) -> RabbitMQ.AMQP.Client.IQueueSpecification!
+RabbitMQ.AMQP.Client.Impl.AmqpManagement.QueueDeletion() -> RabbitMQ.AMQP.Client.IQueueDeletion!
+RabbitMQ.AMQP.Client.Impl.AmqpManagement.TopologyListener() -> RabbitMQ.AMQP.Client.ITopologyListener!
+RabbitMQ.AMQP.Client.Impl.AmqpManagementParameters
+RabbitMQ.AMQP.Client.Impl.AmqpManagementParameters.AmqpManagementParameters(RabbitMQ.AMQP.Client.Impl.AmqpConnection! connection) -> void
+RabbitMQ.AMQP.Client.Impl.AmqpManagementParameters.Connection() -> RabbitMQ.AMQP.Client.Impl.AmqpConnection!
+RabbitMQ.AMQP.Client.Impl.AmqpManagementParameters.TopologyListener() -> RabbitMQ.AMQP.Client.Impl.RecordingTopologyListener!
+RabbitMQ.AMQP.Client.Impl.AmqpManagementParameters.TopologyListener(RabbitMQ.AMQP.Client.Impl.RecordingTopologyListener! topologyListener) -> RabbitMQ.AMQP.Client.Impl.AmqpManagementParameters!
+RabbitMQ.AMQP.Client.Impl.AmqpMessage
+RabbitMQ.AMQP.Client.Impl.AmqpMessage.AmqpMessage() -> void
+RabbitMQ.AMQP.Client.Impl.AmqpMessage.AmqpMessage(Amqp.Message! nativeMessage) -> void
+RabbitMQ.AMQP.Client.Impl.AmqpMessage.AmqpMessage(object! body) -> void
+RabbitMQ.AMQP.Client.Impl.AmqpMessage.Annotation(string! key) -> object!
+RabbitMQ.AMQP.Client.Impl.AmqpMessage.Annotation(string! key, object! value) -> RabbitMQ.AMQP.Client.IMessage!
+RabbitMQ.AMQP.Client.Impl.AmqpMessage.Body() -> object!
+RabbitMQ.AMQP.Client.Impl.AmqpMessage.CorrelationId() -> string!
+RabbitMQ.AMQP.Client.Impl.AmqpMessage.CorrelationId(string! id) -> RabbitMQ.AMQP.Client.IMessage!
+RabbitMQ.AMQP.Client.Impl.AmqpMessage.MessageId() -> string!
+RabbitMQ.AMQP.Client.Impl.AmqpMessage.MessageId(string! id) -> RabbitMQ.AMQP.Client.IMessage!
+RabbitMQ.AMQP.Client.Impl.AmqpMessage.NativeMessage.get -> Amqp.Message!
+RabbitMQ.AMQP.Client.Impl.AmqpMessage.ReplyTo() -> string!
+RabbitMQ.AMQP.Client.Impl.AmqpMessage.ReplyTo(string! id) -> RabbitMQ.AMQP.Client.IMessage!
+RabbitMQ.AMQP.Client.Impl.AmqpMessage.Subject() -> string!
+RabbitMQ.AMQP.Client.Impl.AmqpMessage.Subject(string! subject) -> RabbitMQ.AMQP.Client.IMessage!
+RabbitMQ.AMQP.Client.Impl.AmqpNotOpenException
+RabbitMQ.AMQP.Client.Impl.AmqpNotOpenException.AmqpNotOpenException(string! message) -> void
+RabbitMQ.AMQP.Client.Impl.AmqpPublisher
+RabbitMQ.AMQP.Client.Impl.AmqpPublisher.AmqpPublisher(RabbitMQ.AMQP.Client.Impl.AmqpConnection! connection, string! address, System.TimeSpan timeout, int maxInFlight) -> void
+RabbitMQ.AMQP.Client.Impl.AmqpPublisher.Publish(RabbitMQ.AMQP.Client.IMessage! message, RabbitMQ.AMQP.Client.OutcomeDescriptorCallback! outcomeCallback) -> System.Threading.Tasks.Task!
+RabbitMQ.AMQP.Client.Impl.AmqpPublisherBuilder
+RabbitMQ.AMQP.Client.Impl.AmqpPublisherBuilder.AmqpPublisherBuilder(RabbitMQ.AMQP.Client.Impl.AmqpConnection! connection) -> void
+RabbitMQ.AMQP.Client.Impl.AmqpPublisherBuilder.Build() -> RabbitMQ.AMQP.Client.IPublisher!
+RabbitMQ.AMQP.Client.Impl.AmqpPublisherBuilder.Exchange(string! exchange) -> RabbitMQ.AMQP.Client.IPublisherBuilder!
+RabbitMQ.AMQP.Client.Impl.AmqpPublisherBuilder.Key(string! key) -> RabbitMQ.AMQP.Client.IPublisherBuilder!
+RabbitMQ.AMQP.Client.Impl.AmqpPublisherBuilder.MaxInflightMessages(int maxInFlight) -> RabbitMQ.AMQP.Client.IPublisherBuilder!
+RabbitMQ.AMQP.Client.Impl.AmqpPublisherBuilder.PublishTimeout(System.TimeSpan timeout) -> RabbitMQ.AMQP.Client.IPublisherBuilder!
+RabbitMQ.AMQP.Client.Impl.AmqpPublisherBuilder.Queue(string! queue) -> RabbitMQ.AMQP.Client.IPublisherBuilder!
+RabbitMQ.AMQP.Client.Impl.AmqpQueueDeletion
+RabbitMQ.AMQP.Client.Impl.AmqpQueueDeletion.AmqpQueueDeletion(RabbitMQ.AMQP.Client.Impl.AmqpManagement! management) -> void
+RabbitMQ.AMQP.Client.Impl.AmqpQueueDeletion.Delete(string! name) -> System.Threading.Tasks.Task!
+RabbitMQ.AMQP.Client.Impl.AmqpQueueSpecification
+RabbitMQ.AMQP.Client.Impl.AmqpQueueSpecification.AmqpQueueSpecification(RabbitMQ.AMQP.Client.Impl.AmqpManagement! management) -> void
+RabbitMQ.AMQP.Client.Impl.AmqpQueueSpecification.Arguments() -> System.Collections.Generic.Dictionary