{
                try
                {
                    while (doWork)
                    {
                        // Create a TcpClient.
                        // Note, for this client to work you need to have a TcpServer 
                        // connected to the same address as specified by the server, port
                        // combination.
                        TcpClient client = new TcpClient(Server, Port);

                        // Translate the passed message into ASCII and store it as a Byte array.
                        Byte[] data = Encoding.UTF8.GetBytes(msg);
                        // Get a client stream for reading and writing.


                        NetworkStream stream = client.GetStream();

                        // Send the message to the connected TcpServer. 
                        stream.Write(data, 0, data.Length);

                        // Receive the TcpServer.response.
                        // Buffer to store the response bytes.
                        data = new Byte[256];


                        // String to store the response ASCII representation.

                        // Read the first batch of the TcpServer response bytes.
                        Int32 bytes = stream.Read(data, 0, data.Length);


                        value = System.Text.Encoding.ASCII.GetString(data, 0, bytes);
                        value = value.Substring(0, value.Length - 1);
                   
                           stream.Close();
                           client.Close();
                        if (value[0] == '$' && value.Length <= 13)
                        {
                            NpgsqlConnection conn_ = new NpgsqlConnection(("Server=" + list[0] + ";Port=" + list[1] + ";User Id=" + list[2] + ";Password=" + list[3] + ";Database=" + list[4] + ";Timeout=300; CONNECTIONLIFETIME=300; CommandTimeout = 300 "));
                            if (conn_.State == System.Data.ConnectionState.Closed) conn_.Open();
                            if (ParseGlob != "") Mystr = ("INSERT INTO " + list[5] + "(\"F_TagName_ID\"," + list[9] + ",\"F_Date\")  VALUES (" + IdCom.ToString() + ",(SELECT * FROM " + ParseGlob + "(\'" + value + "\')),\'" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + "\'   )");
                            else Mystr = ("INSERT INTO " + list[5] + "(\"F_TagName_ID\"," + list[9] + ",\"F_Date\")  VALUES (" + IdCom.ToString() + ",\'" + value + "\',\'" + DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") + "\'   )");
                            logger.Trace(Mystr);

                            NpgsqlCommand command = new NpgsqlCommand(Mystr, conn_);
                            command.CommandTimeout = 20;
                            int rowsaffected;
                            try
                            {
                                rowsaffected = command.ExecuteNonQuery();
                            }
                            catch (Exception msg2)
                            {
                                logger.Trace(msg2);
                            }
                            if (conn_.State == System.Data.ConnectionState.Open)
                                conn_.Close();
                            wh.WaitOne();
                        }
                        else
                        {
                            logger.Debug("port_DataReceived " + value);
                            value = "";
                            return;
                        }
                    }
                }
                catch (Exception msg)
                {
                    logger.Error(msg);
                    return;
                }
            }