com.nhncorp.neptune.changelog.pipe
Class InitState

java.lang.Object
  com.nhncorp.neptune.changelog.pipe.InitState

All Implemented Interfaces:

InitStateTestIF

public class InitState
extends java.lang.Object
implements InitStateTestIF

Method Summary

void	clearWriteProcess(com.nhncorp.neptune.changelog.pipe.Pipe.Context ctx)
boolean	connectToNext(com.nhncorp.neptune.changelog.pipe.Pipe.Context ctx)
java.lang.String	getStateName()
void	init(com.nhncorp.neptune.changelog.pipe.Pipe.Context ctx)
static com.nhncorp.neptune.changelog.pipe.PipeState	instance()
int	processPipeConnection(com.nhncorp.neptune.changelog.pipe.Pipe.Context ctx, PipeConnectionInfo connInfo)
boolean	readFromNext(com.nhncorp.neptune.changelog.pipe.Pipe.Context ctx)
boolean	readFromPrev(com.nhncorp.neptune.changelog.pipe.Pipe.Context ctx)
boolean	writeToNext(com.nhncorp.neptune.changelog.pipe.Pipe.Context ctx)
boolean	writeToPrev(com.nhncorp.neptune.changelog.pipe.Pipe.Context ctx)

Methods inherited from class java.lang.Object

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

Method Detail

instance

public static com.nhncorp.neptune.changelog.pipe.PipeState instance()

init

public void init(com.nhncorp.neptune.changelog.pipe.Pipe.Context ctx)
          throws java.io.IOException

Throws:

java.io.IOException

readFromPrev

public boolean readFromPrev(com.nhncorp.neptune.changelog.pipe.Pipe.Context ctx)
                     throws java.io.IOException

Throws:

java.io.IOException

processPipeConnection

public int processPipeConnection(com.nhncorp.neptune.changelog.pipe.Pipe.Context ctx,
                                 PipeConnectionInfo connInfo)
                          throws java.io.IOException,
                                 UnmatchedLogException

Specified by:

processPipeConnection in interface InitStateTestIF

Throws:

java.io.IOException

UnmatchedLogException

connectToNext

public boolean connectToNext(com.nhncorp.neptune.changelog.pipe.Pipe.Context ctx)
                      throws java.io.IOException

Throws:

java.io.IOException

readFromNext

public boolean readFromNext(com.nhncorp.neptune.changelog.pipe.Pipe.Context ctx)
                     throws java.io.IOException

Throws:

java.io.IOException

writeToPrev

public boolean writeToPrev(com.nhncorp.neptune.changelog.pipe.Pipe.Context ctx)
                    throws java.io.IOException

Throws:

java.io.IOException

writeToNext

public boolean writeToNext(com.nhncorp.neptune.changelog.pipe.Pipe.Context ctx)
                    throws java.io.IOException

Throws:

java.io.IOException

clearWriteProcess

public void clearWriteProcess(com.nhncorp.neptune.changelog.pipe.Pipe.Context ctx)
                       throws java.io.IOException

Specified by:

clearWriteProcess in interface InitStateTestIF

Throws:

java.io.IOException

getStateName

public java.lang.String getStateName()