org.apache.derby.impl.store.replication.net
Class ReplicationMessageTransmit.MasterReceiverThread

java.lang.Object
  java.lang.Thread
      org.apache.derby.impl.store.replication.net.ReplicationMessageTransmit.MasterReceiverThread

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

ReplicationMessageTransmit

private class ReplicationMessageTransmit.MasterReceiverThread
extends java.lang.Thread

Thread that listens for messages from the slave. A separate thread listening for messages from the slave is needed because the slave may send messages to the master at any time, and these messages require immediate action.

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

private ReplicationMessage

pongMsg

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

ReplicationMessageTransmit.MasterReceiverThread(java.lang.String dbname)

Method Summary

private ReplicationMessage	readMessage() Used to read a replication message sent by the slave.
void	run()

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Field Detail

pongMsg

private final ReplicationMessage pongMsg

Constructor Detail

ReplicationMessageTransmit.MasterReceiverThread

ReplicationMessageTransmit.MasterReceiverThread(java.lang.String dbname)

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread

readMessage

private ReplicationMessage readMessage()
                                throws java.lang.ClassNotFoundException,
                                       java.io.IOException

Used to read a replication message sent by the slave. Hangs until a message is received from the slave

Returns:

the reply message.

Throws:

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

java.io.IOException - 1) if an exception occurs while reading from the stream. 2) if the connection handle is invalid.