Skip to content

Commit 67b795a

Browse files
committed
Add a UnitTest to test the SSL connection end to end
1 parent 3601029 commit 67b795a

File tree

1 file changed

+100
-0
lines changed

1 file changed

+100
-0
lines changed

src/unit/TestSslEndpoint.cs

Lines changed: 100 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,100 @@
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-2009 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-2009 LShift
47+
// Ltd. Portions created by Cohesive Financial Technologies LLC are
48+
// Copyright (C) 2007-2009 Cohesive Financial Technologies
49+
// LLC. Portions created by Rabbit Technologies Ltd are Copyright
50+
// (C) 2007-2009 Rabbit Technologies Ltd.
51+
//
52+
// All Rights Reserved.
53+
//
54+
// Contributor(s): ______________________________________.
55+
//
56+
//---------------------------------------------------------------------------
57+
using NUnit.Framework;
58+
using System;
59+
using RabbitMQ.Client;
60+
61+
[TestFixture]
62+
public class TestSslEndpoint {
63+
[Test]
64+
public void TestHostWithPort() {
65+
66+
string message = "Hello C# SSL Client World";
67+
68+
ConnectionFactory cf = new ConnectionFactory();
69+
70+
cf.Parameters.Ssl.ServerName = System.Net.Dns.GetHostName();
71+
// cf.Parameters.Ssl.CertPath = "/etc/rabbitmq/clientcert.cer";
72+
cf.Parameters.Ssl.Enabled = true;
73+
74+
IProtocol proto = Protocols.DefaultProtocol;
75+
IConnection conn = cf.CreateConnection(proto, "localhost", 5673);
76+
77+
IModel ch = conn.CreateModel();
78+
79+
80+
ch.ExchangeDeclare("Exchange_TestSslEndPoint", ExchangeType.Direct);
81+
ch.QueueDeclare("Queue_TestSslEndpoint");
82+
ch.QueueBind("Queue_TestSslEndpoint", "Exchange_TestSslEndPoint", "Key_TestSslEndpoint", false, null);
83+
84+
byte[] msgBytes = System.Text.Encoding.UTF8.GetBytes(message);
85+
ch.BasicPublish("Exchange_TestSslEndPoint", "Key_TestSslEndpoint", null, msgBytes);
86+
87+
bool noAck = false;
88+
89+
BasicGetResult result = ch.BasicGet("Queue_TestSslEndpoint", noAck);
90+
byte[] body = result.Body;
91+
92+
string resultMessage = System.Text.Encoding.UTF8.GetString(body);
93+
94+
ch.Close(200, "Closing the channel");
95+
conn.Close();
96+
97+
Assert.AreEqual(message, resultMessage);
98+
99+
}
100+
}

0 commit comments

Comments
 (0)