Skip to content

Commit ad1160b

Browse files
committed
* Fix QueueUnbindAsync default argument in IChannel
* Rename variables in test to make it easier to understand
1 parent d760239 commit ad1160b

File tree

3 files changed

+10
-10
lines changed

3 files changed

+10
-10
lines changed

projects/RabbitMQ.Client/PublicAPI.Unshipped.txt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -912,7 +912,7 @@ virtual RabbitMQ.Client.TcpClientAdapter.ReceiveTimeout.set -> void
912912
~RabbitMQ.Client.IChannel.QueueDeclarePassiveAsync(string queue, System.Threading.CancellationToken cancellationToken = default(System.Threading.CancellationToken)) -> System.Threading.Tasks.Task<RabbitMQ.Client.QueueDeclareOk>
913913
~RabbitMQ.Client.IChannel.QueueDeleteAsync(string queue, bool ifUnused, bool ifEmpty, bool noWait = false, System.Threading.CancellationToken cancellationToken = default(System.Threading.CancellationToken)) -> System.Threading.Tasks.Task<uint>
914914
~RabbitMQ.Client.IChannel.QueuePurgeAsync(string queue, System.Threading.CancellationToken cancellationToken = default(System.Threading.CancellationToken)) -> System.Threading.Tasks.Task<uint>
915-
~RabbitMQ.Client.IChannel.QueueUnbindAsync(string queue, string exchange, string routingKey, System.Collections.Generic.IDictionary<string, object> arguments, System.Threading.CancellationToken cancellationToken = default(System.Threading.CancellationToken)) -> System.Threading.Tasks.Task
915+
~RabbitMQ.Client.IChannel.QueueUnbindAsync(string queue, string exchange, string routingKey, System.Collections.Generic.IDictionary<string, object> arguments = null, System.Threading.CancellationToken cancellationToken = default(System.Threading.CancellationToken)) -> System.Threading.Tasks.Task
916916
~RabbitMQ.Client.IChannel.TxCommitAsync(System.Threading.CancellationToken cancellationToken = default(System.Threading.CancellationToken)) -> System.Threading.Tasks.Task
917917
~RabbitMQ.Client.IChannel.TxRollbackAsync(System.Threading.CancellationToken cancellationToken = default(System.Threading.CancellationToken)) -> System.Threading.Tasks.Task
918918
~RabbitMQ.Client.IChannel.TxSelectAsync(System.Threading.CancellationToken cancellationToken = default(System.Threading.CancellationToken)) -> System.Threading.Tasks.Task

projects/RabbitMQ.Client/client/api/IChannel.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -418,7 +418,7 @@ Task QueueBindAsync(string queue, string exchange, string routingKey,
418418
/// Routing key must be shorter than 255 bytes.
419419
/// </remarks>
420420
Task QueueUnbindAsync(string queue, string exchange, string routingKey,
421-
IDictionary<string, object> arguments,
421+
IDictionary<string, object> arguments = null,
422422
CancellationToken cancellationToken = default);
423423

424424
/// <summary>

projects/Test/Integration/ConnectionRecovery/TestRecoveryWithDeletedEntities.cs

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -97,26 +97,26 @@ public async Task TestThatDeletedExchangesDontReappearOnRecovery()
9797
public async Task TestThatDeletedQueueBindingsDontReappearOnRecovery()
9898
{
9999
string q = (await _channel.QueueDeclareAsync("", false, false, false)).QueueName;
100-
string x1 = "amq.fanout";
101-
string x2 = GenerateExchangeName();
100+
string ex_amq_fanout = "amq.fanout";
101+
string ex_test = GenerateExchangeName();
102102

103-
await _channel.ExchangeDeclareAsync(x2, "fanout");
104-
await _channel.ExchangeBindAsync(x1, x2, "");
105-
await _channel.QueueBindAsync(q, x1, "");
106-
await _channel.QueueUnbindAsync(q, x1, "", null);
103+
await _channel.ExchangeDeclareAsync(ex_test, "fanout");
104+
await _channel.ExchangeBindAsync(destination: ex_amq_fanout, source: ex_test, routingKey: "");
105+
await _channel.QueueBindAsync(q, ex_amq_fanout, "");
106+
await _channel.QueueUnbindAsync(q, ex_amq_fanout, "");
107107

108108
try
109109
{
110110
await CloseAndWaitForRecoveryAsync();
111111
Assert.True(_channel.IsOpen);
112-
await _channel.BasicPublishAsync(x2, "", _encoding.GetBytes("msg"));
112+
await _channel.BasicPublishAsync(ex_test, "", _encoding.GetBytes("msg"));
113113
await AssertMessageCountAsync(q, 0);
114114
}
115115
finally
116116
{
117117
await WithTemporaryChannelAsync(async ch =>
118118
{
119-
await ch.ExchangeDeleteAsync(x2);
119+
await ch.ExchangeDeleteAsync(ex_test);
120120
await ch.QueueDeleteAsync(q);
121121
});
122122
}

0 commit comments

Comments
 (0)