Field Detail

• socket

  private final java.net.Socket socket

  Contains the Socket connection between the Replication master and the slave.

• objOutputStream

  private final java.io.ObjectOutputStream objOutputStream

  used to write message objects into the socket connection.

• objInputStream

  private final java.io.ObjectInputStream objInputStream

  used to read message objects sent in the socket connection.

Constructor Detail

• SocketConnection

  public SocketConnection​(java.net.Socket socket)
                   throws java.io.IOException

  Constructor creates the streams from the socket object passed as parameter.

  Parameters:

  socket - the Socket object that this class encapsulates.

  Throws:

  java.io.IOException - If an exception occurs while creating the streams from the socket object.

Method Detail

• readMessage

  public java.lang.Object readMessage()
                               throws java.lang.ClassNotFoundException,
                                      java.io.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:

  java.lang.ClassNotFoundException - Class of a serialized object cannot be found.

  java.io.IOException - if an exception occurs while reading from the stream.

• writeMessage

  public void writeMessage​(java.lang.Object message)
                    throws java.io.IOException

  Used to send the object messages across the socket conection.

  Parameters:

  message - the data to be written into the connection.

  Throws:

  java.io.IOException - if an exception occurs while writing into the stream.

• tearDown

  public void tearDown()
                throws java.io.IOException

  Closes the Socket and the object streams obtained from it.

  Throws:

  java.io.IOException - if an exception occurs while trying to close the socket or the streams.