Skip to content

Commit 5e3c29e

Browse files
merge bug26208 into default (again, to fix build)
2 parents a2c23b9 + 5fdf6cf commit 5e3c29e

File tree

4 files changed

+18
-1
lines changed

4 files changed

+18
-1
lines changed

projects/client/Apigen/src/apigen/Apigen.cs

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -832,6 +832,8 @@ public void MaybeEmitModelMethod(MethodInfo method) {
832832
if (method.IsSpecialName) {
833833
// It's some kind of event- or property-related method.
834834
// It shouldn't be autogenerated.
835+
} else if (method.Name.EndsWith("Nowait")) {
836+
// Skip *Nowait versions
835837
} else if (Attribute(method, typeof(AmqpMethodDoNotImplementAttribute)) != null) {
836838
// Skip this method, by request (AmqpMethodDoNotImplement)
837839
} else if (Attribute(method, typeof(AmqpContentHeaderFactoryAttribute)) != null) {

projects/client/RabbitMQ.Client/src/client/api/IModel.cs

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -272,6 +272,13 @@ void QueueBind(string queue,
272272
string exchange,
273273
string routingKey);
274274

275+
///<summary>Same as QueueBind but sets nowait parameter to true and returns void (as there
276+
///will be no response from the server).</summary>
277+
void QueueBindNowait(string queue,
278+
string exchange,
279+
string routingKey,
280+
IDictionary<string, object> arguments);
281+
275282
///<summary>(Spec method) Unbind a queue from an exchange.</summary>
276283
///<remarks>
277284
///Note: This operation is only supported when communicating

projects/client/RabbitMQ.Client/src/client/impl/ModelBase.cs

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -935,6 +935,14 @@ public void QueueBind(string queue,
935935
QueueBind(queue, exchange, routingKey, null);
936936
}
937937

938+
public void QueueBindNowait(string queue,
939+
string exchange,
940+
string routingKey,
941+
IDictionary<string, object> arguments)
942+
{
943+
_Private_QueueBind(queue, exchange, routingKey, true, arguments);
944+
}
945+
938946
public abstract void _Private_QueueBind(string queue,
939947
string exchange,
940948
string routingKey,

projects/client/Unit/src/unit/TestQueueDeclare.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -89,7 +89,7 @@ public void TestConcurrentQueueDeclare()
8989
[Test]
9090
public void TestQueueDeclareNowait()
9191
{
92-
string q = GenerateQueueName ();
92+
string q = GenerateQueueName();
9393
Model.QueueDeclareNowait(q, false, true, false, null);
9494
Model.QueueDeclarePassive(q);
9595
}

0 commit comments

Comments
 (0)