Skip to content

Commit f9da3fe

Browse files
committed
PR review suggestions
1 parent c5dcfe7 commit f9da3fe

File tree

2 files changed

+5
-10
lines changed

2 files changed

+5
-10
lines changed

projects/RabbitMQ.Client/client/framing/Channel.cs

Lines changed: 0 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -205,12 +205,6 @@ public override void _Private_QueueDeclare(string queue, bool passive, bool dura
205205
ChannelSend(method);
206206
}
207207

208-
public override ValueTask _Private_QueueDeclareAsync(string queue, bool passive, bool durable, bool exclusive, bool autoDelete, bool nowait, IDictionary<string, object> arguments)
209-
{
210-
var method = new QueueDeclare(queue, passive, durable, exclusive, autoDelete, nowait, arguments);
211-
return ModelSendAsync(method);
212-
}
213-
214208
public override uint _Private_QueueDelete(string queue, bool ifUnused, bool ifEmpty, bool nowait)
215209
{
216210
var method = new QueueDelete(queue, ifUnused, ifEmpty, nowait);

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

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -851,8 +851,6 @@ protected bool HandleQueueDeclareOk(in IncomingCommand cmd)
851851

852852
public abstract void _Private_QueueDeclare(string queue, bool passive, bool durable, bool exclusive, bool autoDelete, bool nowait, IDictionary<string, object> arguments);
853853

854-
public abstract ValueTask _Private_QueueDeclareAsync(string queue, bool passive, bool durable, bool exclusive, bool autoDelete, bool nowait, IDictionary<string, object> arguments);
855-
856854
public abstract uint _Private_QueueDelete(string queue, bool ifUnused, bool ifEmpty, bool nowait);
857855

858856
public abstract uint _Private_QueuePurge(string queue, bool nowait);
@@ -1267,8 +1265,11 @@ private async ValueTask<QueueDeclareOk> QueueDeclareAsync(string queue, bool pas
12671265
try
12681266
{
12691267
Enqueue(k);
1270-
await _Private_QueueDeclareAsync(queue, passive, durable, exclusive, autoDelete, false, arguments)
1271-
.ConfigureAwait(false);
1268+
1269+
1270+
var method = new QueueDeclare(queue, passive, durable, exclusive, autoDelete, false, arguments);
1271+
await ModelSendAsync(method).ConfigureAwait(false);
1272+
12721273
QueueDeclareOk result = await k;
12731274
CurrentQueue = result.QueueName;
12741275
return result;

0 commit comments

Comments
 (0)