Class SocketConnection

java.lang.Object
org.apache.derby.impl.store.replication.net.SocketConnection

public class SocketConnection extends Object
This class encapsulates a Socket connection and has methods that allow to read and write into the Object streams created from this connection.
  • Field Details

    • socket

      private final Socket socket
      Contains the Socket connection between the Replication master and the slave.
    • objOutputStream

      private final ObjectOutputStream objOutputStream
      used to write message objects into the socket connection.
    • objInputStream

      private final ObjectInputStream objInputStream
      used to read message objects sent in the socket connection.
  • Constructor Details

    • SocketConnection

      public SocketConnection(Socket socket) throws IOException
      Constructor creates the streams from the socket object passed as parameter.
      Parameters:
      socket - the Socket object that this class encapsulates.
      Throws:
      IOException - If an exception occurs while creating the streams from the socket object.
  • Method Details

    • readMessage

      public Object readMessage() throws ClassNotFoundException, IOException
      Used to read the object messages that are sent. waits on the input stream until a data is present that can be read and returns this data.
      Returns:
      the data read from the connection.
      Throws:
      ClassNotFoundException - Class of a serialized object cannot be found.
      IOException - if an exception occurs while reading from the stream.
    • writeMessage

      public void writeMessage(Object message) throws IOException
      Used to send the object messages across the socket conection.
      Parameters:
      message - the data to be written into the connection.
      Throws:
      IOException - if an exception occurs while writing into the stream.
    • tearDown

      public void tearDown() throws IOException
      Closes the Socket and the object streams obtained from it.
      Throws:
      IOException - if an exception occurs while trying to close the socket or the streams.