Skip to content

Commit 7116b3e

Browse files
author
Emile Joubert
committed
Handle nowait parameter correctly in ApiGen
1 parent 54cbb91 commit 7116b3e

File tree

2 files changed

+107
-0
lines changed

2 files changed

+107
-0
lines changed

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

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1066,6 +1066,8 @@ public void EmitModelMethod(MethodInfo method) {
10661066
EmitLine(" ModelSend(__req,"+contentHeaderExpr+","+contentBodyExpr+");");
10671067
if (method.ReturnType != typeof(void)) {
10681068
EmitLine(" return "+nowaitExpression+";");
1069+
} else {
1070+
EmitLine(" return;");
10691071
}
10701072
EmitLine(" }");
10711073
}
Lines changed: 105 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,105 @@
1+
// This source code is dual-licensed under the Apache License, version
2+
// 2.0, and the Mozilla Public License, version 1.1.
3+
//
4+
// The APL v2.0:
5+
//
6+
//---------------------------------------------------------------------------
7+
// Copyright (C) 2007-2010 LShift Ltd., Cohesive Financial
8+
// Technologies LLC., and Rabbit Technologies Ltd.
9+
//
10+
// Licensed under the Apache License, Version 2.0 (the "License");
11+
// you may not use this file except in compliance with the License.
12+
// You may obtain a copy of the License at
13+
//
14+
// http://www.apache.org/licenses/LICENSE-2.0
15+
//
16+
// Unless required by applicable law or agreed to in writing, software
17+
// distributed under the License is distributed on an "AS IS" BASIS,
18+
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
19+
// See the License for the specific language governing permissions and
20+
// limitations under the License.
21+
//---------------------------------------------------------------------------
22+
//
23+
// The MPL v1.1:
24+
//
25+
//---------------------------------------------------------------------------
26+
// The contents of this file are subject to the Mozilla Public License
27+
// Version 1.1 (the "License"); you may not use this file except in
28+
// compliance with the License. You may obtain a copy of the License at
29+
// http://www.rabbitmq.com/mpl.html
30+
//
31+
// Software distributed under the License is distributed on an "AS IS"
32+
// basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See the
33+
// License for the specific language governing rights and limitations
34+
// under the License.
35+
//
36+
// The Original Code is The RabbitMQ .NET Client.
37+
//
38+
// The Initial Developers of the Original Code are LShift Ltd,
39+
// Cohesive Financial Technologies LLC, and Rabbit Technologies Ltd.
40+
//
41+
// Portions created before 22-Nov-2008 00:00:00 GMT by LShift Ltd,
42+
// Cohesive Financial Technologies LLC, or Rabbit Technologies Ltd
43+
// are Copyright (C) 2007-2008 LShift Ltd, Cohesive Financial
44+
// Technologies LLC, and Rabbit Technologies Ltd.
45+
//
46+
// Portions created by LShift Ltd are Copyright (C) 2007-2010 LShift
47+
// Ltd. Portions created by Cohesive Financial Technologies LLC are
48+
// Copyright (C) 2007-2010 Cohesive Financial Technologies
49+
// LLC. Portions created by Rabbit Technologies Ltd are Copyright
50+
// (C) 2007-2010 Rabbit Technologies Ltd.
51+
//
52+
// All Rights Reserved.
53+
//
54+
// Contributor(s): ______________________________________.
55+
//
56+
//---------------------------------------------------------------------------
57+
using NUnit.Framework;
58+
using System.IO;
59+
using System.Threading;
60+
61+
using RabbitMQ.Client.Impl;
62+
using RabbitMQ.Client.Exceptions;
63+
using RabbitMQ.Client.Events;
64+
using RabbitMQ.Util;
65+
using System;
66+
67+
68+
namespace RabbitMQ.Client.Unit
69+
{
70+
[TestFixture]
71+
public class TestApiGen
72+
{
73+
IConnection Connection;
74+
IModel Channel;
75+
String exchangeName = "nowait-test-exchange";
76+
77+
[SetUp] public void Connect()
78+
{
79+
Connection = new ConnectionFactory().CreateConnection();
80+
Channel = Connection.CreateModel();
81+
}
82+
83+
[TearDown] public void Disconnect()
84+
{
85+
try {
86+
Channel.ExchangeDelete(exchangeName, false, false);
87+
} catch (OperationInterruptedException) {}
88+
Connection.Abort();
89+
}
90+
91+
[Test, Timeout(1000)]
92+
public void TestExchangeDeclareNoWait()
93+
{
94+
Channel.ExchangeDeclare(exchangeName, "direct",
95+
false, false, true, false, true, null);
96+
}
97+
98+
[Test]
99+
public void TestExchangeDeleteNoWait()
100+
{
101+
Channel.ExchangeDeclare(exchangeName, "direct");
102+
Channel.ExchangeDelete(exchangeName, false, true);
103+
}
104+
}
105+
}

0 commit comments

Comments
 (0)