Added dotnet examples (via Jim)

majek · majek · commit 5b42d5a94629 · 2010-11-23T14:49:17.000Z
diff --git a/.gitignore b/.gitignore
@@ -1 +1,3 @@
 php/lib/php-amqplib
+dotnet/*.exe
+dotnet/lib
diff --git a/dotnet/README.md b/dotnet/README.md
@@ -0,0 +1,29 @@
+# Dotnet C# code for RabbitMQ tutorials
+
+Here you can find a C# code examples from [RabbitMQ
+tutorials](http://www.rabbitmq.com/getstarted.html).
+
+
+Here we present steps to run the examples using Mono on Linux.
+
+## Requirements
+
+You need Mono and RabbitMQ dotnet client.
+
+    sudo apt-get install mono-devel
+    mkdir lib
+    cd lib
+    wget http://www.rabbitmq.com/releases/rabbitmq-dotnet-client/v2.1.1/rabbitmq-dotnet-client-2.1.1-dotnet-3.0.zip
+    unzip rabbitmq-dotnet-client-2.1.1-dotnet-3.0.zip
+    cd ..
+
+
+## Code
+
+[Tutorial one: "Hello World!"](http://www.rabbitmq.com/tutorial-one-python.html):
+
+    gmcs -r:lib/bin/RabbitMQ.Client.dll Send.cs
+    MONO_PATH=lib/bin mono Send.exe
+
+    gmcs -r:lib/bin/RabbitMQ.Client.dll Receive.cs
+    MONO_PATH=lib/bin mono Receive.exe
diff --git a/dotnet/Receive.cs b/dotnet/Receive.cs
@@ -0,0 +1,29 @@
+using System;
+using RabbitMQ.Client;
+using RabbitMQ.Client.Events;
+
+namespace Receive {
+    class Program {
+        static void Main(string[] args) {
+            ConnectionFactory factory = new ConnectionFactory();
+            factory.HostName = "localhost";
+            IConnection connection = factory.CreateConnection();
+            IModel channel = connection.CreateModel();
+
+            channel.QueueDeclare("test");
+
+            QueueingBasicConsumer consumer = new QueueingBasicConsumer(channel);
+            channel.BasicConsume("test", true, null, consumer);
+
+            Console.WriteLine(" [*] Waiting for messages. To exit press CTRL+C");
+            while(true) {
+                BasicDeliverEventArgs ea =
+                    (BasicDeliverEventArgs)consumer.Queue.Dequeue();
+
+                byte[] body = ea.Body;
+                string message = System.Text.Encoding.UTF8.GetString(body);
+                Console.WriteLine(" [x] Received {0}", message);
+            }
+        }
+    }
+}
diff --git a/dotnet/Send.cs b/dotnet/Send.cs
@@ -0,0 +1,24 @@
+using System;
+using RabbitMQ.Client;
+
+namespace Send {
+    class Program {
+        static void Main(string[] args) {
+            ConnectionFactory factory = new ConnectionFactory();
+            factory.HostName = "localhost";
+            IConnection connection = factory.CreateConnection();
+            IModel channel = connection.CreateModel();
+
+            channel.QueueDeclare("test");
+
+            string message = "Hello World!";
+            byte[] body = System.Text.Encoding.UTF8.GetBytes(message);
+
+            channel.BasicPublish("", "test", null, body);
+            Console.WriteLine(" [x] Sent {0}", message);
+
+            channel.Close();
+            connection.Close();
+        }
+    }
+}

Original file line number	Diff line number	Diff line change
`@@ -1 +1,3 @@`
`1`	`1`	`php/lib/php-amqplib`
	`2`	`+dotnet/*.exe`
	`3`	`+dotnet/lib`