Basic skeleton for waiting for packets to be fed in.

Kinematics · Dec 25, 2012 · 8ae2889 · 8ae2889
1 parent 10979a8
commit 8ae2889
Showing 1 changed file with 13 additions and 4 deletions.
diff --git a/ParserCore/Monitors/PacketReader/PacketReader.cs b/ParserCore/Monitors/PacketReader/PacketReader.cs
@@ -44,7 +44,6 @@ private PacketReader()
         ManualResetEvent abortMonitorThread = new ManualResetEvent(false);
         #endregion
 
-
         #region Interface Control Methods and Properties
 
         /// <summary>
@@ -157,7 +156,6 @@ internal void PolExited(object sender, EventArgs e)
 
         #endregion
 
-
         #region Monitor RAM
         /// <summary>
         /// This function is run as a thread to read ram and raise events when new
@@ -189,9 +187,20 @@ internal void Monitor()
                 pol.Process.Exited += new EventHandler(PolExited);
             }
 
-            while (!abortMonitorThread.WaitOne(0))
+            // Wait for packets published from Windower.
+            using (var ctx = new ZMQ.Context(1))
             {
-                // Monitor packets.
+                using (Socket subscriber = ctx.Socket(SocketType.SUB))
+                {
+                    subscriber.Connect("tcp://localhost:43350");
+                    subscriber.Subscribe(pol.Process.Id.ToString(), Encoding.Unicode);
+
+                    while (!abortMonitorThread.WaitOne(0))
+                    {
+                        string address = subscriber.Recv(Encoding.Unicode);
+                        string contents = subscriber.Recv(Encoding.Unicode);
+                    }
+                }
             }
         }
         #endregion