From 4b97b3a2e0c446a912f5be30015abd32a8748f9c Mon Sep 17 00:00:00 2001 From: James Thompson Date: Sun, 28 Jan 2024 10:06:59 +1100 Subject: [PATCH 1/2] Have added net 6 as a TFM and implement conditional packages Revert NetworkOrderDeserializer Have ported some changes from V7 + Reviewed conditional compiles --- .ci/versions.json | 4 +- .../RabbitMQ.Client.OAuth2.csproj | 5 +- .../RabbitMQ.Client/RabbitMQ.Client.csproj | 6 +- .../exceptions/AlreadyClosedException.cs | 2 - .../AuthenticationFailureException.cs | 2 - .../exceptions/BrokerUnreachableException.cs | 2 - .../exceptions/ChannelAllocationException.cs | 2 - .../exceptions/ConnectFailureException.cs | 2 - .../OperationInterruptedException.cs | 2 - .../PacketNotRecognizedException.cs | 2 - .../PossibleAuthenticationFailureException.cs | 2 - .../ProtocolVersionMismatchException.cs | 2 - .../exceptions/ProtocolViolationException.cs | 2 - .../exceptions/RabbitMQClientException.cs | 2 - .../exceptions/UnexpectedMethodException.cs | 2 - .../exceptions/UnsupportedMethodException.cs | 2 - .../UnsupportedMethodFieldException.cs | 2 - .../exceptions/WireFormattingException.cs | 2 - .../logging/RabbitMqClientEventSource.cs | 20 +- .../util/NetworkOrderDeserializer.cs | 16 +- .../util/NetworkOrderSerializer.cs | 16 +- .../APIApproval.Approve.DotNet.verified.txt | 1023 +++++++++++++++++ ...t => APIApproval.Approve.Net.verified.txt} | 2 +- projects/Unit/APIApproval.cs | 3 +- 24 files changed, 1063 insertions(+), 62 deletions(-) create mode 100644 projects/Unit/APIApproval.Approve.DotNet.verified.txt rename projects/Unit/{APIApproval.Approve.verified.txt => APIApproval.Approve.Net.verified.txt} (99%) diff --git a/.ci/versions.json b/.ci/versions.json index 07b90e3746..7184465f2c 100644 --- a/.ci/versions.json +++ b/.ci/versions.json @@ -1,4 +1,4 @@ { - "erlang": "26.0.2", - "rabbitmq": "3.12.4" + "erlang": "26.2.2", + "rabbitmq": "3.12.12" } diff --git a/projects/RabbitMQ.Client.OAuth2/RabbitMQ.Client.OAuth2.csproj b/projects/RabbitMQ.Client.OAuth2/RabbitMQ.Client.OAuth2.csproj index 5159bcdc9d..6ca352b3eb 100644 --- a/projects/RabbitMQ.Client.OAuth2/RabbitMQ.Client.OAuth2.csproj +++ b/projects/RabbitMQ.Client.OAuth2/RabbitMQ.Client.OAuth2.csproj @@ -1,7 +1,7 @@ - net462;netstandard2.0 + net462;netstandard2.0;net6.0 $(NoWarn);CS1591 true RabbitMQ OAuth2 Client Library for .NET @@ -59,6 +59,9 @@ + + + diff --git a/projects/RabbitMQ.Client/RabbitMQ.Client.csproj b/projects/RabbitMQ.Client/RabbitMQ.Client.csproj index eb4266865a..8483888c5d 100755 --- a/projects/RabbitMQ.Client/RabbitMQ.Client.csproj +++ b/projects/RabbitMQ.Client/RabbitMQ.Client.csproj @@ -1,7 +1,7 @@  - net462;netstandard2.0 + net462;netstandard2.0;net6.0 true $(NoWarn);CS1591 true @@ -60,10 +60,10 @@ - - + + diff --git a/projects/RabbitMQ.Client/client/exceptions/AlreadyClosedException.cs b/projects/RabbitMQ.Client/client/exceptions/AlreadyClosedException.cs index e36032b037..43776cb61d 100644 --- a/projects/RabbitMQ.Client/client/exceptions/AlreadyClosedException.cs +++ b/projects/RabbitMQ.Client/client/exceptions/AlreadyClosedException.cs @@ -36,9 +36,7 @@ namespace RabbitMQ.Client.Exceptions /// Thrown when the application tries to make use of a /// session or connection that has already been shut /// down. -#if !NETSTANDARD1_5 [Serializable] -#endif public class AlreadyClosedException : OperationInterruptedException { ///Construct an instance containing the given diff --git a/projects/RabbitMQ.Client/client/exceptions/AuthenticationFailureException.cs b/projects/RabbitMQ.Client/client/exceptions/AuthenticationFailureException.cs index 556d5e6843..7b04d7d42a 100644 --- a/projects/RabbitMQ.Client/client/exceptions/AuthenticationFailureException.cs +++ b/projects/RabbitMQ.Client/client/exceptions/AuthenticationFailureException.cs @@ -35,9 +35,7 @@ namespace RabbitMQ.Client.Exceptions { /// Thrown when the cause is an /// authentication failure. -#if !NETSTANDARD1_5 [Serializable] -#endif public class AuthenticationFailureException : PossibleAuthenticationFailureException { public AuthenticationFailureException(string msg) : base(msg) diff --git a/projects/RabbitMQ.Client/client/exceptions/BrokerUnreachableException.cs b/projects/RabbitMQ.Client/client/exceptions/BrokerUnreachableException.cs index f19149d8cd..ab80e25702 100644 --- a/projects/RabbitMQ.Client/client/exceptions/BrokerUnreachableException.cs +++ b/projects/RabbitMQ.Client/client/exceptions/BrokerUnreachableException.cs @@ -36,9 +36,7 @@ namespace RabbitMQ.Client.Exceptions { ///Thrown when no connection could be opened during a ///ConnectionFactory.CreateConnection attempt. -#if !NETSTANDARD1_5 [Serializable] -#endif public class BrokerUnreachableException : IOException { ///Construct a BrokerUnreachableException. The inner exception is diff --git a/projects/RabbitMQ.Client/client/exceptions/ChannelAllocationException.cs b/projects/RabbitMQ.Client/client/exceptions/ChannelAllocationException.cs index 0cb0368160..c60a7c31e5 100644 --- a/projects/RabbitMQ.Client/client/exceptions/ChannelAllocationException.cs +++ b/projects/RabbitMQ.Client/client/exceptions/ChannelAllocationException.cs @@ -36,9 +36,7 @@ namespace RabbitMQ.Client.Exceptions /// Thrown when a SessionManager cannot allocate a new /// channel number, or the requested channel number is already in /// use. -#if !NETSTANDARD1_5 [Serializable] -#endif public class ChannelAllocationException : ProtocolViolationException { /// diff --git a/projects/RabbitMQ.Client/client/exceptions/ConnectFailureException.cs b/projects/RabbitMQ.Client/client/exceptions/ConnectFailureException.cs index baa840dc46..5d0599617a 100644 --- a/projects/RabbitMQ.Client/client/exceptions/ConnectFailureException.cs +++ b/projects/RabbitMQ.Client/client/exceptions/ConnectFailureException.cs @@ -34,9 +34,7 @@ namespace RabbitMQ.Client.Exceptions { /// Thrown when a connection to the broker fails -#if !NETSTANDARD1_5 [Serializable] -#endif public class ConnectFailureException : ProtocolViolationException { public ConnectFailureException(string msg, Exception inner) diff --git a/projects/RabbitMQ.Client/client/exceptions/OperationInterruptedException.cs b/projects/RabbitMQ.Client/client/exceptions/OperationInterruptedException.cs index 770d9407a0..63c86e370c 100644 --- a/projects/RabbitMQ.Client/client/exceptions/OperationInterruptedException.cs +++ b/projects/RabbitMQ.Client/client/exceptions/OperationInterruptedException.cs @@ -40,9 +40,7 @@ namespace RabbitMQ.Client.Exceptions /// operation, an OperationInterruptedException will be thrown to /// the caller of IModel.QueueDeclare. /// -#if !NETSTANDARD1_5 [Serializable] -#endif public class OperationInterruptedException // TODO: inherit from OperationCanceledException : RabbitMQClientException diff --git a/projects/RabbitMQ.Client/client/exceptions/PacketNotRecognizedException.cs b/projects/RabbitMQ.Client/client/exceptions/PacketNotRecognizedException.cs index a8543c6b53..6bdbc22c69 100644 --- a/projects/RabbitMQ.Client/client/exceptions/PacketNotRecognizedException.cs +++ b/projects/RabbitMQ.Client/client/exceptions/PacketNotRecognizedException.cs @@ -41,9 +41,7 @@ namespace RabbitMQ.Client.Exceptions ///The peer's {'A','M','Q','P',txHi,txLo,major,minor} packet is ///decoded into instances of this class. /// -#if !NETSTANDARD1_5 [Serializable] -#endif public class PacketNotRecognizedException : RabbitMQClientException { ///Fills the new instance's properties with the values passed in. diff --git a/projects/RabbitMQ.Client/client/exceptions/PossibleAuthenticationFailureException.cs b/projects/RabbitMQ.Client/client/exceptions/PossibleAuthenticationFailureException.cs index 13e6030168..e6b2ec481b 100644 --- a/projects/RabbitMQ.Client/client/exceptions/PossibleAuthenticationFailureException.cs +++ b/projects/RabbitMQ.Client/client/exceptions/PossibleAuthenticationFailureException.cs @@ -35,9 +35,7 @@ namespace RabbitMQ.Client.Exceptions { /// Thrown when the likely cause is an /// authentication failure. -#if !NETSTANDARD1_5 [Serializable] -#endif public class PossibleAuthenticationFailureException : RabbitMQClientException { public PossibleAuthenticationFailureException(string msg, Exception inner) : base(msg, inner) diff --git a/projects/RabbitMQ.Client/client/exceptions/ProtocolVersionMismatchException.cs b/projects/RabbitMQ.Client/client/exceptions/ProtocolVersionMismatchException.cs index 2f418fa50e..5da970ef04 100644 --- a/projects/RabbitMQ.Client/client/exceptions/ProtocolVersionMismatchException.cs +++ b/projects/RabbitMQ.Client/client/exceptions/ProtocolVersionMismatchException.cs @@ -36,9 +36,7 @@ namespace RabbitMQ.Client.Exceptions ///Thrown to indicate that the peer does not support the ///wire protocol version we requested immediately after opening ///the TCP socket. -#if !NETSTANDARD1_5 [Serializable] -#endif public class ProtocolVersionMismatchException : ProtocolViolationException { ///Fills the new instance's properties with the values passed in. diff --git a/projects/RabbitMQ.Client/client/exceptions/ProtocolViolationException.cs b/projects/RabbitMQ.Client/client/exceptions/ProtocolViolationException.cs index 5799f31d4a..b5bc9826ec 100644 --- a/projects/RabbitMQ.Client/client/exceptions/ProtocolViolationException.cs +++ b/projects/RabbitMQ.Client/client/exceptions/ProtocolViolationException.cs @@ -33,9 +33,7 @@ namespace RabbitMQ.Client.Exceptions { -#if !NETSTANDARD1_5 [Serializable] -#endif public class ProtocolViolationException : RabbitMQClientException { public ProtocolViolationException(string message) : base(message) diff --git a/projects/RabbitMQ.Client/client/exceptions/RabbitMQClientException.cs b/projects/RabbitMQ.Client/client/exceptions/RabbitMQClientException.cs index 449c475403..99f1a3a7b3 100644 --- a/projects/RabbitMQ.Client/client/exceptions/RabbitMQClientException.cs +++ b/projects/RabbitMQ.Client/client/exceptions/RabbitMQClientException.cs @@ -33,9 +33,7 @@ namespace RabbitMQ.Client.Exceptions { -#if !NETSTANDARD1_5 [Serializable] -#endif public abstract class RabbitMQClientException : Exception { /// Initializes a new instance of the class. diff --git a/projects/RabbitMQ.Client/client/exceptions/UnexpectedMethodException.cs b/projects/RabbitMQ.Client/client/exceptions/UnexpectedMethodException.cs index 76c2fb390c..9189eae48e 100644 --- a/projects/RabbitMQ.Client/client/exceptions/UnexpectedMethodException.cs +++ b/projects/RabbitMQ.Client/client/exceptions/UnexpectedMethodException.cs @@ -36,9 +36,7 @@ namespace RabbitMQ.Client.Exceptions /// /// Thrown when the model receives an RPC reply that it wasn't expecting. /// -#if !NETSTANDARD1_5 [Serializable] -#endif public class UnexpectedMethodException : ProtocolViolationException { public UnexpectedMethodException(IMethod method) diff --git a/projects/RabbitMQ.Client/client/exceptions/UnsupportedMethodException.cs b/projects/RabbitMQ.Client/client/exceptions/UnsupportedMethodException.cs index 2ddfc00299..d675b4c955 100644 --- a/projects/RabbitMQ.Client/client/exceptions/UnsupportedMethodException.cs +++ b/projects/RabbitMQ.Client/client/exceptions/UnsupportedMethodException.cs @@ -36,9 +36,7 @@ namespace RabbitMQ.Client.Exceptions /// /// Thrown when the model receives an RPC request it cannot satisfy. /// -#if !NETSTANDARD1_5 [Serializable] -#endif public class UnsupportedMethodException : NotSupportedException { public UnsupportedMethodException(string methodName) diff --git a/projects/RabbitMQ.Client/client/exceptions/UnsupportedMethodFieldException.cs b/projects/RabbitMQ.Client/client/exceptions/UnsupportedMethodFieldException.cs index bd85308907..70dc68c6e3 100644 --- a/projects/RabbitMQ.Client/client/exceptions/UnsupportedMethodFieldException.cs +++ b/projects/RabbitMQ.Client/client/exceptions/UnsupportedMethodFieldException.cs @@ -37,9 +37,7 @@ namespace RabbitMQ.Client.Exceptions /// because the version of the protocol the model is implementing /// does not contain a definition for the field in /// question. -#if !NETSTANDARD1_5 [Serializable] -#endif public class UnsupportedMethodFieldException : NotSupportedException { public UnsupportedMethodFieldException(string methodName, string fieldName) diff --git a/projects/RabbitMQ.Client/client/exceptions/WireFormattingException.cs b/projects/RabbitMQ.Client/client/exceptions/WireFormattingException.cs index 88c04c6724..f6958d970d 100644 --- a/projects/RabbitMQ.Client/client/exceptions/WireFormattingException.cs +++ b/projects/RabbitMQ.Client/client/exceptions/WireFormattingException.cs @@ -35,9 +35,7 @@ namespace RabbitMQ.Client.Exceptions { /// Thrown when the wire-formatting code cannot encode a /// particular .NET value to AMQP protocol format. -#if !NETSTANDARD1_5 [Serializable] -#endif public class WireFormattingException : ProtocolViolationException { ///Construct a WireFormattingException with no diff --git a/projects/RabbitMQ.Client/client/logging/RabbitMqClientEventSource.cs b/projects/RabbitMQ.Client/client/logging/RabbitMqClientEventSource.cs index 38460b46bd..ad130e7345 100644 --- a/projects/RabbitMQ.Client/client/logging/RabbitMqClientEventSource.cs +++ b/projects/RabbitMQ.Client/client/logging/RabbitMqClientEventSource.cs @@ -38,6 +38,7 @@ namespace RabbitMQ.Client.Logging [EventSource(Name = "rabbitmq-dotnet-client")] public sealed class RabbitMqClientEventSource : EventSource { + public static readonly RabbitMqClientEventSource Log = new RabbitMqClientEventSource(); public class Keywords { public const EventKeywords Log = (EventKeywords)1; @@ -47,8 +48,6 @@ public RabbitMqClientEventSource() : base(EventSourceSettings.EtwSelfDescribingE { } - public static RabbitMqClientEventSource Log = new RabbitMqClientEventSource(); - [Event(1, Message = "INFO", Keywords = Keywords.Log, Level = EventLevel.Informational)] public void Info(string message) { @@ -67,20 +66,25 @@ public void Warn(string message) public void Error(string message, RabbitMqExceptionDetail ex) { if (IsEnabled()) +#if NET6_0_OR_GREATER WriteExceptionEvent(message, ex); +#else + WriteEvent(3, message, ex); +#endif } [NonEvent] - [UnconditionalSuppressMessage("Trimming", "IL2026", Justification = "The properties are preserved with the DynamicallyAccessedMembers attribute.")] - private void WriteExceptionEvent<[DynamicallyAccessedMembers(DynamicallyAccessedMemberTypes.PublicProperties)] T>(string message, T ex) + public void Error(string message, Exception ex) { - WriteEvent(3, message, ex); + Error(message, new RabbitMqExceptionDetail(ex)); } - [NonEvent] - public void Error(string message, Exception ex) +#if NET6_0_OR_GREATER + [UnconditionalSuppressMessage("Trimming", "IL2026", Justification = "The properties are preserved with the DynamicallyAccessedMembers attribute.")] + private void WriteExceptionEvent<[DynamicallyAccessedMembers(DynamicallyAccessedMemberTypes.PublicProperties)] T>(string message, T ex) { - Error(message, new RabbitMqExceptionDetail(ex)); + WriteEvent(3, message, ex); } +#endif } } diff --git a/projects/RabbitMQ.Client/util/NetworkOrderDeserializer.cs b/projects/RabbitMQ.Client/util/NetworkOrderDeserializer.cs index 120d2dbade..a989ca261a 100644 --- a/projects/RabbitMQ.Client/util/NetworkOrderDeserializer.cs +++ b/projects/RabbitMQ.Client/util/NetworkOrderDeserializer.cs @@ -15,7 +15,7 @@ internal static double ReadDouble(ReadOnlySpan span) throw new ArgumentOutOfRangeException(nameof(span), "Insufficient length to decode Double from memory."); } ulong val = ReadUInt64(span); -#elif NETSTANDARD +#else ulong val = BinaryPrimitives.ReadUInt64BigEndian(span); #endif return Unsafe.As(ref val); @@ -31,7 +31,7 @@ internal static short ReadInt16(ReadOnlySpan span) } return (short)ReadUInt16(span); -#elif NETSTANDARD +#else return BinaryPrimitives.ReadInt16BigEndian(span); #endif } @@ -46,7 +46,7 @@ internal static int ReadInt32(ReadOnlySpan span) } return (int)ReadUInt32(span); -#elif NETSTANDARD +#else return BinaryPrimitives.ReadInt32BigEndian(span); #endif } @@ -61,7 +61,7 @@ internal static long ReadInt64(ReadOnlySpan span) } return (long)ReadUInt64(span); -#elif NETSTANDARD +#else return BinaryPrimitives.ReadInt64BigEndian(span); #endif } @@ -76,7 +76,7 @@ internal static float ReadSingle(ReadOnlySpan span) } uint num = ReadUInt32(span); -#elif NETSTANDARD +#else uint num = BinaryPrimitives.ReadUInt32BigEndian(span); #endif return Unsafe.As(ref num); @@ -92,7 +92,7 @@ internal static ushort ReadUInt16(ReadOnlySpan span) } return (ushort)((span[0] << 8) | span[1]); -#elif NETSTANDARD +#else return BinaryPrimitives.ReadUInt16BigEndian(span); #endif } @@ -107,7 +107,7 @@ internal static uint ReadUInt32(ReadOnlySpan span) } return (uint)((span[0] << 24) | (span[1] << 16) | (span[2] << 8) | span[3]); -#elif NETSTANDARD +#else return BinaryPrimitives.ReadUInt32BigEndian(span); #endif } @@ -124,7 +124,7 @@ internal static ulong ReadUInt64(ReadOnlySpan span) uint num1 = (uint)((span[0] << 24) | (span[1] << 16) | (span[2] << 8) | span[3]); uint num2 = (uint)((span[4] << 24) | (span[5] << 16) | (span[6] << 8) | span[7]); return ((ulong)num1 << 32) | num2; -#elif NETSTANDARD +#else return BinaryPrimitives.ReadUInt64BigEndian(span); #endif } diff --git a/projects/RabbitMQ.Client/util/NetworkOrderSerializer.cs b/projects/RabbitMQ.Client/util/NetworkOrderSerializer.cs index 74eb3615d7..f551b90154 100644 --- a/projects/RabbitMQ.Client/util/NetworkOrderSerializer.cs +++ b/projects/RabbitMQ.Client/util/NetworkOrderSerializer.cs @@ -25,7 +25,7 @@ internal static void WriteDouble(Span span, double val) span[5] = (byte)((tempVal >> 16) & 0xFF); span[6] = (byte)((tempVal >> 8) & 0xFF); span[7] = (byte)(tempVal & 0xFF); -#elif NETSTANDARD +#else long tempVal = BitConverter.DoubleToInt64Bits(val); BinaryPrimitives.WriteInt64BigEndian(span, tempVal); #endif @@ -42,7 +42,7 @@ internal static void WriteInt16(Span span, short val) span[0] = (byte)((val >> 8) & 0xFF); span[1] = (byte)(val & 0xFF); -#elif NETSTANDARD +#else BinaryPrimitives.WriteInt16BigEndian(span, val); #endif } @@ -60,7 +60,7 @@ internal static void WriteInt32(Span span, int val) span[1] = (byte)((val >> 16) & 0xFF); span[2] = (byte)((val >> 8) & 0xFF); span[3] = (byte)(val & 0xFF); -#elif NETSTANDARD +#else BinaryPrimitives.WriteInt32BigEndian(span, val); #endif } @@ -82,7 +82,7 @@ internal static void WriteInt64(Span span, long val) span[5] = (byte)((val >> 16) & 0xFF); span[6] = (byte)((val >> 8) & 0xFF); span[7] = (byte)(val & 0xFF); -#elif NETSTANDARD +#else BinaryPrimitives.WriteInt64BigEndian(span, val); #endif } @@ -101,7 +101,7 @@ internal static void WriteSingle(Span span, float val) span[1] = (byte)((tempVal >> 16) & 0xFF); span[2] = (byte)((tempVal >> 8) & 0xFF); span[3] = (byte)(tempVal & 0xFF); -#elif NETSTANDARD +#else int tempVal = Unsafe.As(ref val); BinaryPrimitives.WriteInt32BigEndian(span, tempVal); #endif @@ -118,7 +118,7 @@ internal static void WriteUInt16(Span span, ushort val) span[0] = (byte)((val >> 8) & 0xFF); span[1] = (byte)(val & 0xFF); -#elif NETSTANDARD +#else BinaryPrimitives.WriteUInt16BigEndian(span, val); #endif } @@ -136,7 +136,7 @@ internal static void WriteUInt32(Span span, uint val) span[1] = (byte)((val >> 16) & 0xFF); span[2] = (byte)((val >> 8) & 0xFF); span[3] = (byte)(val & 0xFF); -#elif NETSTANDARD +#else BinaryPrimitives.WriteUInt32BigEndian(span, val); #endif } @@ -159,7 +159,7 @@ internal static void WriteUInt64(Span span, ulong val) span[5] = (byte)((val >> 16) & 0xFF); span[6] = (byte)((val >> 8) & 0xFF); span[7] = (byte)(val & 0xFF); -#elif NETSTANDARD +#else BinaryPrimitives.WriteUInt64BigEndian(span, val); #endif } diff --git a/projects/Unit/APIApproval.Approve.DotNet.verified.txt b/projects/Unit/APIApproval.Approve.DotNet.verified.txt new file mode 100644 index 0000000000..c87d208d9a --- /dev/null +++ b/projects/Unit/APIApproval.Approve.DotNet.verified.txt @@ -0,0 +1,1023 @@ +[assembly: System.Reflection.AssemblyMetadata("RepositoryUrl", "https://github.com/rabbitmq/rabbitmq-dotnet-client.git")] +[assembly: System.Runtime.CompilerServices.InternalsVisibleTo(@"Unit, PublicKey=00240000048000009400000006020000002400005253413100040000010001008d20ec856aeeb8c3153a77faa2d80e6e43b5db93224a20cc7ae384f65f142e89730e2ff0fcc5d578bbe96fa98a7196c77329efdee4579b3814c0789e5a39b51df6edd75b602a33ceabdfcf19a3feb832f31d8254168cd7ba5700dfbca301fbf8db614ba41ba18474de0a5f4c2d51c995bc3636c641c8cbe76f45717bfcb943b5")] +namespace RabbitMQ.Client +{ + public class AmqpTcpEndpoint + { + public const int DefaultAmqpSslPort = 5671; + public const int UseDefaultPort = -1; + public AmqpTcpEndpoint() { } + public AmqpTcpEndpoint(System.Uri uri) { } + public AmqpTcpEndpoint(string hostName, int portOrMinusOne = -1) { } + public AmqpTcpEndpoint(System.Uri uri, RabbitMQ.Client.SslOption ssl) { } + public AmqpTcpEndpoint(string hostName, int portOrMinusOne, RabbitMQ.Client.SslOption ssl) { } + public AmqpTcpEndpoint(string hostName, int portOrMinusOne, RabbitMQ.Client.SslOption ssl, uint maxMessageSize) { } + public System.Net.Sockets.AddressFamily AddressFamily { get; set; } + public string HostName { get; set; } + public uint MaxMessageSize { get; } + public int Port { get; set; } + public RabbitMQ.Client.IProtocol Protocol { get; } + public RabbitMQ.Client.SslOption Ssl { get; set; } + public object Clone() { } + public RabbitMQ.Client.AmqpTcpEndpoint CloneWithHostname(string hostname) { } + public override bool Equals(object obj) { } + public override int GetHashCode() { } + public override string ToString() { } + public static RabbitMQ.Client.AmqpTcpEndpoint Parse(string address) { } + public static RabbitMQ.Client.AmqpTcpEndpoint[] ParseMultiple(string addresses) { } + } + public struct AmqpTimestamp + { + public AmqpTimestamp(long unixTime) { } + public long UnixTime { get; } + public override string ToString() { } + } + public class AsyncDefaultBasicConsumer : RabbitMQ.Client.IAsyncBasicConsumer, RabbitMQ.Client.IBasicConsumer + { + public AsyncDefaultBasicConsumer() { } + public AsyncDefaultBasicConsumer(RabbitMQ.Client.IModel model) { } + public string[] ConsumerTags { get; } + public bool IsRunning { get; set; } + public RabbitMQ.Client.IModel Model { get; set; } + public RabbitMQ.Client.ShutdownEventArgs ShutdownReason { get; set; } + public event RabbitMQ.Client.Events.AsyncEventHandler ConsumerCancelled; + public virtual System.Threading.Tasks.Task HandleBasicCancel(string consumerTag) { } + public virtual System.Threading.Tasks.Task HandleBasicCancelOk(string consumerTag) { } + public virtual System.Threading.Tasks.Task HandleBasicConsumeOk(string consumerTag) { } + public virtual System.Threading.Tasks.Task HandleBasicDeliver(string consumerTag, ulong deliveryTag, bool redelivered, string exchange, string routingKey, RabbitMQ.Client.IBasicProperties properties, System.ReadOnlyMemory body) { } + public virtual System.Threading.Tasks.Task HandleModelShutdown(object model, RabbitMQ.Client.ShutdownEventArgs reason) { } + public virtual System.Threading.Tasks.Task OnCancel(params string[] consumerTags) { } + } + public class BasicCredentialsProvider : RabbitMQ.Client.ICredentialsProvider + { + public BasicCredentialsProvider(string userName, string password) { } + public BasicCredentialsProvider(string name, string userName, string password) { } + public string Name { get; } + public string Password { get; } + public string UserName { get; } + public System.TimeSpan? ValidUntil { get; } + public void Refresh() { } + } + public class BasicGetResult + { + public BasicGetResult(ulong deliveryTag, bool redelivered, string exchange, string routingKey, uint messageCount, RabbitMQ.Client.IBasicProperties basicProperties, System.ReadOnlyMemory body) { } + public RabbitMQ.Client.IBasicProperties BasicProperties { get; } + public System.ReadOnlyMemory Body { get; } + public ulong DeliveryTag { get; } + public string Exchange { get; } + public uint MessageCount { get; } + public bool Redelivered { get; } + public string RoutingKey { get; } + } + public static class BasicPublishBatchExtensions + { + public static void Add(this RabbitMQ.Client.IBasicPublishBatch batch, string exchange, string routingKey, bool mandatory, RabbitMQ.Client.IBasicProperties properties, System.ReadOnlyMemory body) { } + } + public class BinaryTableValue + { + public BinaryTableValue() { } + public BinaryTableValue(byte[] bytes) { } + public byte[] Bytes { get; set; } + } + public sealed class ConnectionFactory : RabbitMQ.Client.ConnectionFactoryBase, RabbitMQ.Client.IAsyncConnectionFactory, RabbitMQ.Client.IConnectionFactory + { + public const ushort DefaultChannelMax = 2047; + public const uint DefaultFrameMax = 0u; + public const uint DefaultMaxMessageSize = 0u; + public const string DefaultPass = "guest"; + public const string DefaultUser = "guest"; + public const string DefaultVHost = "/"; + public static readonly System.Collections.Generic.IList DefaultAuthMechanisms; + public static readonly System.TimeSpan DefaultConnectionTimeout; + public static readonly System.TimeSpan DefaultHeartbeat; + public ConnectionFactory() { } + public System.Security.Authentication.SslProtocols AmqpUriSslProtocols { get; set; } + public System.Collections.Generic.IList AuthMechanisms { get; set; } + public bool AutomaticRecoveryEnabled { get; set; } + public System.Collections.Generic.IDictionary ClientProperties { get; set; } + public string ClientProvidedName { get; set; } + public int ConsumerDispatchConcurrency { get; set; } + public System.TimeSpan ContinuationTimeout { get; set; } + public RabbitMQ.Client.ICredentialsProvider CredentialsProvider { get; set; } + public RabbitMQ.Client.ICredentialsRefresher CredentialsRefresher { get; set; } + public bool DispatchConsumersAsync { get; set; } + public RabbitMQ.Client.AmqpTcpEndpoint Endpoint { get; set; } + public System.Func, RabbitMQ.Client.IEndpointResolver> EndpointResolverFactory { get; set; } + public System.TimeSpan HandshakeContinuationTimeout { get; set; } + public string HostName { get; set; } + public uint MaxMessageSize { get; set; } + public System.Buffers.ArrayPool MemoryPool { get; set; } + public System.TimeSpan NetworkRecoveryInterval { get; set; } + public string Password { get; set; } + public int Port { get; set; } + public ushort RequestedChannelMax { get; set; } + public System.TimeSpan RequestedConnectionTimeout { get; set; } + public uint RequestedFrameMax { get; set; } + public System.TimeSpan RequestedHeartbeat { get; set; } + public System.TimeSpan SocketReadTimeout { get; set; } + public System.TimeSpan SocketWriteTimeout { get; set; } + public RabbitMQ.Client.SslOption Ssl { get; set; } + public bool TopologyRecoveryEnabled { get; set; } + public RabbitMQ.Client.TopologyRecoveryExceptionHandler TopologyRecoveryExceptionHandler { get; set; } + public RabbitMQ.Client.TopologyRecoveryFilter TopologyRecoveryFilter { get; set; } + public System.Uri Uri { get; set; } + [System.Obsolete("Currently a no-op. UseBackgroundThreadsForIO will be removed in version 7")] + public bool UseBackgroundThreadsForIO { get; set; } + public string UserName { get; set; } + public string VirtualHost { get; set; } + public static System.Net.Sockets.AddressFamily DefaultAddressFamily { get; set; } + public static System.Security.Authentication.SslProtocols DefaultAmqpUriSslProtocols { get; set; } + public RabbitMQ.Client.IAuthMechanismFactory AuthMechanismFactory(System.Collections.Generic.IList mechanismNames) { } + public RabbitMQ.Client.IConnection CreateConnection() { } + public RabbitMQ.Client.IConnection CreateConnection(System.Collections.Generic.IList endpoints) { } + public RabbitMQ.Client.IConnection CreateConnection(System.Collections.Generic.IList hostnames) { } + public RabbitMQ.Client.IConnection CreateConnection(string clientProvidedName) { } + public RabbitMQ.Client.IConnection CreateConnection(RabbitMQ.Client.IEndpointResolver endpointResolver, string clientProvidedName) { } + public RabbitMQ.Client.IConnection CreateConnection(System.Collections.Generic.IList endpoints, string clientProvidedName) { } + public RabbitMQ.Client.IConnection CreateConnection(System.Collections.Generic.IList hostnames, string clientProvidedName) { } + } + public class ConnectionFactoryBase + { + public System.Func SocketFactory; + public ConnectionFactoryBase() { } + public static RabbitMQ.Client.ITcpClient DefaultSocketFactory(System.Net.Sockets.AddressFamily addressFamily) { } + } + public static class Constants + { + public const int AccessRefused = 403; + public const int ChannelError = 504; + public const int CommandInvalid = 503; + public const int ConnectionForced = 320; + public const int ContentTooLarge = 311; + public const int FrameBody = 3; + public const int FrameEnd = 206; + public const int FrameError = 501; + public const int FrameHeader = 2; + public const int FrameHeartbeat = 8; + public const int FrameMethod = 1; + public const int FrameMinSize = 4096; + public const int InternalError = 541; + public const int InvalidPath = 402; + public const int NoConsumers = 313; + public const int NoRoute = 312; + public const int NotAllowed = 530; + public const int NotFound = 404; + public const int NotImplemented = 540; + public const int PreconditionFailed = 406; + public const int ReplySuccess = 200; + public const int ResourceError = 506; + public const int ResourceLocked = 405; + public const int SyntaxError = 502; + public const int UnexpectedFrame = 505; + } + public class DefaultBasicConsumer : RabbitMQ.Client.IBasicConsumer + { + public DefaultBasicConsumer() { } + public DefaultBasicConsumer(RabbitMQ.Client.IModel model) { } + public string[] ConsumerTags { get; } + public bool IsRunning { get; set; } + public RabbitMQ.Client.IModel Model { get; set; } + public RabbitMQ.Client.ShutdownEventArgs ShutdownReason { get; set; } + public event System.EventHandler ConsumerCancelled; + public virtual void HandleBasicCancel(string consumerTag) { } + public virtual void HandleBasicCancelOk(string consumerTag) { } + public virtual void HandleBasicConsumeOk(string consumerTag) { } + public virtual void HandleBasicDeliver(string consumerTag, ulong deliveryTag, bool redelivered, string exchange, string routingKey, RabbitMQ.Client.IBasicProperties properties, System.ReadOnlyMemory body) { } + public virtual void HandleModelShutdown(object model, RabbitMQ.Client.ShutdownEventArgs reason) { } + public virtual void OnCancel(params string[] consumerTags) { } + } + public class DefaultEndpointResolver : RabbitMQ.Client.IEndpointResolver + { + public DefaultEndpointResolver(System.Collections.Generic.IEnumerable tcpEndpoints) { } + public System.Collections.Generic.IEnumerable All() { } + } + public static class EndpointResolverExtensions + { + public static T SelectOne(this RabbitMQ.Client.IEndpointResolver resolver, System.Func selector) { } + } + public static class ExchangeType + { + public const string Direct = "direct"; + public const string Fanout = "fanout"; + public const string Headers = "headers"; + public const string Topic = "topic"; + public static System.Collections.Generic.ICollection All() { } + } + public class ExternalMechanism : RabbitMQ.Client.IAuthMechanism + { + public ExternalMechanism() { } + public byte[] handleChallenge(byte[] challenge, RabbitMQ.Client.IConnectionFactory factory) { } + } + public class ExternalMechanismFactory : RabbitMQ.Client.IAuthMechanismFactory + { + public ExternalMechanismFactory() { } + public string Name { get; } + public RabbitMQ.Client.IAuthMechanism GetInstance() { } + } + public static class Headers + { + public const string AlternateExchange = "alternate-exchange"; + public const string XDeadLetterExchange = "x-dead-letter-exchange"; + public const string XDeadLetterRoutingKey = "x-dead-letter-routing-key"; + public const string XExpires = "x-expires"; + public const string XMaxLength = "x-max-length"; + public const string XMaxLengthInBytes = "x-max-length-bytes"; + public const string XMaxPriority = "x-max-priority"; + public const string XMessageTTL = "x-message-ttl"; + public const string XOverflow = "x-overflow"; + public const string XPriority = "x-priority"; + public const string XQueueMode = "x-queue-mode"; + public const string XQueueType = "x-queue-type"; + public const string XQuorumInitialGroupSize = "x-quorum-initial-group-size"; + public const string XSingleActiveConsumer = "x-single-active-consumer"; + } + public interface IAsyncBasicConsumer + { + RabbitMQ.Client.IModel Model { get; } + event RabbitMQ.Client.Events.AsyncEventHandler ConsumerCancelled; + System.Threading.Tasks.Task HandleBasicCancel(string consumerTag); + System.Threading.Tasks.Task HandleBasicCancelOk(string consumerTag); + System.Threading.Tasks.Task HandleBasicConsumeOk(string consumerTag); + System.Threading.Tasks.Task HandleBasicDeliver(string consumerTag, ulong deliveryTag, bool redelivered, string exchange, string routingKey, RabbitMQ.Client.IBasicProperties properties, System.ReadOnlyMemory body); + System.Threading.Tasks.Task HandleModelShutdown(object model, RabbitMQ.Client.ShutdownEventArgs reason); + } + public interface IAsyncConnectionFactory : RabbitMQ.Client.IConnectionFactory + { + bool DispatchConsumersAsync { get; set; } + } + public interface IAuthMechanism + { + byte[] handleChallenge(byte[] challenge, RabbitMQ.Client.IConnectionFactory factory); + } + public interface IAuthMechanismFactory + { + string Name { get; } + RabbitMQ.Client.IAuthMechanism GetInstance(); + } + public interface IAutorecoveringConnection : RabbitMQ.Client.IConnection, RabbitMQ.Client.INetworkConnection, System.IDisposable + { + event System.EventHandler ConnectionRecoveryError; + event System.EventHandler ConsumerTagChangeAfterRecovery; + event System.EventHandler QueueNameChangeAfterRecovery; + event System.EventHandler RecoveringConsumer; + event System.EventHandler RecoverySucceeded; + } + public interface IBasicConsumer + { + RabbitMQ.Client.IModel Model { get; } + event System.EventHandler ConsumerCancelled; + void HandleBasicCancel(string consumerTag); + void HandleBasicCancelOk(string consumerTag); + void HandleBasicConsumeOk(string consumerTag); + void HandleBasicDeliver(string consumerTag, ulong deliveryTag, bool redelivered, string exchange, string routingKey, RabbitMQ.Client.IBasicProperties properties, System.ReadOnlyMemory body); + void HandleModelShutdown(object model, RabbitMQ.Client.ShutdownEventArgs reason); + } + public interface IBasicProperties : RabbitMQ.Client.IContentHeader + { + string AppId { get; set; } + string ClusterId { get; set; } + string ContentEncoding { get; set; } + string ContentType { get; set; } + string CorrelationId { get; set; } + byte DeliveryMode { get; set; } + string Expiration { get; set; } + System.Collections.Generic.IDictionary Headers { get; set; } + string MessageId { get; set; } + bool Persistent { get; set; } + byte Priority { get; set; } + string ReplyTo { get; set; } + RabbitMQ.Client.PublicationAddress ReplyToAddress { get; set; } + RabbitMQ.Client.AmqpTimestamp Timestamp { get; set; } + string Type { get; set; } + string UserId { get; set; } + void ClearAppId(); + void ClearClusterId(); + void ClearContentEncoding(); + void ClearContentType(); + void ClearCorrelationId(); + void ClearDeliveryMode(); + void ClearExpiration(); + void ClearHeaders(); + void ClearMessageId(); + void ClearPriority(); + void ClearReplyTo(); + void ClearTimestamp(); + void ClearType(); + void ClearUserId(); + bool IsAppIdPresent(); + bool IsClusterIdPresent(); + bool IsContentEncodingPresent(); + bool IsContentTypePresent(); + bool IsCorrelationIdPresent(); + bool IsDeliveryModePresent(); + bool IsExpirationPresent(); + bool IsHeadersPresent(); + bool IsMessageIdPresent(); + bool IsPriorityPresent(); + bool IsReplyToPresent(); + bool IsTimestampPresent(); + bool IsTypePresent(); + bool IsUserIdPresent(); + } + public interface IBasicPublishBatch + { + [System.Obsolete("Use Add(string exchange, string routingKey, bool mandatory, IBasicProperties prop" + + "erties, ReadOnlyMemory body) instead. Will be replaced in version 7.0", false)] + void Add(string exchange, string routingKey, bool mandatory, RabbitMQ.Client.IBasicProperties properties, byte[] body); + void Publish(); + } + public interface IConnection : RabbitMQ.Client.INetworkConnection, System.IDisposable + { + ushort ChannelMax { get; } + System.Collections.Generic.IDictionary ClientProperties { get; } + string ClientProvidedName { get; } + RabbitMQ.Client.ShutdownEventArgs CloseReason { get; } + RabbitMQ.Client.AmqpTcpEndpoint Endpoint { get; } + uint FrameMax { get; } + System.TimeSpan Heartbeat { get; } + bool IsOpen { get; } + RabbitMQ.Client.AmqpTcpEndpoint[] KnownHosts { get; } + RabbitMQ.Client.IProtocol Protocol { get; } + System.Collections.Generic.IDictionary ServerProperties { get; } + System.Collections.Generic.IList ShutdownReport { get; } + event System.EventHandler CallbackException; + event System.EventHandler ConnectionBlocked; + event System.EventHandler ConnectionShutdown; + event System.EventHandler ConnectionUnblocked; + void Abort(); + void Abort(System.TimeSpan timeout); + void Abort(ushort reasonCode, string reasonText); + void Abort(ushort reasonCode, string reasonText, System.TimeSpan timeout); + void Close(); + void Close(System.TimeSpan timeout); + void Close(ushort reasonCode, string reasonText); + void Close(ushort reasonCode, string reasonText, System.TimeSpan timeout); + RabbitMQ.Client.IModel CreateModel(); + void HandleConnectionBlocked(string reason); + void HandleConnectionUnblocked(); + void UpdateSecret(string newSecret, string reason); + } + public interface IConnectionFactory + { + System.Collections.Generic.IDictionary ClientProperties { get; set; } + string ClientProvidedName { get; set; } + System.TimeSpan ContinuationTimeout { get; set; } + RabbitMQ.Client.ICredentialsProvider CredentialsProvider { get; set; } + RabbitMQ.Client.ICredentialsRefresher CredentialsRefresher { get; set; } + System.TimeSpan HandshakeContinuationTimeout { get; set; } + string Password { get; set; } + ushort RequestedChannelMax { get; set; } + uint RequestedFrameMax { get; set; } + System.TimeSpan RequestedHeartbeat { get; set; } + System.Uri Uri { get; set; } + bool UseBackgroundThreadsForIO { get; set; } + string UserName { get; set; } + string VirtualHost { get; set; } + RabbitMQ.Client.IAuthMechanismFactory AuthMechanismFactory(System.Collections.Generic.IList mechanismNames); + RabbitMQ.Client.IConnection CreateConnection(); + RabbitMQ.Client.IConnection CreateConnection(System.Collections.Generic.IList endpoints); + RabbitMQ.Client.IConnection CreateConnection(System.Collections.Generic.IList hostnames); + RabbitMQ.Client.IConnection CreateConnection(string clientProvidedName); + RabbitMQ.Client.IConnection CreateConnection(System.Collections.Generic.IList endpoints, string clientProvidedName); + RabbitMQ.Client.IConnection CreateConnection(System.Collections.Generic.IList hostnames, string clientProvidedName); + } + public interface IContentHeader + { + ushort ProtocolClassId { get; } + string ProtocolClassName { get; } + } + public interface ICredentialsProvider + { + string Name { get; } + string Password { get; } + string UserName { get; } + System.TimeSpan? ValidUntil { get; } + void Refresh(); + } + public interface ICredentialsRefresher + { + RabbitMQ.Client.ICredentialsProvider Register(RabbitMQ.Client.ICredentialsProvider provider, RabbitMQ.Client.NotifyCredentialRefreshed callback); + bool Unregister(RabbitMQ.Client.ICredentialsProvider provider); + } + public interface IEndpointResolver + { + System.Collections.Generic.IEnumerable All(); + } + public interface IMethod + { + ushort ProtocolClassId { get; } + ushort ProtocolMethodId { get; } + string ProtocolMethodName { get; } + } + public interface IModel : System.IDisposable + { + int ChannelNumber { get; } + RabbitMQ.Client.ShutdownEventArgs CloseReason { get; } + System.TimeSpan ContinuationTimeout { get; set; } + string CurrentQueue { get; } + RabbitMQ.Client.IBasicConsumer DefaultConsumer { get; set; } + bool IsClosed { get; } + bool IsOpen { get; } + ulong NextPublishSeqNo { get; } + event System.EventHandler BasicAcks; + event System.EventHandler BasicNacks; + event System.EventHandler BasicRecoverOk; + event System.EventHandler BasicReturn; + event System.EventHandler CallbackException; + event System.EventHandler FlowControl; + event System.EventHandler ModelShutdown; + void Abort(); + void Abort(ushort replyCode, string replyText); + void BasicAck(ulong deliveryTag, bool multiple); + void BasicCancel(string consumerTag); + void BasicCancelNoWait(string consumerTag); + string BasicConsume(string queue, bool autoAck, string consumerTag, bool noLocal, bool exclusive, System.Collections.Generic.IDictionary arguments, RabbitMQ.Client.IBasicConsumer consumer); + RabbitMQ.Client.BasicGetResult BasicGet(string queue, bool autoAck); + void BasicNack(ulong deliveryTag, bool multiple, bool requeue); + void BasicPublish(string exchange, string routingKey, bool mandatory, RabbitMQ.Client.IBasicProperties basicProperties, System.ReadOnlyMemory body); + void BasicQos(uint prefetchSize, ushort prefetchCount, bool global); + void BasicRecover(bool requeue); + void BasicRecoverAsync(bool requeue); + void BasicReject(ulong deliveryTag, bool requeue); + void Close(); + void Close(ushort replyCode, string replyText); + void ConfirmSelect(); + uint ConsumerCount(string queue); + RabbitMQ.Client.IBasicProperties CreateBasicProperties(); + RabbitMQ.Client.IBasicPublishBatch CreateBasicPublishBatch(); + void ExchangeBind(string destination, string source, string routingKey, System.Collections.Generic.IDictionary arguments); + void ExchangeBindNoWait(string destination, string source, string routingKey, System.Collections.Generic.IDictionary arguments); + void ExchangeDeclare(string exchange, string type, bool durable, bool autoDelete, System.Collections.Generic.IDictionary arguments); + void ExchangeDeclareNoWait(string exchange, string type, bool durable, bool autoDelete, System.Collections.Generic.IDictionary arguments); + void ExchangeDeclarePassive(string exchange); + void ExchangeDelete(string exchange, bool ifUnused); + void ExchangeDeleteNoWait(string exchange, bool ifUnused); + void ExchangeUnbind(string destination, string source, string routingKey, System.Collections.Generic.IDictionary arguments); + void ExchangeUnbindNoWait(string destination, string source, string routingKey, System.Collections.Generic.IDictionary arguments); + uint MessageCount(string queue); + void QueueBind(string queue, string exchange, string routingKey, System.Collections.Generic.IDictionary arguments); + void QueueBindNoWait(string queue, string exchange, string routingKey, System.Collections.Generic.IDictionary arguments); + RabbitMQ.Client.QueueDeclareOk QueueDeclare(string queue, bool durable, bool exclusive, bool autoDelete, System.Collections.Generic.IDictionary arguments); + void QueueDeclareNoWait(string queue, bool durable, bool exclusive, bool autoDelete, System.Collections.Generic.IDictionary arguments); + RabbitMQ.Client.QueueDeclareOk QueueDeclarePassive(string queue); + uint QueueDelete(string queue, bool ifUnused, bool ifEmpty); + void QueueDeleteNoWait(string queue, bool ifUnused, bool ifEmpty); + uint QueuePurge(string queue); + void QueueUnbind(string queue, string exchange, string routingKey, System.Collections.Generic.IDictionary arguments); + void TxCommit(); + void TxRollback(); + void TxSelect(); + bool WaitForConfirms(); + bool WaitForConfirms(System.TimeSpan timeout); + bool WaitForConfirms(System.TimeSpan timeout, out bool timedOut); + void WaitForConfirmsOrDie(); + void WaitForConfirmsOrDie(System.TimeSpan timeout); + } + public static class IModelExensions + { + public static string BasicConsume(this RabbitMQ.Client.IModel model, string queue, bool autoAck, RabbitMQ.Client.IBasicConsumer consumer) { } + public static string BasicConsume(this RabbitMQ.Client.IModel model, string queue, bool autoAck, string consumerTag, RabbitMQ.Client.IBasicConsumer consumer) { } + public static string BasicConsume(this RabbitMQ.Client.IModel model, string queue, bool autoAck, string consumerTag, System.Collections.Generic.IDictionary arguments, RabbitMQ.Client.IBasicConsumer consumer) { } + public static string BasicConsume(this RabbitMQ.Client.IModel model, RabbitMQ.Client.IBasicConsumer consumer, string queue, bool autoAck = false, string consumerTag = "", bool noLocal = false, bool exclusive = false, System.Collections.Generic.IDictionary arguments = null) { } + public static void BasicPublish(this RabbitMQ.Client.IModel model, RabbitMQ.Client.PublicationAddress addr, RabbitMQ.Client.IBasicProperties basicProperties, System.ReadOnlyMemory body) { } + public static void BasicPublish(this RabbitMQ.Client.IModel model, string exchange, string routingKey, RabbitMQ.Client.IBasicProperties basicProperties, System.ReadOnlyMemory body) { } + public static void BasicPublish(this RabbitMQ.Client.IModel model, string exchange, string routingKey, bool mandatory = false, RabbitMQ.Client.IBasicProperties basicProperties = null, System.ReadOnlyMemory body = default) { } + public static void ExchangeBind(this RabbitMQ.Client.IModel model, string destination, string source, string routingKey, System.Collections.Generic.IDictionary arguments = null) { } + public static void ExchangeBindNoWait(this RabbitMQ.Client.IModel model, string destination, string source, string routingKey, System.Collections.Generic.IDictionary arguments = null) { } + public static void ExchangeDeclare(this RabbitMQ.Client.IModel model, string exchange, string type, bool durable = false, bool autoDelete = false, System.Collections.Generic.IDictionary arguments = null) { } + public static void ExchangeDeclareNoWait(this RabbitMQ.Client.IModel model, string exchange, string type, bool durable = false, bool autoDelete = false, System.Collections.Generic.IDictionary arguments = null) { } + public static void ExchangeDelete(this RabbitMQ.Client.IModel model, string exchange, bool ifUnused = false) { } + public static void ExchangeDeleteNoWait(this RabbitMQ.Client.IModel model, string exchange, bool ifUnused = false) { } + public static void ExchangeUnbind(this RabbitMQ.Client.IModel model, string destination, string source, string routingKey, System.Collections.Generic.IDictionary arguments = null) { } + public static void QueueBind(this RabbitMQ.Client.IModel model, string queue, string exchange, string routingKey, System.Collections.Generic.IDictionary arguments = null) { } + public static RabbitMQ.Client.QueueDeclareOk QueueDeclare(this RabbitMQ.Client.IModel model, string queue = "", bool durable = false, bool exclusive = true, bool autoDelete = true, System.Collections.Generic.IDictionary arguments = null) { } + public static uint QueueDelete(this RabbitMQ.Client.IModel model, string queue, bool ifUnused = false, bool ifEmpty = false) { } + public static void QueueDeleteNoWait(this RabbitMQ.Client.IModel model, string queue, bool ifUnused = false, bool ifEmpty = false) { } + public static void QueueUnbind(this RabbitMQ.Client.IModel model, string queue, string exchange, string routingKey, System.Collections.Generic.IDictionary arguments = null) { } + } + public interface INetworkConnection + { + int LocalPort { get; } + int RemotePort { get; } + } + public interface IProtocol + { + string ApiName { get; } + int DefaultPort { get; } + int MajorVersion { get; } + int MinorVersion { get; } + int Revision { get; } + } + public interface IRecordedBinding + { + System.Collections.Generic.IDictionary Arguments { get; } + string Destination { get; } + string RoutingKey { get; } + string Source { get; } + } + public interface IRecordedConsumer + { + System.Collections.Generic.IDictionary Arguments { get; } + bool AutoAck { get; } + string ConsumerTag { get; } + bool Exclusive { get; } + string Queue { get; } + } + public interface IRecordedExchange + { + System.Collections.Generic.IDictionary Arguments { get; } + bool AutoDelete { get; } + bool Durable { get; } + string Name { get; } + string Type { get; } + } + public interface IRecordedQueue + { + System.Collections.Generic.IDictionary Arguments { get; } + bool AutoDelete { get; } + bool Durable { get; } + bool Exclusive { get; } + bool IsServerNamed { get; } + string Name { get; } + } + public interface IRecoverable + { + event System.EventHandler Recovery; + } + public interface IStreamProperties : RabbitMQ.Client.IContentHeader + { + string ContentEncoding { get; set; } + string ContentType { get; set; } + System.Collections.Generic.IDictionary Headers { get; set; } + byte Priority { get; set; } + RabbitMQ.Client.AmqpTimestamp Timestamp { get; set; } + void ClearContentEncoding(); + void ClearContentType(); + void ClearHeaders(); + void ClearPriority(); + void ClearTimestamp(); + bool IsContentEncodingPresent(); + bool IsContentTypePresent(); + bool IsHeadersPresent(); + bool IsPriorityPresent(); + bool IsTimestampPresent(); + } + public interface ITcpClient : System.IDisposable + { + System.Net.Sockets.Socket Client { get; } + bool Connected { get; } + System.TimeSpan ReceiveTimeout { get; set; } + void Close(); + System.Threading.Tasks.Task ConnectAsync(string host, int port); + System.Net.Sockets.NetworkStream GetStream(); + } + public delegate void NotifyCredentialRefreshed(bool successfully); + public class PlainMechanism : RabbitMQ.Client.IAuthMechanism + { + public PlainMechanism() { } + public byte[] handleChallenge(byte[] challenge, RabbitMQ.Client.IConnectionFactory factory) { } + } + public class PlainMechanismFactory : RabbitMQ.Client.IAuthMechanismFactory + { + public PlainMechanismFactory() { } + public string Name { get; } + public RabbitMQ.Client.IAuthMechanism GetInstance() { } + } + public static class Protocols + { + public static RabbitMQ.Client.IProtocol AMQP_0_9_1 { get; } + public static RabbitMQ.Client.IProtocol DefaultProtocol { get; } + } + public class PublicationAddress + { + public static readonly System.Text.RegularExpressions.Regex PSEUDO_URI_PARSER; + public PublicationAddress(string exchangeType, string exchangeName, string routingKey) { } + public string ExchangeName { get; } + public string ExchangeType { get; } + public string RoutingKey { get; } + public override string ToString() { } + public static RabbitMQ.Client.PublicationAddress Parse(string uriLikeString) { } + public static bool TryParse(string uriLikeString, out RabbitMQ.Client.PublicationAddress result) { } + } + public class QueueDeclareOk + { + public QueueDeclareOk(string queueName, uint messageCount, uint consumerCount) { } + public uint ConsumerCount { get; } + public uint MessageCount { get; } + public string QueueName { get; } + public static string op_Implicit(RabbitMQ.Client.QueueDeclareOk declareOk) { } + } + public class ShutdownEventArgs : System.EventArgs + { + public ShutdownEventArgs(RabbitMQ.Client.ShutdownInitiator initiator, ushort replyCode, string replyText, System.Exception exception) { } + public ShutdownEventArgs(RabbitMQ.Client.ShutdownInitiator initiator, ushort replyCode, string replyText, object cause = null) { } + public ShutdownEventArgs(RabbitMQ.Client.ShutdownInitiator initiator, ushort replyCode, string replyText, ushort classId, ushort methodId, object cause = null) { } + public object Cause { get; } + public ushort ClassId { get; } + public System.Exception Exception { get; } + public RabbitMQ.Client.ShutdownInitiator Initiator { get; } + public ushort MethodId { get; } + public ushort ReplyCode { get; } + public string ReplyText { get; } + public override string ToString() { } + } + public enum ShutdownInitiator + { + Application = 0, + Library = 1, + Peer = 2, + } + public class ShutdownReportEntry + { + public ShutdownReportEntry(string description, System.Exception exception) { } + public string Description { get; set; } + public System.Exception Exception { get; set; } + public override string ToString() { } + } + public class SslOption + { + public SslOption() { } + public SslOption(string serverName, string certificatePath = "", bool enabled = false) { } + public System.Net.Security.SslPolicyErrors AcceptablePolicyErrors { get; set; } + public string CertPassphrase { get; set; } + public string CertPath { get; set; } + public System.Net.Security.LocalCertificateSelectionCallback CertificateSelectionCallback { get; set; } + public System.Net.Security.RemoteCertificateValidationCallback CertificateValidationCallback { get; set; } + public System.Security.Cryptography.X509Certificates.X509CertificateCollection Certs { get; set; } + public bool CheckCertificateRevocation { get; set; } + public bool Enabled { get; set; } + public string ServerName { get; set; } + public System.Security.Authentication.SslProtocols Version { get; set; } + } + public class TcpClientAdapter : RabbitMQ.Client.ITcpClient, System.IDisposable + { + public TcpClientAdapter(System.Net.Sockets.Socket socket) { } + public virtual System.Net.Sockets.Socket Client { get; } + public virtual bool Connected { get; } + public virtual System.TimeSpan ReceiveTimeout { get; set; } + public virtual void Close() { } + public virtual System.Threading.Tasks.Task ConnectAsync(string host, int port) { } + public void Dispose() { } + protected virtual void Dispose(bool disposing) { } + public virtual System.Net.Sockets.NetworkStream GetStream() { } + public static System.Net.IPAddress GetMatchingHost(System.Collections.Generic.IReadOnlyCollection addresses, System.Net.Sockets.AddressFamily addressFamily) { } + } + public class TimerBasedCredentialRefresher : RabbitMQ.Client.ICredentialsRefresher + { + public TimerBasedCredentialRefresher() { } + public RabbitMQ.Client.ICredentialsProvider Register(RabbitMQ.Client.ICredentialsProvider provider, RabbitMQ.Client.NotifyCredentialRefreshed callback) { } + public bool Unregister(RabbitMQ.Client.ICredentialsProvider provider) { } + } + [System.Diagnostics.Tracing.EventSource(Name="TimerBasedCredentialRefresher")] + public class TimerBasedCredentialRefresherEventSource : System.Diagnostics.Tracing.EventSource + { + public TimerBasedCredentialRefresherEventSource() { } + public static RabbitMQ.Client.TimerBasedCredentialRefresherEventSource Log { get; } + [System.Diagnostics.Tracing.Event(6)] + public void AlreadyRegistered(string name) { } + [System.Diagnostics.CodeAnalysis.UnconditionalSuppressMessage("ReflectionAnalysis", "IL2026:RequiresUnreferencedCode", Justification="Parameters to this method are primitive and are trimmer safe")] + [System.Diagnostics.Tracing.Event(5)] + public void RefreshedCredentials(string name, bool succesfully) { } + [System.Diagnostics.Tracing.Event(1)] + public void Registered(string name) { } + [System.Diagnostics.CodeAnalysis.UnconditionalSuppressMessage("ReflectionAnalysis", "IL2026:RequiresUnreferencedCode", Justification="Parameters to this method are primitive and are trimmer safe")] + [System.Diagnostics.Tracing.Event(3)] + public void ScheduledTimer(string name, double interval) { } + [System.Diagnostics.Tracing.Event(4)] + public void TriggeredTimer(string name) { } + [System.Diagnostics.Tracing.Event(2)] + public void Unregistered(string name) { } + } + public class TopologyRecoveryExceptionHandler + { + public TopologyRecoveryExceptionHandler() { } + public System.Func BindingRecoveryExceptionCondition { get; set; } + public System.Action BindingRecoveryExceptionHandler { get; set; } + public System.Func ConsumerRecoveryExceptionCondition { get; set; } + public System.Action ConsumerRecoveryExceptionHandler { get; set; } + public System.Func ExchangeRecoveryExceptionCondition { get; set; } + public System.Action ExchangeRecoveryExceptionHandler { get; set; } + public System.Func QueueRecoveryExceptionCondition { get; set; } + public System.Action QueueRecoveryExceptionHandler { get; set; } + } + public class TopologyRecoveryFilter + { + public TopologyRecoveryFilter() { } + public System.Func BindingFilter { get; set; } + public System.Func ConsumerFilter { get; set; } + public System.Func ExchangeFilter { get; set; } + public System.Func QueueFilter { get; set; } + } +} +namespace RabbitMQ.Client.Events +{ + public delegate System.Threading.Tasks.Task AsyncEventHandler(object sender, TEvent @event); + public class AsyncEventingBasicConsumer : RabbitMQ.Client.AsyncDefaultBasicConsumer + { + public AsyncEventingBasicConsumer(RabbitMQ.Client.IModel model) { } + public event RabbitMQ.Client.Events.AsyncEventHandler Received; + public event RabbitMQ.Client.Events.AsyncEventHandler Registered; + public event RabbitMQ.Client.Events.AsyncEventHandler Shutdown; + public event RabbitMQ.Client.Events.AsyncEventHandler Unregistered; + public override System.Threading.Tasks.Task HandleBasicCancelOk(string consumerTag) { } + public override System.Threading.Tasks.Task HandleBasicConsumeOk(string consumerTag) { } + public override System.Threading.Tasks.Task HandleBasicDeliver(string consumerTag, ulong deliveryTag, bool redelivered, string exchange, string routingKey, RabbitMQ.Client.IBasicProperties properties, System.ReadOnlyMemory body) { } + public override System.Threading.Tasks.Task HandleModelShutdown(object model, RabbitMQ.Client.ShutdownEventArgs reason) { } + } + public abstract class BaseExceptionEventArgs : System.EventArgs + { + public BaseExceptionEventArgs(System.Exception exception) { } + public System.Collections.Generic.IDictionary Detail { get; } + public System.Exception Exception { get; } + public System.Collections.Generic.IDictionary UpdateDetails(System.Collections.Generic.IDictionary other) { } + } + public class BasicAckEventArgs : System.EventArgs + { + public BasicAckEventArgs() { } + public ulong DeliveryTag { get; set; } + public bool Multiple { get; set; } + } + public class BasicDeliverEventArgs : System.EventArgs + { + public BasicDeliverEventArgs() { } + public BasicDeliverEventArgs(string consumerTag, ulong deliveryTag, bool redelivered, string exchange, string routingKey, RabbitMQ.Client.IBasicProperties properties, System.ReadOnlyMemory body) { } + public RabbitMQ.Client.IBasicProperties BasicProperties { get; set; } + public System.ReadOnlyMemory Body { get; set; } + public string ConsumerTag { get; set; } + public ulong DeliveryTag { get; set; } + public string Exchange { get; set; } + public bool Redelivered { get; set; } + public string RoutingKey { get; set; } + } + public class BasicNackEventArgs : System.EventArgs + { + public BasicNackEventArgs() { } + public ulong DeliveryTag { get; set; } + public bool Multiple { get; set; } + public bool Requeue { get; set; } + } + public class BasicReturnEventArgs : System.EventArgs + { + public BasicReturnEventArgs() { } + public RabbitMQ.Client.IBasicProperties BasicProperties { get; set; } + public System.ReadOnlyMemory Body { get; set; } + public string Exchange { get; set; } + public ushort ReplyCode { get; set; } + public string ReplyText { get; set; } + public string RoutingKey { get; set; } + } + public class CallbackExceptionEventArgs : RabbitMQ.Client.Events.BaseExceptionEventArgs + { + public CallbackExceptionEventArgs(System.Exception e) { } + public static RabbitMQ.Client.Events.CallbackExceptionEventArgs Build(System.Exception e, System.Collections.Generic.IDictionary details) { } + public static RabbitMQ.Client.Events.CallbackExceptionEventArgs Build(System.Exception e, string context) { } + } + public class ConnectionBlockedEventArgs : System.EventArgs + { + public ConnectionBlockedEventArgs(string reason) { } + public string Reason { get; } + } + public sealed class ConnectionRecoveryErrorEventArgs : System.EventArgs + { + public ConnectionRecoveryErrorEventArgs(System.Exception ex) { } + public System.Exception Exception { get; } + } + public class ConsumerEventArgs : System.EventArgs + { + public ConsumerEventArgs(string[] consumerTags) { } + public string[] ConsumerTags { get; } + } + public sealed class ConsumerTagChangedAfterRecoveryEventArgs : System.EventArgs + { + public ConsumerTagChangedAfterRecoveryEventArgs(string tagBefore, string tagAfter) { } + public string TagAfter { get; } + public string TagBefore { get; } + } + public class EventingBasicConsumer : RabbitMQ.Client.DefaultBasicConsumer + { + public EventingBasicConsumer(RabbitMQ.Client.IModel model) { } + public event System.EventHandler Received; + public event System.EventHandler Registered; + public event System.EventHandler Shutdown; + public event System.EventHandler Unregistered; + public override void HandleBasicCancelOk(string consumerTag) { } + public override void HandleBasicConsumeOk(string consumerTag) { } + public override void HandleBasicDeliver(string consumerTag, ulong deliveryTag, bool redelivered, string exchange, string routingKey, RabbitMQ.Client.IBasicProperties properties, System.ReadOnlyMemory body) { } + public override void HandleModelShutdown(object model, RabbitMQ.Client.ShutdownEventArgs reason) { } + } + public class FlowControlEventArgs : System.EventArgs + { + public FlowControlEventArgs(bool active) { } + public bool Active { get; } + } + public sealed class QueueNameChangedAfterRecoveryEventArgs : System.EventArgs + { + public QueueNameChangedAfterRecoveryEventArgs(string nameBefore, string nameAfter) { } + public string NameAfter { get; } + public string NameBefore { get; } + } + public class RecoveringConsumerEventArgs : System.EventArgs + { + public RecoveringConsumerEventArgs(System.Collections.Generic.IDictionary consumerArguments, string consumerTag) { } + public System.Collections.Generic.IDictionary ConsumerArguments { get; } + public string ConsumerTag { get; } + } + public class RecoveryExceptionEventArgs : RabbitMQ.Client.Events.BaseExceptionEventArgs + { + public RecoveryExceptionEventArgs(System.Exception e) { } + } +} +namespace RabbitMQ.Client.Exceptions +{ + [System.Serializable] + public class AlreadyClosedException : RabbitMQ.Client.Exceptions.OperationInterruptedException + { + public AlreadyClosedException(RabbitMQ.Client.ShutdownEventArgs reason) { } + } + [System.Serializable] + public class AuthenticationFailureException : RabbitMQ.Client.Exceptions.PossibleAuthenticationFailureException + { + public AuthenticationFailureException(string msg) { } + } + [System.Serializable] + public class BrokerUnreachableException : System.IO.IOException + { + public BrokerUnreachableException(System.Exception Inner) { } + } + [System.Serializable] + public class ChannelAllocationException : RabbitMQ.Client.Exceptions.ProtocolViolationException + { + public ChannelAllocationException() { } + public ChannelAllocationException(int channel) { } + public int Channel { get; } + } + public class ChannelErrorException : RabbitMQ.Client.Exceptions.HardProtocolException + { + public ChannelErrorException(int channel) { } + public int Channel { get; } + public override ushort ReplyCode { get; } + } + [System.Serializable] + public class ConnectFailureException : RabbitMQ.Client.Exceptions.ProtocolViolationException + { + public ConnectFailureException(string msg, System.Exception inner) { } + } + public abstract class HardProtocolException : RabbitMQ.Client.Exceptions.ProtocolException + { + protected readonly bool _canShutdownCleanly; + protected HardProtocolException(string message) { } + protected HardProtocolException(string message, bool canShutdownCleanly) { } + public bool CanShutdownCleanly { get; } + } + public class MalformedFrameException : RabbitMQ.Client.Exceptions.HardProtocolException + { + public MalformedFrameException(string message) { } + public MalformedFrameException(string message, bool canShutdownCleanly) { } + public override ushort ReplyCode { get; } + } + [System.Serializable] + public class OperationInterruptedException : RabbitMQ.Client.Exceptions.RabbitMQClientException + { + protected OperationInterruptedException() { } + public OperationInterruptedException(RabbitMQ.Client.ShutdownEventArgs reason) { } + protected OperationInterruptedException(string message) { } + public OperationInterruptedException(RabbitMQ.Client.ShutdownEventArgs reason, string prefix) { } + protected OperationInterruptedException(string message, System.Exception inner) { } + public RabbitMQ.Client.ShutdownEventArgs ShutdownReason { get; set; } + } + [System.Serializable] + public class PacketNotRecognizedException : RabbitMQ.Client.Exceptions.RabbitMQClientException + { + public PacketNotRecognizedException(int transportHigh, int transportLow, int serverMajor, int serverMinor) { } + public int ServerMajor { get; } + public int ServerMinor { get; } + public int TransportHigh { get; } + public int TransportLow { get; } + } + [System.Serializable] + public class PossibleAuthenticationFailureException : RabbitMQ.Client.Exceptions.RabbitMQClientException + { + public PossibleAuthenticationFailureException(string msg) { } + public PossibleAuthenticationFailureException(string msg, System.Exception inner) { } + } + public abstract class ProtocolException : RabbitMQ.Client.Exceptions.RabbitMQClientException + { + protected ProtocolException(string message) { } + public abstract ushort ReplyCode { get; } + public virtual RabbitMQ.Client.ShutdownEventArgs ShutdownReason { get; } + } + [System.Serializable] + public class ProtocolVersionMismatchException : RabbitMQ.Client.Exceptions.ProtocolViolationException + { + public ProtocolVersionMismatchException(int clientMajor, int clientMinor, int serverMajor, int serverMinor) { } + public int ClientMajor { get; } + public int ClientMinor { get; } + public int ServerMajor { get; } + public int ServerMinor { get; } + } + [System.Serializable] + public class ProtocolViolationException : RabbitMQ.Client.Exceptions.RabbitMQClientException + { + public ProtocolViolationException() { } + public ProtocolViolationException(string message) { } + public ProtocolViolationException(string message, System.Exception inner) { } + } + [System.Serializable] + public abstract class RabbitMQClientException : System.Exception + { + protected RabbitMQClientException() { } + protected RabbitMQClientException(string message) { } + protected RabbitMQClientException(string message, System.Exception innerException) { } + } + public abstract class SoftProtocolException : RabbitMQ.Client.Exceptions.ProtocolException + { + protected SoftProtocolException(int channelNumber, string message) { } + public int Channel { get; } + } + public class SyntaxErrorException : RabbitMQ.Client.Exceptions.HardProtocolException + { + public SyntaxErrorException(string message) { } + public override ushort ReplyCode { get; } + } + public class TopologyRecoveryException : RabbitMQ.Client.Exceptions.RabbitMQClientException + { + public TopologyRecoveryException(string message, System.Exception cause) { } + } + public class UnexpectedFrameException : RabbitMQ.Client.Exceptions.HardProtocolException + { + public override ushort ReplyCode { get; } + } + [System.Serializable] + public class UnexpectedMethodException : RabbitMQ.Client.Exceptions.ProtocolViolationException + { + public UnexpectedMethodException(RabbitMQ.Client.IMethod method) { } + public RabbitMQ.Client.IMethod Method { get; } + } + public class UnknownClassOrMethodException : RabbitMQ.Client.Exceptions.HardProtocolException + { + public UnknownClassOrMethodException(ushort classId, ushort methodId) { } + public ushort ClassId { get; } + public ushort MethodId { get; } + public override ushort ReplyCode { get; } + public override string ToString() { } + } + [System.Serializable] + public class UnsupportedMethodException : System.NotSupportedException + { + public UnsupportedMethodException(string methodName) { } + public string MethodName { get; } + } + [System.Serializable] + public class UnsupportedMethodFieldException : System.NotSupportedException + { + public UnsupportedMethodFieldException(string methodName, string fieldName) { } + public string FieldName { get; } + public string MethodName { get; } + } + [System.Serializable] + public class WireFormattingException : RabbitMQ.Client.Exceptions.ProtocolViolationException + { + public WireFormattingException(string message) { } + public WireFormattingException(string message, object offender) { } + public object Offender { get; } + } +} +namespace RabbitMQ.Client.Logging +{ + [System.Diagnostics.Tracing.EventSource(Name="rabbitmq-dotnet-client")] + public sealed class RabbitMqClientEventSource : System.Diagnostics.Tracing.EventSource + { + public static readonly RabbitMQ.Client.Logging.RabbitMqClientEventSource Log; + public RabbitMqClientEventSource() { } + [System.Diagnostics.Tracing.Event(3, Keywords=System.Diagnostics.Tracing.EventKeywords.None, Level=System.Diagnostics.Tracing.EventLevel.Error, Message="ERROR")] + public void Error(string message, RabbitMQ.Client.Logging.RabbitMqExceptionDetail ex) { } + [System.Diagnostics.Tracing.NonEvent] + public void Error(string message, System.Exception ex) { } + [System.Diagnostics.Tracing.Event(1, Keywords=System.Diagnostics.Tracing.EventKeywords.None, Level=System.Diagnostics.Tracing.EventLevel.Informational, Message="INFO")] + public void Info(string message) { } + [System.Diagnostics.Tracing.Event(2, Keywords=System.Diagnostics.Tracing.EventKeywords.None, Level=System.Diagnostics.Tracing.EventLevel.Warning, Message="WARN")] + public void Warn(string message) { } + public class Keywords + { + public const System.Diagnostics.Tracing.EventKeywords Log = 1; + public Keywords() { } + } + } + public sealed class RabbitMqConsoleEventListener : System.Diagnostics.Tracing.EventListener, System.IDisposable + { + public RabbitMqConsoleEventListener() { } + public override void Dispose() { } + protected override void OnEventWritten(System.Diagnostics.Tracing.EventWrittenEventArgs eventData) { } + } + [System.Diagnostics.Tracing.EventData] + public class RabbitMqExceptionDetail + { + public RabbitMqExceptionDetail(System.Collections.Generic.IDictionary ex) { } + public RabbitMqExceptionDetail(System.Exception ex) { } + public string InnerException { get; } + public string Message { get; } + public string StackTrace { get; } + public string Type { get; } + public override string ToString() { } + } +} \ No newline at end of file diff --git a/projects/Unit/APIApproval.Approve.verified.txt b/projects/Unit/APIApproval.Approve.Net.verified.txt similarity index 99% rename from projects/Unit/APIApproval.Approve.verified.txt rename to projects/Unit/APIApproval.Approve.Net.verified.txt index 061b0a6d19..3114aa4f82 100644 --- a/projects/Unit/APIApproval.Approve.verified.txt +++ b/projects/Unit/APIApproval.Approve.Net.verified.txt @@ -985,7 +985,7 @@ namespace RabbitMQ.Client.Logging [System.Diagnostics.Tracing.EventSource(Name="rabbitmq-dotnet-client")] public sealed class RabbitMqClientEventSource : System.Diagnostics.Tracing.EventSource { - public static RabbitMQ.Client.Logging.RabbitMqClientEventSource Log; + public static readonly RabbitMQ.Client.Logging.RabbitMqClientEventSource Log; public RabbitMqClientEventSource() { } [System.Diagnostics.Tracing.Event(3, Keywords=System.Diagnostics.Tracing.EventKeywords.None, Level=System.Diagnostics.Tracing.EventLevel.Error, Message="ERROR")] public void Error(string message, RabbitMQ.Client.Logging.RabbitMqExceptionDetail ex) { } diff --git a/projects/Unit/APIApproval.cs b/projects/Unit/APIApproval.cs index c758edb26d..eb36b7b6f9 100644 --- a/projects/Unit/APIApproval.cs +++ b/projects/Unit/APIApproval.cs @@ -38,7 +38,7 @@ namespace RabbitMQ.Client.Unit { [TestFixture] - [Platform(Exclude="Mono,Linux")] + [Platform(Exclude = "Mono,Linux")] public class APIApproval { [Test] @@ -48,6 +48,7 @@ public Task Approve() var settings = new VerifySettings(); settings.DisableDiff(); + settings.UniqueForTargetFramework(); return Verifier.Verify(publicApi, settings); } From 581b100585ed76ec79f0727b08addfd14b1eef50 Mon Sep 17 00:00:00 2001 From: Luke Bakken Date: Fri, 15 Mar 2024 14:00:03 -0700 Subject: [PATCH 2/2] Bump Erlang and RabbitMQ versions for CI --- .ci/versions.json | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/.ci/versions.json b/.ci/versions.json index 7184465f2c..11c0c71d14 100644 --- a/.ci/versions.json +++ b/.ci/versions.json @@ -1,4 +1,4 @@ { - "erlang": "26.2.2", - "rabbitmq": "3.12.12" + "erlang": "26.2.3", + "rabbitmq": "3.13.0" }