support amqps scheme + update example docs

We need to ignore RemoteCertificateNameMismatches because the server name
may not also be it's network name (and it's also Java's default
behaviour).  We still need to set ServerName, though; the ssl connect function
needs it.

Author: Alexandru Scvortov

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

@@ -41,6 +41,7 @@
 using System;
 using System.IO;
 using System.Net;
+using System.Net.Security;
 using System.Net.Sockets;
 using System.Collections;
 
@@ -181,14 +182,21 @@ public String Uri
 
               Uri uri = new Uri(value, UriKind.Absolute);
 
-              if ("amqp".CompareTo(uri.Scheme) != 0) {
+              if ("amqp".CompareTo(uri.Scheme.ToLower()) == 0) {
+                  // nothing special to do
+              } else if ("amqps".CompareTo(uri.Scheme.ToLower()) == 0) {
+                  Ssl.Enabled = true;
+                  Ssl.AcceptablePolicyErrors = SslPolicyErrors.RemoteCertificateNameMismatch;
+                  Port = AmqpTcpEndpoint.DefaultAmqpSslPort;
+              } else {
                   throw new ArgumentException("Wrong scheme in AMQP URI: " +
                                               value);
               }
               string host = uri.Host;
               if (!String.IsNullOrEmpty(host)) {
                   HostName = host;
               }
+              Ssl.ServerName = HostName;
 
               int port = uri.Port;
               if (port != -1) {

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

@@ -144,7 +144,7 @@ private void ParseFail(string uri)
                 ConnectionFactory cf = new ConnectionFactory();
                 cf.Uri = uri;
                 Assert.Fail("URI parse didn't fail: '" + uri + "'");
-            } catch (Exception e) {
+            } catch (Exception) {
                 // whoosh!
             }
         }

projects/examples/client/AddClient/src/examples/AddClient.cs

@@ -50,7 +50,7 @@ namespace RabbitMQ.Client.Examples {
     public class AddClient {
         public static int Main(string[] args) {
             if (args.Length < 1) {
-                Console.Error.WriteLine("Usage: AddClient <hostname>[:<portnumber>] [<number> ...]");
+                Console.Error.WriteLine("Usage: AddClient <uri> [<number> ...]");
                 Console.Error.WriteLine("RabbitMQ .NET client version "+typeof(IModel).Assembly.GetName().Version.ToString());
                 return 2;
             }

projects/examples/client/AddServer/src/examples/AddServer.cs

@@ -51,7 +51,7 @@ namespace RabbitMQ.Client.Examples {
     public class AddServer: SimpleRpcServer {
         public static int Main(string[] args) {
             if (args.Length < 1) {
-                Console.Error.WriteLine("Usage: AddServer <hostname>[:<portnumber>]");
+                Console.Error.WriteLine("Usage: AddServer <uri>");
                 Console.Error.WriteLine("RabbitMQ .NET client version "+typeof(IModel).Assembly.GetName().Version.ToString());
                 return 2;
             }

projects/examples/client/DeclareQueue/src/examples/DeclareQueue.cs

@@ -72,7 +72,7 @@ public static int Main(string[] args) {
             if (((args.Length - optionIndex) < 2) ||
                 (((args.Length - optionIndex) % 2) != 0))
                 {
-                    Console.Error.WriteLine("Usage: DeclareQueue [<option> ...] <hostname>[:<portnumber>] <queue> [<exchange> <routingkey>] ...");
+                    Console.Error.WriteLine("Usage: DeclareQueue [<option> ...] <uri> <queue> [<exchange> <routingkey>] ...");
                     Console.Error.WriteLine("RabbitMQ .NET client version "+typeof(IModel).Assembly.GetName().Version.ToString());
                     Console.Error.WriteLine("Available options:");
                     Console.Error.WriteLine("  /durable      declare a durable queue");

projects/examples/client/ExceptionTest/src/examples/ExceptionTest.cs

@@ -52,7 +52,7 @@ public class ExceptionTest {
         public static int Main(string[] args) {
             try {
                 if (args.Length < 1) {
-                    Console.Error.WriteLine("Usage: ExceptionTest <hostname>[:<portnumber>]");
+                    Console.Error.WriteLine("Usage: ExceptionTest <uri>");
                     Console.Error.WriteLine("RabbitMQ .NET client version "+typeof(IModel).Assembly.GetName().Version.ToString());
                     return 2;
                 }

projects/examples/client/LogTail/src/examples/LogTail.cs

@@ -52,7 +52,7 @@ namespace RabbitMQ.Client.Examples {
     public class LogTail {
         public static int Main(string[] args) {
             if (args.Length < 4) {
-                Console.Error.WriteLine("Usage: LogTail <hostname>[:<portnumber>] <exchange> <exchangetype> <routingkey>");
+                Console.Error.WriteLine("Usage: LogTail <uri> <exchange> <exchangetype> <routingkey>");
                 Console.Error.WriteLine("RabbitMQ .NET client version "+typeof(IModel).Assembly.GetName().Version.ToString());
                 Console.Error.WriteLine("If the exchange name is the empty string, will instead declare a queue named");
                 Console.Error.WriteLine("by the routingkey, and consume from that queue.");

projects/examples/client/LowlevelLogTail/src/examples/LowlevelLogTail.cs

@@ -52,7 +52,7 @@ namespace RabbitMQ.Client.Examples {
     public class LowlevelLogTail {
         public static int Main(string[] args) {
             if (args.Length < 4) {
-                Console.Error.WriteLine("Usage: LowlevelLogTail <hostname>[:<portnumber>] <exchange> <exchangetype> <routingkey>");
+                Console.Error.WriteLine("Usage: LowlevelLogTail <uri> <exchange> <exchangetype> <routingkey>");
                 Console.Error.WriteLine("RabbitMQ .NET client version "+typeof(IModel).Assembly.GetName().Version.ToString());
                 Console.Error.WriteLine("If the exchange name is the empty string, will instead declare a queue named");
                 Console.Error.WriteLine("by the routingkey, and consume from that queue.");

projects/examples/client/PerfTest/src/examples/PerfTest.cs

@@ -51,7 +51,7 @@ public class PerfTest {
 
         public static int Main(string[] args) {
             if (args.Length < 2) {
-                Console.Error.WriteLine("Usage: PerfTest <hostname>[:<portnumber>] <number of messages>");
+                Console.Error.WriteLine("Usage: PerfTest <uri> <number of messages>");
                 Console.Error.WriteLine("RabbitMQ .NET client version "+typeof(IModel).Assembly.GetName().Version.ToString());
                 return 2;
             }

projects/examples/client/SendString/src/examples/SendString.cs

@@ -47,7 +47,7 @@ namespace RabbitMQ.Client.Examples {
     public class SendString {
         public static int Main(string[] args) {
             if (args.Length < 5) {
-                Console.Error.WriteLine("Usage: SendString <hostname>[:<portnumber>] <exchange> <exchangetype> <routingkey> <message>");
+                Console.Error.WriteLine("Usage: SendString <uri> <exchange> <exchangetype> <routingkey> <message>");
                 Console.Error.WriteLine("RabbitMQ .NET client version "+typeof(IModel).Assembly.GetName().Version.ToString());
                 return 2;
             }