Skip to content

Commit 946b4c2

Browse files
authored
Merge pull request #1631 from Tornhoof/IReadOnlyBasicProperties
Replace ReadOnlyBasicProperties with IReadOnlyBasicProperties
2 parents e247e8b + b3f0bc7 commit 946b4c2

24 files changed

+55
-54
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 & 13 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,12 +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.ReadOnlyBasicProperties input) -> void
125+
RabbitMQ.Client.BasicProperties.BasicProperties(RabbitMQ.Client.IReadOnlyBasicProperties input) -> void
126126
RabbitMQ.Client.BasicProperties.ClearAppId() -> void
127127
RabbitMQ.Client.BasicProperties.ClearClusterId() -> void
128128
RabbitMQ.Client.BasicProperties.ClearContentEncoding() -> void
@@ -292,11 +292,11 @@ RabbitMQ.Client.Events.BaseExceptionEventArgs.BaseExceptionEventArgs(System.Coll
292292
RabbitMQ.Client.Events.BasicAckEventArgs
293293
RabbitMQ.Client.Events.BasicAckEventArgs.BasicAckEventArgs(ulong deliveryTag, bool multiple) -> void
294294
RabbitMQ.Client.Events.BasicDeliverEventArgs
295-
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
296296
RabbitMQ.Client.Events.BasicNackEventArgs
297297
RabbitMQ.Client.Events.BasicNackEventArgs.BasicNackEventArgs(ulong deliveryTag, bool multiple, bool requeue) -> void
298298
RabbitMQ.Client.Events.BasicReturnEventArgs
299-
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
300300
RabbitMQ.Client.Events.CallbackExceptionEventArgs
301301
RabbitMQ.Client.Events.CallbackExceptionEventArgs.CallbackExceptionEventArgs(System.Collections.Generic.IDictionary<string, object> detail, System.Exception exception) -> void
302302
RabbitMQ.Client.Events.ConnectionBlockedEventArgs
@@ -413,7 +413,7 @@ RabbitMQ.Client.IAsyncBasicConsumer.ConsumerCancelled -> RabbitMQ.Client.Events.
413413
RabbitMQ.Client.IAsyncBasicConsumer.HandleBasicCancel(string consumerTag) -> System.Threading.Tasks.Task
414414
RabbitMQ.Client.IAsyncBasicConsumer.HandleBasicCancelOk(string consumerTag) -> System.Threading.Tasks.Task
415415
RabbitMQ.Client.IAsyncBasicConsumer.HandleBasicConsumeOk(string consumerTag) -> System.Threading.Tasks.Task
416-
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
417417
RabbitMQ.Client.IAsyncBasicConsumer.HandleChannelShutdown(object channel, RabbitMQ.Client.ShutdownEventArgs reason) -> System.Threading.Tasks.Task
418418
RabbitMQ.Client.IAuthMechanism
419419
RabbitMQ.Client.IAuthMechanism.handleChallenge(byte[] challenge, RabbitMQ.Client.ConnectionConfig config) -> byte[]
@@ -766,7 +766,7 @@ RabbitMQ.Client.TopologyRecoveryFilter.QueueFilter.get -> System.Func<RabbitMQ.C
766766
RabbitMQ.Client.TopologyRecoveryFilter.QueueFilter.set -> void
767767
RabbitMQ.Client.TopologyRecoveryFilter.TopologyRecoveryFilter() -> void
768768
readonly RabbitMQ.Client.AmqpTimestamp.UnixTime -> long
769-
readonly RabbitMQ.Client.BasicGetResult.BasicProperties -> RabbitMQ.Client.ReadOnlyBasicProperties
769+
readonly RabbitMQ.Client.BasicGetResult.BasicProperties -> RabbitMQ.Client.IReadOnlyBasicProperties
770770
readonly RabbitMQ.Client.BasicGetResult.Body -> System.ReadOnlyMemory<byte>
771771
readonly RabbitMQ.Client.BasicGetResult.DeliveryTag -> ulong
772772
readonly RabbitMQ.Client.BasicGetResult.Exchange -> string
@@ -798,7 +798,7 @@ readonly RabbitMQ.Client.Events.BaseExceptionEventArgs.Detail -> System.Collecti
798798
readonly RabbitMQ.Client.Events.BaseExceptionEventArgs.Exception -> System.Exception
799799
readonly RabbitMQ.Client.Events.BasicAckEventArgs.DeliveryTag -> ulong
800800
readonly RabbitMQ.Client.Events.BasicAckEventArgs.Multiple -> bool
801-
readonly RabbitMQ.Client.Events.BasicDeliverEventArgs.BasicProperties -> RabbitMQ.Client.ReadOnlyBasicProperties
801+
readonly RabbitMQ.Client.Events.BasicDeliverEventArgs.BasicProperties -> RabbitMQ.Client.IReadOnlyBasicProperties
802802
readonly RabbitMQ.Client.Events.BasicDeliverEventArgs.Body -> System.ReadOnlyMemory<byte>
803803
readonly RabbitMQ.Client.Events.BasicDeliverEventArgs.ConsumerTag -> string
804804
readonly RabbitMQ.Client.Events.BasicDeliverEventArgs.DeliveryTag -> ulong
@@ -808,7 +808,7 @@ readonly RabbitMQ.Client.Events.BasicDeliverEventArgs.RoutingKey -> string
808808
readonly RabbitMQ.Client.Events.BasicNackEventArgs.DeliveryTag -> ulong
809809
readonly RabbitMQ.Client.Events.BasicNackEventArgs.Multiple -> bool
810810
readonly RabbitMQ.Client.Events.BasicNackEventArgs.Requeue -> bool
811-
readonly RabbitMQ.Client.Events.BasicReturnEventArgs.BasicProperties -> RabbitMQ.Client.ReadOnlyBasicProperties
811+
readonly RabbitMQ.Client.Events.BasicReturnEventArgs.BasicProperties -> RabbitMQ.Client.IReadOnlyBasicProperties
812812
readonly RabbitMQ.Client.Events.BasicReturnEventArgs.Body -> System.ReadOnlyMemory<byte>
813813
readonly RabbitMQ.Client.Events.BasicReturnEventArgs.Exchange -> string
814814
readonly RabbitMQ.Client.Events.BasicReturnEventArgs.ReplyCode -> ushort
@@ -863,7 +863,7 @@ static readonly RabbitMQ.Client.PublicationAddress.PSEUDO_URI_PARSER -> System.T
863863
virtual RabbitMQ.Client.AsyncDefaultBasicConsumer.HandleBasicCancel(string consumerTag) -> System.Threading.Tasks.Task
864864
virtual RabbitMQ.Client.AsyncDefaultBasicConsumer.HandleBasicCancelOk(string consumerTag) -> System.Threading.Tasks.Task
865865
virtual RabbitMQ.Client.AsyncDefaultBasicConsumer.HandleBasicConsumeOk(string consumerTag) -> System.Threading.Tasks.Task
866-
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
867867
virtual RabbitMQ.Client.AsyncDefaultBasicConsumer.HandleChannelShutdown(object channel, RabbitMQ.Client.ShutdownEventArgs reason) -> System.Threading.Tasks.Task
868868
virtual RabbitMQ.Client.AsyncDefaultBasicConsumer.OnCancel(params string[] consumerTags) -> System.Threading.Tasks.Task
869869
virtual RabbitMQ.Client.DefaultBasicConsumer.HandleBasicCancel(string consumerTag) -> void
@@ -882,7 +882,7 @@ virtual RabbitMQ.Client.TcpClientAdapter.ReceiveTimeout.get -> System.TimeSpan
882882
virtual RabbitMQ.Client.TcpClientAdapter.ReceiveTimeout.set -> void
883883
~const RabbitMQ.Client.RabbitMQActivitySource.PublisherSourceName = "RabbitMQ.Client.Publisher" -> string
884884
~const RabbitMQ.Client.RabbitMQActivitySource.SubscriberSourceName = "RabbitMQ.Client.Subscriber" -> string
885-
~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
886886
~RabbitMQ.Client.AmqpTcpEndpoint.AmqpTcpEndpoint(string hostName, int portOrMinusOne, RabbitMQ.Client.SslOption ssl, uint maxInboundMessageBodySize) -> void
887887
~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>
888888
~RabbitMQ.Client.ConnectionFactory.CreateConnectionAsync(string clientProvidedName, System.Threading.CancellationToken cancellationToken = default(System.Threading.CancellationToken)) -> System.Threading.Tasks.Task<RabbitMQ.Client.IConnection>
@@ -891,7 +891,7 @@ virtual RabbitMQ.Client.TcpClientAdapter.ReceiveTimeout.set -> void
891891
~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>
892892
~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>
893893
~RabbitMQ.Client.ConnectionFactory.CreateConnectionAsync(System.Threading.CancellationToken cancellationToken = default(System.Threading.CancellationToken)) -> System.Threading.Tasks.Task<RabbitMQ.Client.IConnection>
894-
~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
895895
~RabbitMQ.Client.IChannel.BasicCancelAsync(string consumerTag, bool noWait = false, System.Threading.CancellationToken cancellationToken = default(System.Threading.CancellationToken)) -> System.Threading.Tasks.Task
896896
~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>
897897
~RabbitMQ.Client.IChannel.BasicGetAsync(string queue, bool autoAck, System.Threading.CancellationToken cancellationToken = default(System.Threading.CancellationToken)) -> System.Threading.Tasks.ValueTask<RabbitMQ.Client.BasicGetResult>
@@ -960,5 +960,5 @@ virtual RabbitMQ.Client.TcpClientAdapter.ReceiveTimeout.set -> void
960960
~static RabbitMQ.Client.RabbitMQActivitySource.ContextExtractor.set -> void
961961
~static RabbitMQ.Client.RabbitMQActivitySource.ContextInjector.get -> System.Action<System.Diagnostics.Activity, System.Collections.Generic.IDictionary<string, object>>
962962
~static RabbitMQ.Client.RabbitMQActivitySource.ContextInjector.set -> void
963-
~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
964964

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,2 +1,2 @@
1-
RabbitMQ.Client.BasicProperties.BasicProperties(RabbitMQ.Client.ReadOnlyBasicProperties! input) -> void
2-
RabbitMQ.Client.IConnection.DispatchConsumersAsyncEnabled.get -> bool
1+
RabbitMQ.Client.BasicProperties.BasicProperties(RabbitMQ.Client.IReadOnlyBasicProperties! input) -> void
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/BasicProperties.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -85,7 +85,7 @@ public BasicProperties()
8585
{
8686
}
8787

88-
public BasicProperties(ReadOnlyBasicProperties input)
88+
public BasicProperties(IReadOnlyBasicProperties input)
8989
{
9090
ContentType = input.ContentType;
9191
ContentEncoding = input.ContentEncoding;

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.

0 commit comments

Comments
 (0)