Skip to content

Commit 6e8b1c5

Browse files
committed
* Just for grins, don't use a server-generated queue name.
1 parent f931aea commit 6e8b1c5

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

projects/Test/Integration/TestQueueDeclare.cs

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -97,9 +97,10 @@ async Task f()
9797
// sleep for a random amount of time to increase the chances
9898
// of thread interleaving. MK.
9999
await Task.Delay(S_Random.Next(5, 50));
100-
QueueDeclareOk r = await _channel.QueueDeclareAsync(queue: string.Empty,
100+
string queueName = $"{_testDisplayName}-{Guid.NewGuid()}";
101+
QueueDeclareOk r = await _channel.QueueDeclareAsync(queue: queueName,
101102
durable: false, exclusive: true, autoDelete: false);
102-
string queueName = r.QueueName;
103+
Assert.Equal(queueName, r.QueueName);
103104
await _channel.QueueBindAsync(queue: queueName, exchange: "amq.fanout", routingKey: queueName);
104105
if (false == queueNames.TryAdd(queueName, true))
105106
{

0 commit comments

Comments
 (0)