Class BaseMessageSender

    • Field Detail

      • m_clientSocket

        protected java.net.Socket m_clientSocket
      • m_host

        private java.lang.String m_host
      • m_port

        private int m_port
      • m_ackLock

        protected java.lang.Object m_ackLock
      • m_requestStopReceiver

        private boolean m_requestStopReceiver
      • m_serverSocket

        private java.net.ServerSocket m_serverSocket
      • m_outStream

        protected java.io.OutputStream m_outStream
        Outgoing message stream.
      • m_outWriter

        private java.io.PrintWriter m_outWriter
        Used to send ACK and STOP
      • m_inStream

        protected volatile java.io.InputStream m_inStream
        Incoming message stream.
      • m_inReader

        protected volatile java.io.BufferedReader m_inReader
        Used to receive ACK and STOP
      • m_ack

        private boolean m_ack
      • m_serial

        private int m_serial
      • m_latestAck

        private java.lang.String m_latestAck
    • Constructor Detail

      • BaseMessageSender

        public BaseMessageSender​(java.lang.String host,
                                 int port,
                                 boolean ack)
    • Method Detail

      • connect

        public void connect()
                     throws java.io.IOException
        Starts the connection.
        Specified by:
        connect in interface IMessageSender
        Throws:
        org.testng.TestNGException - if an exception occurred while establishing the connection
        java.io.IOException
      • sendAdminMessage

        private void sendAdminMessage​(java.lang.String message)
      • initReceiver

        public void initReceiver()
                          throws java.net.SocketTimeoutException
        Description copied from interface: IMessageSender
        Initialize the receiver. the underlying socket server will be polling until a first client connect.
        Specified by:
        initReceiver in interface IMessageSender
        Throws:
        java.net.SocketTimeoutException
      • stopReceiver

        public void stopReceiver()
        Description copied from interface: IMessageSender
        Stop the receiver. it provides a way that allow the API invoker to stop the receiver, e.g. break from a dead while loop
        Specified by:
        stopReceiver in interface IMessageSender
      • closeQuietly

        private void closeQuietly​(java.io.Closeable c)
      • waitForAck

        protected void waitForAck()
      • p

        private static void p​(java.lang.String msg)