Skip to content

Commit 8f7d151

Browse files
committed
* Fix recovery with server-named queues
1 parent 479ef6b commit 8f7d151

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

projects/RabbitMQ.Client/client/impl/RecordedQueue.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,7 @@ public RecordedQueue(QueueName newName, in RecordedQueue old)
7676
public async Task<QueueName> RecoverAsync(IChannel channel, CancellationToken cancellationToken)
7777
{
7878
QueueName queueName = _name;
79-
if (_name.IsEmpty)
79+
if (_isServerNamed || _name.IsEmpty)
8080
{
8181
queueName = QueueName.Empty;
8282
}

projects/Test/Integration/ConnectionRecovery/TestExchangeRecovery.cs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -63,14 +63,14 @@ public async Task TestExchangeToExchangeBindingRecovery()
6363
await _channel.ExchangeDeclareAsync(ex_source, ExchangeType.Fanout);
6464
await _channel.ExchangeDeclareAsync(ex_destination, ExchangeType.Fanout);
6565

66-
await _channel.ExchangeBindAsync(destination: ex_destination, source: ex_source, "");
67-
await _channel.QueueBindAsync(q, ex_destination, "");
66+
await _channel.ExchangeBindAsync(destination: ex_destination, source: ex_source, RoutingKey.Empty);
67+
await _channel.QueueBindAsync(q, ex_destination, RoutingKey.Empty);
6868

6969
try
7070
{
7171
await CloseAndWaitForRecoveryAsync();
7272
Assert.True(_channel.IsOpen);
73-
await _channel.BasicPublishAsync(ex_source, "", _encoding.GetBytes("msg"));
73+
await _channel.BasicPublishAsync(ex_source, RoutingKey.Empty, _encoding.GetBytes("msg"));
7474
await AssertMessageCountAsync(q, 1);
7575
}
7676
finally

0 commit comments

Comments
 (0)