ClrZmq returning messages always to first started client

See more:

C#

WPF

CLR

Python2.7

Task

Hi,

We're creating a WPF app in which we execute python scripts from different Test Stations and show the output in its corresponding output panel, To run the scripts in parallel we are using Task but when we run the scripts in parallel from the stations, We are getting the output of other stations also into the station that is started first, we're using the following code,

private void ZmqStatusListener(string endPoint)
{
    using (Context context = new Context())
    {
        StatusPort = string.Empty;
        TestResultPort = string.Empty;
        using (Socket server = context.Socket(SocketType.REP))
        {
            try
            {
                if (isStatusContextActive == false || isPortChanged == true)
                {
                    server.Bind(endPoint);
                    isStatusContextActive = true;
                }
            }
            catch (ZMQ.Exception ex)
            {
                if (ex.Errno != 100)
                {
                    string IPCPort = _globalParameters.GlbParam.GlbParamIpcStartPort;
                    if (IPCPort == string.Empty)
                    {
                        IPCPort = "0";
                    }
                    if (endPoint == EditorConstants.PortAddress.PortPrefix + IPCPort)
                    {
                        StatusPort = endPoint;
                        TestReultError = EditorConstants.CommonMessageTypes.TestReultError + ex.Message + EditorConstants.CommonMessageTypes.StackTraceMessage + ex.StackTrace;
                    }
                    StopExecOfScript(default(object));
                    isCancelledtask = true;
                    ScriptStatusDesc = new ScriptStatusDesc()
                    {
                        Status = "Failed",
                        statusDescription = "Failed"
                    };
                }
            }
            while (true)
            {
                string message = server.Recv(Encoding.UTF8);
                UpdateTestResults(message);
                server.Send(" ACK", Encoding.UTF8);
                // if (message == "Test Passed")
                //break;
            }
        }
    }
}

and for testing purpose we're breaking the while loop in this code based on a test message we kept in the python script, then we are able to get the output in the respective station correctly but this way we can only run in a synchronous fashion which we don't want as we require to run the test stations in parallel and the while loop should not break as it should be listening for the response.

Thanks,
Abdul Mateen.