all examples are now building. All tests are passing

Author: David R. MacIver

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

@@ -100,7 +100,7 @@ public static int Main(string[] args) {
             string serverAddress = args[optionIndex++];
             string inputQueueName = args[optionIndex++];
 
-            using (IConnection conn = new ConnectionFactory().CreateConnection(serverAddress))
+            using (IConnection conn = new ConnectionFactory(AmqpTcpEndpoint.Parse(serverAddress)).CreateConnection())
                 {
                     using (IModel ch = conn.CreateModel()) {
 

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

@@ -75,7 +75,7 @@ public static int Main(string[] args) {
 
                 string serverAddress = args[0];
 
-                using (IConnection conn = new ConnectionFactory().CreateConnection(serverAddress))
+                using (IConnection conn = new ConnectionFactory(AmqpTcpEndpoint.Parse(serverAddress)).CreateConnection())
                 {
                     conn.ConnectionShutdown += new ConnectionShutdownEventHandler(First);
                     conn.ConnectionShutdown += new ConnectionShutdownEventHandler(OnConnectionShutdown);

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

@@ -81,7 +81,7 @@ public static int Main(string[] args) {
             string exchangeType = args[2];
             string routingKey = args[3];
 
-            using (IConnection conn = new ConnectionFactory().CreateConnection(serverAddress))
+            using (IConnection conn = new ConnectionFactory(AmqpTcpEndpoint.Parse(serverAddress)).CreateConnection())
                 {
                     using (IModel ch = conn.CreateModel())
                         {

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

@@ -76,7 +76,7 @@ public static int Main(string[] args) {
             int messageCount = int.Parse(args[1]);
 
             using (IConnection conn =
-                   new ConnectionFactory().CreateConnection(serverAddress))
+                   new ConnectionFactory(AmqpTcpEndpoint.Parse(serverAddress)).CreateConnection())
                 {
                     Stopwatch sendTimer = new Stopwatch();
                     Stopwatch receiveTimer = new Stopwatch();

projects/examples/client/SendMap/src/examples/SendMap.cs

@@ -111,7 +111,7 @@ public static int Main(string[] args) {
                 exchange = "";
             }
 
-            using (IConnection conn = new ConnectionFactory().CreateConnection(uri))
+            using (IConnection conn = new ConnectionFactory(new AmqpTcpEndpoint(uri)).CreateConnection())
                 {
                     using (IModel ch = conn.CreateModel()) {
 

projects/examples/client/ShutdownableClient/src/examples/ShutdownableClient.cs

@@ -71,7 +71,7 @@ public static int Main(string[] args) {
                 return 2;
             }
 
-            using (IConnection conn = new ConnectionFactory().CreateConnection(args[0])) {
+            using (IConnection conn = new ConnectionFactory(AmqpTcpEndpoint.Parse(args[0])).CreateConnection()) {
                 using (IModel ch = conn.CreateModel()) {
                     object[] callArgs = new object[1];
                     if (args.Length > 1) {

projects/examples/client/ShutdownableServer/src/examples/ShutdownableServer.cs

@@ -71,7 +71,7 @@ public static int Main(string[] args) {
                 return 2;
             }
 
-            using (IConnection conn = new ConnectionFactory().CreateConnection(args[0])) {
+            using (IConnection conn = new ConnectionFactory(AmqpTcpEndpoint.Parse(args[0])).CreateConnection()) {
                 using (IModel ch = conn.CreateModel()) {
                     Subscription sub = new Subscription(ch, "ShutdownableServer");
                     new ShutdownableServer(sub).MainLoop();