com.sleepycat.je.rep.stream

Class FeederReplicaHandshake

java.lang.Object

com.sleepycat.je.rep.stream.FeederReplicaHandshake

public class FeederReplicaHandshake
extends java.lang.Object

Implements the Feeder side of the handshake between the Feeder and the Replica. The ReplicaFeederHandshake class takes care of the other side.

See Also:

FeederReplicaHandshake

Constructor Summary

Constructors

Constructor and Description
FeederReplicaHandshake(RepNode repNode, Feeder feeder, NamedChannel namedChannel) An instance of this class is created with each new handshake preceding the setting up of a connection.

Method Summary

Methods

Modifier and Type	Method and Description
Protocol	execute() Executes the feeder side of the handshake.
NameIdPair	getReplicaNameIdPair() Returns the replica node ID.
static void	setTestLogVersion(int testLogVersion)

Methods inherited from class java.lang.Object

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

Constructor Detail

FeederReplicaHandshake

public FeederReplicaHandshake(RepNode repNode,
                      Feeder feeder,
                      NamedChannel namedChannel)

An instance of this class is created with each new handshake preceding the setting up of a connection.

Parameters:

repNode - the replication node

feeder - the feeder instance

namedChannel - the channel to be used for the handshake

Method Detail

getReplicaNameIdPair

public NameIdPair getReplicaNameIdPair()

Returns the replica node ID. The returned value is only valid after the handshake has been executed.

Returns:

the replica node name id pair

setTestLogVersion

public static void setTestLogVersion(int testLogVersion)

execute

public Protocol execute()
                 throws DatabaseException,
                        java.io.IOException,
                        BinaryProtocol.ProtocolException,
                        Feeder.ExitException

Executes the feeder side of the handshake.

Throws:

BinaryProtocol.ProtocolException

Feeder.ExitException

DatabaseException

java.io.IOException