using System;
using System.Collections.Generic;
using System.Linq;
using System.Linq.Expressions;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using NetMQ;

namespace DDEConnector
{
    class Program
    {
        static void Main(string[] args)
        {
            var ctx = NetMQContext.Create();
            var pushSocket = ctx.CreatePushSocket();
            var pullSocket = ctx.CreatePullSocket();
            pushSocket.Bind("tcp://192.168.1.13:5000"); // outgoing messages
            pullSocket.Bind("tcp://192.168.1.13:5001"); // input messages

            var poller = new Poller(new[] {pullSocket}); // obj for constantly checking sockets

            Task.Run(() => poller.Start()); // run in separate task/thread

            // receive event
            pullSocket.ReceiveReady += (sender, eventArgs) =>
                Console.WriteLine("received: " + eventArgs.Socket.ReceiveString());

            // sending test messages
            String resp;
            foreach (var s in Enumerable.Range(0,10))
            {
                Thread.Sleep(1000);

                pushSocket.Send(s.ToString());
                Console.WriteLine("sending: " + s);
            }

            Console.ReadKey();
        }
    }
}