com.sleepycat.je.rep.stream
Class FeederReplicaHandshake

java.lang.Object
  extended by com.sleepycat.je.rep.stream.FeederReplicaHandshake

public class FeederReplicaHandshake
extends 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
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
 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,
                        IOException,
                        BinaryProtocol.ProtocolException,
                        Feeder.ExitException
Executes the feeder side of the handshake.

Throws:
BinaryProtocol.ProtocolException
Feeder.ExitException
DatabaseException
IOException


Copyright (c) 2004-2012 Oracle. All rights reserved.