Class AgentForwardedChannel

    • Field Detail

      • MESSAGE_POLL_FREQUENCY

        public static final java.lang.String MESSAGE_POLL_FREQUENCY
        Time to wait for new incoming messages before checking if the channel is still active
        See Also:
        Constant Field Values
      • messages

        private final java.util.Queue<Buffer> messages
      • receiveBuffer

        private final Buffer receiveBuffer
    • Constructor Detail

      • AgentForwardedChannel

        public AgentForwardedChannel​(java.lang.String channelType)
    • Method Detail

      • request

        protected Buffer request​(Buffer buffer)
                          throws java.io.IOException
        Throws:
        java.io.IOException
      • waitForMessageBuffer

        protected Buffer waitForMessageBuffer()
                                       throws java.io.IOException
        Throws:
        java.io.IOException
      • doOpen

        protected void doOpen()
                       throws java.io.IOException
        Specified by:
        doOpen in class AbstractClientChannel
        Throws:
        java.io.IOException
      • doWriteData

        protected void doWriteData​(byte[] data,
                                   int off,
                                   long len)
                            throws java.io.IOException
        Overrides:
        doWriteData in class AbstractClientChannel
        Throws:
        java.io.IOException