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 Summary

    Fields
    Modifier and Type
    Field
    Description
    private final ObjectInputStream
    objInputStream
    used to read message objects sent in the socket connection.
    private final ObjectOutputStream
    objOutputStream
    used to write message objects into the socket connection.
    private final Socket
    socket
    Contains the Socket connection between the Replication master and the slave.

  • Constructor Summary

    Constructors
    Constructor
    Description
    SocketConnection(Socket socket)
    Constructor creates the streams from the socket object passed as parameter.

  • Method Summary

    Modifier and Type
    Method
    Description
    Object
    readMessage()
    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.
    void
    tearDown()
    Closes the Socket and the object streams obtained from it.
    void
    writeMessage(Object message)
    Used to send the object messages across the socket conection.

    Methods inherited from class Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • 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.