Skip to content

Commit edd0ad2

Browse files
lukebakkenlukebakken
committed
Merge branch 'main' into NRT
2 parents 5e11d18 + 946b4c2 commit edd0ad2

23 files changed

+53
-51
lines changed

‎projects/Benchmarks/ConsumerDispatching/AsyncBasicConsumerFake.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@ public AsyncBasicConsumerFake(ManualResetEventSlim autoResetEvent)
1919
}
2020

2121
public Task HandleBasicDeliver(string consumerTag, ulong deliveryTag, bool redelivered, string exchange, string routingKey,
22-
ReadOnlyBasicProperties properties, ReadOnlyMemory<byte> body)
22+
IReadOnlyBasicProperties properties, ReadOnlyMemory<byte> body)
2323
{
2424
if (Interlocked.Increment(ref _current) == Count)
2525
{
@@ -30,7 +30,7 @@ public Task HandleBasicDeliver(string consumerTag, ulong deliveryTag, bool redel
3030
}
3131

3232
Task IBasicConsumer.HandleBasicDeliverAsync(string consumerTag, ulong deliveryTag, bool redelivered, string exchange, string routingKey,
33-
ReadOnlyBasicProperties properties, ReadOnlyMemory<byte> body)
33+
IReadOnlyBasicProperties properties, ReadOnlyMemory<byte> body)
3434
{
3535
if (Interlocked.Increment(ref _current) == Count)
3636
{

‎projects/RabbitMQ.Client/PublicAPI.Shipped.txt

Lines changed: 13 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,7 @@ override RabbitMQ.Client.AmqpTimestamp.GetHashCode() -> int
6262
override RabbitMQ.Client.AmqpTimestamp.ToString() -> string
6363
override RabbitMQ.Client.Events.AsyncEventingBasicConsumer.HandleBasicCancelOk(string consumerTag) -> System.Threading.Tasks.Task
6464
override RabbitMQ.Client.Events.AsyncEventingBasicConsumer.HandleBasicConsumeOk(string consumerTag) -> System.Threading.Tasks.Task
65-
override RabbitMQ.Client.Events.AsyncEventingBasicConsumer.HandleBasicDeliver(string consumerTag, ulong deliveryTag, bool redelivered, string exchange, string routingKey, RabbitMQ.Client.ReadOnlyBasicProperties properties, System.ReadOnlyMemory<byte> body) -> System.Threading.Tasks.Task
65+
override RabbitMQ.Client.Events.AsyncEventingBasicConsumer.HandleBasicDeliver(string consumerTag, ulong deliveryTag, bool redelivered, string exchange, string routingKey, RabbitMQ.Client.IReadOnlyBasicProperties properties, System.ReadOnlyMemory<byte> body) -> System.Threading.Tasks.Task
6666
override RabbitMQ.Client.Events.AsyncEventingBasicConsumer.HandleChannelShutdown(object channel, RabbitMQ.Client.ShutdownEventArgs reason) -> System.Threading.Tasks.Task
6767
override RabbitMQ.Client.Events.EventingBasicConsumer.HandleBasicCancelOk(string consumerTag) -> void
6868
override RabbitMQ.Client.Events.EventingBasicConsumer.HandleBasicConsumeOk(string consumerTag) -> void
@@ -117,11 +117,12 @@ RabbitMQ.Client.BasicCredentialsProvider.Refresh() -> void
117117
RabbitMQ.Client.BasicCredentialsProvider.UserName.get -> string
118118
RabbitMQ.Client.BasicCredentialsProvider.ValidUntil.get -> System.TimeSpan?
119119
RabbitMQ.Client.BasicGetResult
120-
RabbitMQ.Client.BasicGetResult.BasicGetResult(ulong deliveryTag, bool redelivered, string exchange, string routingKey, uint messageCount, in RabbitMQ.Client.ReadOnlyBasicProperties basicProperties, System.ReadOnlyMemory<byte> body) -> void
120+
RabbitMQ.Client.BasicGetResult.BasicGetResult(ulong deliveryTag, bool redelivered, string exchange, string routingKey, uint messageCount, RabbitMQ.Client.IReadOnlyBasicProperties basicProperties, System.ReadOnlyMemory<byte> body) -> void
121121
RabbitMQ.Client.BasicProperties
122122
RabbitMQ.Client.BasicProperties.AppId.get -> string
123123
RabbitMQ.Client.BasicProperties.AppId.set -> void
124124
RabbitMQ.Client.BasicProperties.BasicProperties() -> void
125+
RabbitMQ.Client.BasicProperties.BasicProperties(RabbitMQ.Client.IReadOnlyBasicProperties input) -> void
125126
RabbitMQ.Client.BasicProperties.ClearAppId() -> void
126127
RabbitMQ.Client.BasicProperties.ClearClusterId() -> void
127128
RabbitMQ.Client.BasicProperties.ClearContentEncoding() -> void
@@ -291,11 +292,11 @@ RabbitMQ.Client.Events.BaseExceptionEventArgs.BaseExceptionEventArgs(System.Coll
291292
RabbitMQ.Client.Events.BasicAckEventArgs
292293
RabbitMQ.Client.Events.BasicAckEventArgs.BasicAckEventArgs(ulong deliveryTag, bool multiple) -> void
293294
RabbitMQ.Client.Events.BasicDeliverEventArgs
294-
RabbitMQ.Client.Events.BasicDeliverEventArgs.BasicDeliverEventArgs(string consumerTag, ulong deliveryTag, bool redelivered, string exchange, string routingKey, in RabbitMQ.Client.ReadOnlyBasicProperties properties, System.ReadOnlyMemory<byte> body) -> void
295+
RabbitMQ.Client.Events.BasicDeliverEventArgs.BasicDeliverEventArgs(string consumerTag, ulong deliveryTag, bool redelivered, string exchange, string routingKey, RabbitMQ.Client.IReadOnlyBasicProperties properties, System.ReadOnlyMemory<byte> body) -> void
295296
RabbitMQ.Client.Events.BasicNackEventArgs
296297
RabbitMQ.Client.Events.BasicNackEventArgs.BasicNackEventArgs(ulong deliveryTag, bool multiple, bool requeue) -> void
297298
RabbitMQ.Client.Events.BasicReturnEventArgs
298-
RabbitMQ.Client.Events.BasicReturnEventArgs.BasicReturnEventArgs(ushort replyCode, string replyText, string exchange, string routingKey, RabbitMQ.Client.ReadOnlyBasicProperties basicProperties, System.ReadOnlyMemory<byte> body) -> void
299+
RabbitMQ.Client.Events.BasicReturnEventArgs.BasicReturnEventArgs(ushort replyCode, string replyText, string exchange, string routingKey, RabbitMQ.Client.IReadOnlyBasicProperties basicProperties, System.ReadOnlyMemory<byte> body) -> void
299300
RabbitMQ.Client.Events.CallbackExceptionEventArgs
300301
RabbitMQ.Client.Events.CallbackExceptionEventArgs.CallbackExceptionEventArgs(System.Collections.Generic.IDictionary<string, object> detail, System.Exception exception) -> void
301302
RabbitMQ.Client.Events.ConnectionBlockedEventArgs
@@ -412,7 +413,7 @@ RabbitMQ.Client.IAsyncBasicConsumer.ConsumerCancelled -> RabbitMQ.Client.Events.
412413
RabbitMQ.Client.IAsyncBasicConsumer.HandleBasicCancel(string consumerTag) -> System.Threading.Tasks.Task
413414
RabbitMQ.Client.IAsyncBasicConsumer.HandleBasicCancelOk(string consumerTag) -> System.Threading.Tasks.Task
414415
RabbitMQ.Client.IAsyncBasicConsumer.HandleBasicConsumeOk(string consumerTag) -> System.Threading.Tasks.Task
415-
RabbitMQ.Client.IAsyncBasicConsumer.HandleBasicDeliver(string consumerTag, ulong deliveryTag, bool redelivered, string exchange, string routingKey, RabbitMQ.Client.ReadOnlyBasicProperties properties, System.ReadOnlyMemory<byte> body) -> System.Threading.Tasks.Task
416+
RabbitMQ.Client.IAsyncBasicConsumer.HandleBasicDeliver(string consumerTag, ulong deliveryTag, bool redelivered, string exchange, string routingKey, RabbitMQ.Client.IReadOnlyBasicProperties properties, System.ReadOnlyMemory<byte> body) -> System.Threading.Tasks.Task
416417
RabbitMQ.Client.IAsyncBasicConsumer.HandleChannelShutdown(object channel, RabbitMQ.Client.ShutdownEventArgs reason) -> System.Threading.Tasks.Task
417418
RabbitMQ.Client.IAuthMechanism
418419
RabbitMQ.Client.IAuthMechanism.handleChallenge(byte[] challenge, RabbitMQ.Client.ConnectionConfig config) -> byte[]
@@ -765,7 +766,7 @@ RabbitMQ.Client.TopologyRecoveryFilter.QueueFilter.get -> System.Func<RabbitMQ.C
765766
RabbitMQ.Client.TopologyRecoveryFilter.QueueFilter.set -> void
766767
RabbitMQ.Client.TopologyRecoveryFilter.TopologyRecoveryFilter() -> void
767768
readonly RabbitMQ.Client.AmqpTimestamp.UnixTime -> long
768-
readonly RabbitMQ.Client.BasicGetResult.BasicProperties -> RabbitMQ.Client.ReadOnlyBasicProperties
769+
readonly RabbitMQ.Client.BasicGetResult.BasicProperties -> RabbitMQ.Client.IReadOnlyBasicProperties
769770
readonly RabbitMQ.Client.BasicGetResult.Body -> System.ReadOnlyMemory<byte>
770771
readonly RabbitMQ.Client.BasicGetResult.DeliveryTag -> ulong
771772
readonly RabbitMQ.Client.BasicGetResult.Exchange -> string
@@ -797,7 +798,7 @@ readonly RabbitMQ.Client.Events.BaseExceptionEventArgs.Detail -> System.Collecti
797798
readonly RabbitMQ.Client.Events.BaseExceptionEventArgs.Exception -> System.Exception
798799
readonly RabbitMQ.Client.Events.BasicAckEventArgs.DeliveryTag -> ulong
799800
readonly RabbitMQ.Client.Events.BasicAckEventArgs.Multiple -> bool
800-
readonly RabbitMQ.Client.Events.BasicDeliverEventArgs.BasicProperties -> RabbitMQ.Client.ReadOnlyBasicProperties
801+
readonly RabbitMQ.Client.Events.BasicDeliverEventArgs.BasicProperties -> RabbitMQ.Client.IReadOnlyBasicProperties
801802
readonly RabbitMQ.Client.Events.BasicDeliverEventArgs.Body -> System.ReadOnlyMemory<byte>
802803
readonly RabbitMQ.Client.Events.BasicDeliverEventArgs.ConsumerTag -> string
803804
readonly RabbitMQ.Client.Events.BasicDeliverEventArgs.DeliveryTag -> ulong
@@ -807,7 +808,7 @@ readonly RabbitMQ.Client.Events.BasicDeliverEventArgs.RoutingKey -> string
807808
readonly RabbitMQ.Client.Events.BasicNackEventArgs.DeliveryTag -> ulong
808809
readonly RabbitMQ.Client.Events.BasicNackEventArgs.Multiple -> bool
809810
readonly RabbitMQ.Client.Events.BasicNackEventArgs.Requeue -> bool
810-
readonly RabbitMQ.Client.Events.BasicReturnEventArgs.BasicProperties -> RabbitMQ.Client.ReadOnlyBasicProperties
811+
readonly RabbitMQ.Client.Events.BasicReturnEventArgs.BasicProperties -> RabbitMQ.Client.IReadOnlyBasicProperties
811812
readonly RabbitMQ.Client.Events.BasicReturnEventArgs.Body -> System.ReadOnlyMemory<byte>
812813
readonly RabbitMQ.Client.Events.BasicReturnEventArgs.Exchange -> string
813814
readonly RabbitMQ.Client.Events.BasicReturnEventArgs.ReplyCode -> ushort
@@ -862,7 +863,7 @@ static readonly RabbitMQ.Client.PublicationAddress.PSEUDO_URI_PARSER -> System.T
862863
virtual RabbitMQ.Client.AsyncDefaultBasicConsumer.HandleBasicCancel(string consumerTag) -> System.Threading.Tasks.Task
863864
virtual RabbitMQ.Client.AsyncDefaultBasicConsumer.HandleBasicCancelOk(string consumerTag) -> System.Threading.Tasks.Task
864865
virtual RabbitMQ.Client.AsyncDefaultBasicConsumer.HandleBasicConsumeOk(string consumerTag) -> System.Threading.Tasks.Task
865-
virtual RabbitMQ.Client.AsyncDefaultBasicConsumer.HandleBasicDeliver(string consumerTag, ulong deliveryTag, bool redelivered, string exchange, string routingKey, RabbitMQ.Client.ReadOnlyBasicProperties properties, System.ReadOnlyMemory<byte> body) -> System.Threading.Tasks.Task
866+
virtual RabbitMQ.Client.AsyncDefaultBasicConsumer.HandleBasicDeliver(string consumerTag, ulong deliveryTag, bool redelivered, string exchange, string routingKey, RabbitMQ.Client.IReadOnlyBasicProperties properties, System.ReadOnlyMemory<byte> body) -> System.Threading.Tasks.Task
866867
virtual RabbitMQ.Client.AsyncDefaultBasicConsumer.HandleChannelShutdown(object channel, RabbitMQ.Client.ShutdownEventArgs reason) -> System.Threading.Tasks.Task
867868
virtual RabbitMQ.Client.AsyncDefaultBasicConsumer.OnCancel(params string[] consumerTags) -> System.Threading.Tasks.Task
868869
virtual RabbitMQ.Client.DefaultBasicConsumer.HandleBasicCancel(string consumerTag) -> void
@@ -881,7 +882,7 @@ virtual RabbitMQ.Client.TcpClientAdapter.ReceiveTimeout.get -> System.TimeSpan
881882
virtual RabbitMQ.Client.TcpClientAdapter.ReceiveTimeout.set -> void
882883
~const RabbitMQ.Client.RabbitMQActivitySource.PublisherSourceName = "RabbitMQ.Client.Publisher" -> string
883884
~const RabbitMQ.Client.RabbitMQActivitySource.SubscriberSourceName = "RabbitMQ.Client.Subscriber" -> string
884-
~override RabbitMQ.Client.Events.EventingBasicConsumer.HandleBasicDeliverAsync(string consumerTag, ulong deliveryTag, bool redelivered, string exchange, string routingKey, RabbitMQ.Client.ReadOnlyBasicProperties properties, System.ReadOnlyMemory<byte> body) -> System.Threading.Tasks.Task
885+
~override RabbitMQ.Client.Events.EventingBasicConsumer.HandleBasicDeliverAsync(string consumerTag, ulong deliveryTag, bool redelivered, string exchange, string routingKey, RabbitMQ.Client.IReadOnlyBasicProperties properties, System.ReadOnlyMemory<byte> body) -> System.Threading.Tasks.Task
885886
~RabbitMQ.Client.AmqpTcpEndpoint.AmqpTcpEndpoint(string hostName, int portOrMinusOne, RabbitMQ.Client.SslOption ssl, uint maxInboundMessageBodySize) -> void
886887
~RabbitMQ.Client.ConnectionFactory.CreateConnectionAsync(RabbitMQ.Client.IEndpointResolver endpointResolver, string clientProvidedName, System.Threading.CancellationToken cancellationToken = default(System.Threading.CancellationToken)) -> System.Threading.Tasks.Task<RabbitMQ.Client.IConnection>
887888
~RabbitMQ.Client.ConnectionFactory.CreateConnectionAsync(string clientProvidedName, System.Threading.CancellationToken cancellationToken = default(System.Threading.CancellationToken)) -> System.Threading.Tasks.Task<RabbitMQ.Client.IConnection>
@@ -890,7 +891,7 @@ virtual RabbitMQ.Client.TcpClientAdapter.ReceiveTimeout.set -> void
890891
~RabbitMQ.Client.ConnectionFactory.CreateConnectionAsync(System.Collections.Generic.IEnumerable<string> hostnames, string clientProvidedName, System.Threading.CancellationToken cancellationToken = default(System.Threading.CancellationToken)) -> System.Threading.Tasks.Task<RabbitMQ.Client.IConnection>
891892
~RabbitMQ.Client.ConnectionFactory.CreateConnectionAsync(System.Collections.Generic.IEnumerable<string> hostnames, System.Threading.CancellationToken cancellationToken = default(System.Threading.CancellationToken)) -> System.Threading.Tasks.Task<RabbitMQ.Client.IConnection>
892893
~RabbitMQ.Client.ConnectionFactory.CreateConnectionAsync(System.Threading.CancellationToken cancellationToken = default(System.Threading.CancellationToken)) -> System.Threading.Tasks.Task<RabbitMQ.Client.IConnection>
893-
~RabbitMQ.Client.IBasicConsumer.HandleBasicDeliverAsync(string consumerTag, ulong deliveryTag, bool redelivered, string exchange, string routingKey, RabbitMQ.Client.ReadOnlyBasicProperties properties, System.ReadOnlyMemory<byte> body) -> System.Threading.Tasks.Task
894+
~RabbitMQ.Client.IBasicConsumer.HandleBasicDeliverAsync(string consumerTag, ulong deliveryTag, bool redelivered, string exchange, string routingKey, RabbitMQ.Client.IReadOnlyBasicProperties properties, System.ReadOnlyMemory<byte> body) -> System.Threading.Tasks.Task
894895
~RabbitMQ.Client.IChannel.BasicCancelAsync(string consumerTag, bool noWait = false, System.Threading.CancellationToken cancellationToken = default(System.Threading.CancellationToken)) -> System.Threading.Tasks.Task
895896
~RabbitMQ.Client.IChannel.BasicConsumeAsync(string queue, bool autoAck, string consumerTag, bool noLocal, bool exclusive, System.Collections.Generic.IDictionary<string, object> arguments, RabbitMQ.Client.IBasicConsumer consumer, System.Threading.CancellationToken cancellationToken = default(System.Threading.CancellationToken)) -> System.Threading.Tasks.Task<string>
896897
~RabbitMQ.Client.IChannel.BasicGetAsync(string queue, bool autoAck, System.Threading.CancellationToken cancellationToken = default(System.Threading.CancellationToken)) -> System.Threading.Tasks.ValueTask<RabbitMQ.Client.BasicGetResult>
@@ -959,5 +960,5 @@ virtual RabbitMQ.Client.TcpClientAdapter.ReceiveTimeout.set -> void
959960
~static RabbitMQ.Client.RabbitMQActivitySource.ContextExtractor.set -> void
960961
~static RabbitMQ.Client.RabbitMQActivitySource.ContextInjector.get -> System.Action<System.Diagnostics.Activity, System.Collections.Generic.IDictionary<string, object>>
961962
~static RabbitMQ.Client.RabbitMQActivitySource.ContextInjector.set -> void
962-
~virtual RabbitMQ.Client.DefaultBasicConsumer.HandleBasicDeliverAsync(string consumerTag, ulong deliveryTag, bool redelivered, string exchange, string routingKey, RabbitMQ.Client.ReadOnlyBasicProperties properties, System.ReadOnlyMemory<byte> body) -> System.Threading.Tasks.Task
963+
~virtual RabbitMQ.Client.DefaultBasicConsumer.HandleBasicDeliverAsync(string consumerTag, ulong deliveryTag, bool redelivered, string exchange, string routingKey, RabbitMQ.Client.IReadOnlyBasicProperties properties, System.ReadOnlyMemory<byte> body) -> System.Threading.Tasks.Task
963964

‎projects/RabbitMQ.Client/PublicAPI.Unshipped.txt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,2 +1,2 @@
11
RabbitMQ.Client.BasicProperties.BasicProperties(RabbitMQ.Client.IReadOnlyBasicProperties! input) -> void
2-
RabbitMQ.Client.IConnection.DispatchConsumersAsyncEnabled.get -> bool
2+
RabbitMQ.Client.IConnection.DispatchConsumersAsyncEnabled.get -> bool

‎projects/RabbitMQ.Client/client/api/AsyncDefaultBasicConsumer.cs

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -112,7 +112,7 @@ public virtual Task HandleBasicDeliver(string consumerTag,
112112
bool redelivered,
113113
string exchange,
114114
string routingKey,
115-
ReadOnlyBasicProperties properties,
115+
IReadOnlyBasicProperties properties,
116116
ReadOnlyMemory<byte> body)
117117
{
118118
// Nothing to do here.
@@ -166,8 +166,9 @@ void IBasicConsumer.HandleBasicConsumeOk(string consumerTag)
166166
throw new InvalidOperationException("Should never be called. Enable 'DispatchConsumersAsync'.");
167167
}
168168

169-
Task IBasicConsumer.HandleBasicDeliverAsync(string consumerTag, ulong deliveryTag, bool redelivered, string exchange, string routingKey,
170-
ReadOnlyBasicProperties properties, ReadOnlyMemory<byte> body)
169+
Task IBasicConsumer.HandleBasicDeliverAsync(string consumerTag, ulong deliveryTag, bool redelivered,
170+
string exchange, string routingKey,
171+
IReadOnlyBasicProperties properties, ReadOnlyMemory<byte> body)
171172
{
172173
throw new InvalidOperationException("Should never be called. Enable 'DispatchConsumersAsync'.");
173174
}

‎projects/RabbitMQ.Client/client/api/BasicGetResult.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -50,7 +50,7 @@ public sealed class BasicGetResult
5050
/// <param name="basicProperties">The Basic-class content header properties for the message.</param>
5151
/// <param name="body">The body</param>
5252
public BasicGetResult(ulong deliveryTag, bool redelivered, string exchange, string routingKey,
53-
uint messageCount, in ReadOnlyBasicProperties basicProperties, ReadOnlyMemory<byte> body)
53+
uint messageCount, IReadOnlyBasicProperties basicProperties, ReadOnlyMemory<byte> body)
5454
{
5555
DeliveryTag = deliveryTag;
5656
Redelivered = redelivered;
@@ -64,7 +64,7 @@ public BasicGetResult(ulong deliveryTag, bool redelivered, string exchange, stri
6464
/// <summary>
6565
/// Retrieves the Basic-class content header properties for this message.
6666
/// </summary>
67-
public readonly ReadOnlyBasicProperties BasicProperties;
67+
public readonly IReadOnlyBasicProperties BasicProperties;
6868

6969
/// <summary>
7070
/// Retrieves the body of this message.

‎projects/RabbitMQ.Client/client/api/DefaultBasicConsumer.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -153,7 +153,7 @@ public virtual Task HandleBasicDeliverAsync(string consumerTag,
153153
bool redelivered,
154154
string exchange,
155155
string routingKey,
156-
ReadOnlyBasicProperties properties,
156+
IReadOnlyBasicProperties properties,
157157
ReadOnlyMemory<byte> body)
158158
{
159159
// Nothing to do here.

‎projects/RabbitMQ.Client/client/api/IAsyncBasicConsumer.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -51,7 +51,7 @@ Task HandleBasicDeliver(string consumerTag,
5151
bool redelivered,
5252
string exchange,
5353
string routingKey,
54-
ReadOnlyBasicProperties properties,
54+
IReadOnlyBasicProperties properties,
5555
ReadOnlyMemory<byte> body);
5656

5757
/// <summary>

‎projects/RabbitMQ.Client/client/api/IBasicConsumer.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -94,7 +94,7 @@ Task HandleBasicDeliverAsync(string consumerTag,
9494
bool redelivered,
9595
string exchange,
9696
string routingKey,
97-
ReadOnlyBasicProperties properties,
97+
IReadOnlyBasicProperties properties,
9898
ReadOnlyMemory<byte> body);
9999

100100
/// <summary>

‎projects/RabbitMQ.Client/client/events/AsyncEventingBasicConsumer.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -77,7 +77,7 @@ await base.HandleBasicConsumeOk(consumerTag)
7777

7878
///<summary>Fires the Received event.</summary>
7979
public override Task HandleBasicDeliver(string consumerTag, ulong deliveryTag, bool redelivered, string exchange, string routingKey,
80-
ReadOnlyBasicProperties properties, ReadOnlyMemory<byte> body)
80+
IReadOnlyBasicProperties properties, ReadOnlyMemory<byte> body)
8181
{
8282
var deliverEventArgs = new BasicDeliverEventArgs(consumerTag, deliveryTag, redelivered, exchange, routingKey, properties, body);
8383
// No need to call base, it's empty.

‎projects/RabbitMQ.Client/client/events/BasicDeliverEventArgs.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,7 @@ public BasicDeliverEventArgs(string consumerTag,
4444
bool redelivered,
4545
string exchange,
4646
string routingKey,
47-
in ReadOnlyBasicProperties properties,
47+
IReadOnlyBasicProperties properties,
4848
ReadOnlyMemory<byte> body) : base()
4949
{
5050
ConsumerTag = consumerTag;
@@ -57,7 +57,7 @@ public BasicDeliverEventArgs(string consumerTag,
5757
}
5858

5959
///<summary>The content header of the message.</summary>
60-
public readonly ReadOnlyBasicProperties BasicProperties;
60+
public readonly IReadOnlyBasicProperties BasicProperties;
6161

6262
///<summary>The message body.</summary>
6363
public readonly ReadOnlyMemory<byte> Body;

0 commit comments

Comments
 (0)