Class SocketConnection
- java.lang.Object
-
- org.apache.derby.impl.store.replication.net.SocketConnection
-
public class SocketConnection extends java.lang.Object
This class encapsulates aSocket
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 java.io.ObjectInputStream
objInputStream
used to read message objects sent in the socket connection.private java.io.ObjectOutputStream
objOutputStream
used to write message objects into the socket connection.private java.net.Socket
socket
Contains the Socket connection between the Replication master and the slave.
-
Constructor Summary
Constructors Constructor Description SocketConnection(java.net.Socket socket)
Constructor creates the streams from the socket object passed as parameter.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.lang.Object
readMessage()
Used to read the object messages that are sent.void
tearDown()
Closes theSocket
and the object streams obtained from it.void
writeMessage(java.lang.Object message)
Used to send the object messages across the socket conection.
-
-
-
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
- theSocket
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 theSocket
and the object streams obtained from it.- Throws:
java.io.IOException
- if an exception occurs while trying to close the socket or the streams.
-
-