Class BioSender

java.lang.Object
org.apache.catalina.tribes.transport.AbstractSender
org.apache.catalina.tribes.transport.bio.BioSender
All Implemented Interfaces:
DataSender

@Deprecated public class BioSender extends AbstractSender
Deprecated.
This will be removed in Tomcat 10
Send cluster messages with only one socket. Ack and keep Alive Handling is supported
Since:
5.5.16
Author:
Peter Rossbach
  • Field Details

    • sm

      protected static final StringManager sm
      Deprecated.
      The string manager for this package.
    • ackbuf

      protected final XByteBuffer ackbuf
      Deprecated.
  • Constructor Details

    • BioSender

      public BioSender()
      Deprecated.
  • Method Details

    • connect

      public void connect() throws IOException
      Deprecated.
      Connect other cluster member receiver
      Throws:
      IOException - when an error occurs
      See Also:
    • disconnect

      public void disconnect()
      Deprecated.
      disconnect and close socket
      See Also:
    • sendMessage

      public void sendMessage(byte[] data, boolean waitForAck) throws IOException
      Deprecated.
      Send message.
      Parameters:
      data - The data to send
      waitForAck - Wait for an ack
      Throws:
      IOException - An IO error occurred sending the message
    • toString

      public String toString()
      Deprecated.
      Overrides:
      toString in class Object
    • openSocket

      protected void openSocket() throws IOException
      Deprecated.
      Open real socket and set time out when waitForAck is enabled is socket open return directly.
      Throws:
      IOException - Error opening socket
    • closeSocket

      protected void closeSocket()
      Deprecated.
      Close socket.
      See Also:
    • pushMessage

      protected void pushMessage(byte[] data, boolean reconnect, boolean waitForAck) throws IOException
      Deprecated.
      Push messages with only one socket at a time Wait for ack is needed and make auto retry when write message is failed. After sending error close and reopen socket again. After successful sending update stats WARNING: Subclasses must be very careful that only one thread call this pushMessage at once!!!
      Parameters:
      data - Data to send
      reconnect - Do a reconnect (close socket then reopen)
      waitForAck - Wait for an acknowledgement
      Throws:
      IOException - IO error writing data
      Since:
      5.5.10
      See Also:
    • waitForAck

      protected void waitForAck() throws IOException
      Deprecated.
      Wait for Acknowledgement from other server. FIXME Please, not wait only for three characters, better control that the wait ack message is correct.
      Throws:
      IOException - An IO error occurred