more fixing of examples

David R. MacIver · David R. MacIver · commit 386dfb0274cb · 2009-12-17T12:29:21.000Z
diff --git a/projects/examples/client/LogTail/src/examples/LogTail.cs b/projects/examples/client/LogTail/src/examples/LogTail.cs
@@ -80,7 +80,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()) {
                         Subscription sub;
diff --git a/projects/examples/client/SendString/src/examples/SendString.cs b/projects/examples/client/SendString/src/examples/SendString.cs
@@ -74,7 +74,7 @@ public static int Main(string[] args) {
             string routingKey = args[3];
             string message = args[4];
             
-            using (IConnection conn = new ConnectionFactory().CreateConnection(serverAddress))
+            using (IConnection conn = new ConnectionFactory(AmqpTcpEndpoint.Parse(serverAddress)).CreateConnection())
                 {
                     using (IModel ch = conn.CreateModel()) {
                         
diff --git a/projects/examples/client/SingleGet/src/examples/SingleGet.cs b/projects/examples/client/SingleGet/src/examples/SingleGet.cs
@@ -74,7 +74,7 @@ public static int Main(string[] args) {
             string serverAddress = args[0];
             string queueName = args[1];
             
-            IConnection conn = new ConnectionFactory().CreateConnection(serverAddress);
+            IConnection conn = new ConnectionFactory(AmqpTcpEndpoint.Parse(serverAddress)).CreateConnection();
             conn.ConnectionShutdown += new ConnectionShutdownEventHandler(LogConnClose);
 
             using (IModel ch = conn.CreateModel()) {

Original file line number	Diff line number	Diff line change
`@@ -80,7 +80,7 @@ public static int Main(string[] args) {`
`80`	`80`	`string exchangeType = args[2];`
`81`	`81`	`string routingKey = args[3];`
`82`	`82`
`83`		`- using (IConnection conn = new ConnectionFactory().CreateConnection(serverAddress))`
	`83`	`+ using (IConnection conn = new ConnectionFactory(AmqpTcpEndpoint.Parse(serverAddress)).CreateConnection())`
`84`	`84`	`{`
`85`	`85`	`using (IModel ch = conn.CreateModel()) {`
`86`	`86`	`Subscription sub;`
Original file line number	Diff line number	Diff line change
`@@ -74,7 +74,7 @@ public static int Main(string[] args) {`
`74`	`74`	`string routingKey = args[3];`
`75`	`75`	`string message = args[4];`
`76`	`76`
`77`		`- using (IConnection conn = new ConnectionFactory().CreateConnection(serverAddress))`
	`77`	`+ using (IConnection conn = new ConnectionFactory(AmqpTcpEndpoint.Parse(serverAddress)).CreateConnection())`
`78`	`78`	`{`
`79`	`79`	`using (IModel ch = conn.CreateModel()) {`
`80`	`80`