Added interrupt.cs and refactored rrbroker.cs

examples/C#/interrupt.cs

@@ -0,0 +1,47 @@
+//
+//  Shows how to handle Ctrl-C
+//
+
+//  Author:     Tomas Roos
+//  Email:      ptomasroos@gmail.com
+
+using System;
+using System.Text;
+using System.Threading;
+using ZMQ;
+
+namespace ZMQGuide
+{
+    internal class Program
+    {
+
+        public static void Main(string[] args)
+        {
+            using (var context = new Context(1))
+            {
+                using (Socket replyer = context.Socket(SocketType.REP))
+                {
+                    replyer.Bind("tcp://*:5555");
+
+                    bool interrupted = false;
+
+                    Console.CancelKeyPress += delegate { interrupted = true; };
+
+                    const string replyMessage = "World";
+
+                    while (!interrupted)
+                    {
+                        string message = replyer.Recv(Encoding.Unicode);
+                        Console.WriteLine("Received request: {0}", message);
+
+                        // Simulate work, by sleeping
+                        Thread.Sleep(1000);
+
+                        // Send reply back to client
+                        replyer.Send(replyMessage, Encoding.Unicode);
+                    }
+                }
+            }
+        }
+    }
+}

examples/C#/rrbroker.cs

@@ -2,66 +2,59 @@
 //  Simple request-reply broker
 //
 
-//  Author:     Michael Compton
-//  Email:      michael.compton@littleedge.co.uk
+//  Author:     Michael Compton, Tomas Roos
+//  Email:      michael.compton@littleedge.co.uk, ptomasroos@gmail.com
 
 using System;
 using System.Text;
 using ZMQ;
 
-namespace ZMQGuide {
-    public class RRBroker {
-        private Context context;
-        private Socket backend;
-        private Socket frontend;
-
-        public RRBroker() {
-            //  Prepare our context and sockets
-            context = new Context(1);
-            frontend = context.Socket(SocketType.ROUTER);
-            backend = context.Socket(SocketType.DEALER);
-            frontend.Bind("tcp://*:5559");
-            backend.Bind("tcp://*:5560");
-        }
-
-        public void Broker() {
-            //  Initialize poll set
-            PollItem[] pollItems = new PollItem[2];
-            pollItems[0] = frontend.CreatePollItem(IOMultiPlex.POLLIN);
-            pollItems[0].PollInHandler += new PollHandler(FrontendPollInHandler);
-            pollItems[1] = backend.CreatePollItem(IOMultiPlex.POLLIN);
-            pollItems[1].PollInHandler += new PollHandler(BackendPollInHandler);
-            //  Switch messages between sockets
-            while (true) {
-                context.Poll(pollItems, -1);
+namespace ZMQGuide
+{
+    internal class Program
+    {
+        public static void Main(string[] args)
+        {
+            using (var context = new Context(1))
+            {
+                using (Socket frontend = context.Socket(SocketType.ROUTER), backend = context.Socket(SocketType.DEALER))
+                {
+                    frontend.Bind("tcp://*:5559");
+                    backend.Bind("tcp://*:5560");
+
+                    var pollItems = new PollItem[2];
+                    pollItems[0] = frontend.CreatePollItem(IOMultiPlex.POLLIN);
+                    pollItems[0].PollInHandler += (socket, revents) => FrontendPollInHandler(socket, backend);
+                    pollItems[1] = backend.CreatePollItem(IOMultiPlex.POLLIN);
+                    pollItems[1].PollInHandler += (socket, revents) => BackendPollInHandler(socket, frontend);
+
+                    while (true)
+                    {
+                        context.Poll(pollItems, -1);
+                    }
+                }
             }
         }
 
-        private void FrontendPollInHandler(Socket socket, IOMultiPlex revents) {
-            //  Process all parts of the message
-            bool isProcessing = true;
-            while (isProcessing) {
-                byte[] message = socket.Recv();
-                backend.Send(message, socket.RcvMore ? SendRecvOpt.SNDMORE : 0);
-                isProcessing = socket.RcvMore;
-            }
+        private static void FrontendPollInHandler(Socket frontend, Socket backend)
+        {
+            RelayMessage(frontend, backend);
         }
 
-        private void BackendPollInHandler(Socket socket, IOMultiPlex revents) {
-            //  Process all parts of the message
-            bool isProcessing = true;
-            while (isProcessing) {
-                byte[] message = socket.Recv();
-                frontend.Send(message, socket.RcvMore ? SendRecvOpt.SNDMORE : 0);
-                isProcessing = socket.RcvMore;
-            }
+        private static void BackendPollInHandler(Socket backend, Socket frontend)
+        {
+            RelayMessage(backend, frontend);
         }
-    }
 
-    class Program {
-        static void Main(string[] args) {
-            RRBroker broker = new RRBroker();
-            broker.Broker();
+        private static void RelayMessage(Socket source, Socket destination)
+        {
+            bool hasMore = true;
+            while (hasMore)
+            {
+                byte[] message = source.Recv();
+                hasMore = source.RcvMore;
+                destination.Send(message, hasMore ? SendRecvOpt.SNDMORE : 0);
+            }
         }
     }
 }