Interface FrameHandler

    • Method Detail

      • setTimeout

        void setTimeout​(int timeoutMs)
                 throws java.net.SocketException
        Set the underlying socket's read timeout in milliseconds, if applicable.
        Parameters:
        timeoutMs - The timeout in milliseconds
        Throws:
        java.net.SocketException
      • getTimeout

        int getTimeout()
                throws java.net.SocketException
        Get the underlying socket's read timeout in milliseconds.
        Returns:
        The timeout in milliseconds
        Throws:
        java.net.SocketException
      • sendHeader

        void sendHeader()
                 throws java.io.IOException
        Send the initial connection header, thus kickstarting the AMQP protocol version negotiation process and putting the underlying connection in a state such that the next layer of startup can proceed.
        Throws:
        java.io.IOException - if there is a problem accessing the connection
      • readFrame

        Frame readFrame()
                 throws java.io.IOException
        Read a Frame from the underlying data connection.
        Returns:
        an incoming Frame, or null if there is none
        Throws:
        java.io.IOException - if there is a problem accessing the connection
        java.net.SocketTimeoutException - if the underlying read times out
      • writeFrame

        void writeFrame​(Frame frame)
                 throws java.io.IOException
        Write a Frame to the underlying data connection.
        Parameters:
        frame - the Frame to transmit
        Throws:
        java.io.IOException - if there is a problem accessing the connection
      • flush

        void flush()
            throws java.io.IOException
        Flush the underlying data connection.
        Throws:
        java.io.IOException - if there is a problem accessing the connection
      • close

        void close()
        Close the underlying data connection (complaint not permitted).