org.apache.derby.impl.store.replication.net
Class SocketConnection

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

public class SocketConnection
extends java.lang.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
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
SocketConnection(java.net.Socket socket)
          Constructor creates the streams from the socket object passed as parameter.
 
Method Summary
 java.lang.Object readMessage()
          Used to read the object messages that are sent.
 void tearDown()
          Closes the Socket and the object streams obtained from it.
 void writeMessage(java.lang.Object message)
          Used to send the object messages across the socket conection.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

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.

Built on Thu 2010-12-23 20:49:13+0000, from revision ???

Apache Derby V10.6 Internals - Copyright © 2004,2007 The Apache Software Foundation. All Rights Reserved.