net.tomp2p.p2p.builder
Class DHTBuilder<K extends DHTBuilder<K>>

java.lang.Object
  net.tomp2p.p2p.builder.DHTBuilder<K>

Direct Known Subclasses:

AddBuilder, GetBuilder, ParallelRequestBuilder, PutBuilder, RemoveBuilder, SendBuilder

public abstract class DHTBuilder<K extends DHTBuilder<K>>
extends Object

Field Summary

static Number160	DEFAULT_DOMAIN
protected FutureCreator<FutureDHT>	defaultDirectReplication
protected boolean	directReplication
protected Number160	domainKey
protected static FutureDHT	FUTURE_DHT_SHUTDOWN
protected FutureChannelCreator	futureChannelCreator
protected FutureCreate<FutureDHT>	futureCreate
protected Number160	locationKey
protected boolean	manualCleanup
protected Peer	peer
protected boolean	protectDomain
protected int	refreshSeconds
protected RequestP2PConfiguration	requestP2PConfiguration
protected RoutingConfiguration	routingConfiguration
protected boolean	signMessage

Constructor Summary

DHTBuilder(Peer peer, Number160 locationKey)

Method Summary

FutureCreator<FutureDHT>	getDefaultDirectReplication()
Number160	getDomainKey()
FutureChannelCreator	getFutureChannelCreator()
FutureCreate<FutureDHT>	getFutureCreate()
int	getRefreshSeconds()
RequestP2PConfiguration	getRequestP2PConfiguration()
RoutingConfiguration	getRoutingConfiguration()
boolean	isDirectReplication()
boolean	isManualCleanup()
boolean	isProtectDomain()
boolean	isSignMessage()
protected void	preBuild(String name)
void	self(K self)
K	setDefaultDirectReplication(FutureCreator<FutureDHT> defaultDirectReplication)
K	setDirectReplication()
K	setDirectReplication(boolean directReplication)
K	setDomainKey(Number160 domainKey)
K	setFutureChannelCreator(FutureChannelCreator futureChannelCreator)
K	setFutureCreate(FutureCreate<FutureDHT> futureCreate)
K	setManualCleanup()
K	setManualCleanup(boolean isManualCleanup)
K	setProtectDomain()
K	setProtectDomain(boolean protectDomain)
K	setRefreshSeconds(int refreshSeconds)
K	setRequestP2PConfiguration(RequestP2PConfiguration requestP2PConfiguration)
K	setRoutingConfiguration(RoutingConfiguration routingConfiguration)
K	setSignMessage()
K	setSignMessage(boolean signMessage)
protected void	setupCancel(FutureCleanup futureCleanup, ScheduledFuture<?> future)
abstract FutureDHT	start()

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_DOMAIN

public static final Number160 DEFAULT_DOMAIN

FUTURE_DHT_SHUTDOWN

protected static final FutureDHT FUTURE_DHT_SHUTDOWN

peer

protected final Peer peer

locationKey

protected final Number160 locationKey

domainKey

protected Number160 domainKey

routingConfiguration

protected RoutingConfiguration routingConfiguration

requestP2PConfiguration

protected RequestP2PConfiguration requestP2PConfiguration

futureCreate

protected FutureCreate<FutureDHT> futureCreate

futureChannelCreator

protected FutureChannelCreator futureChannelCreator

defaultDirectReplication

protected FutureCreator<FutureDHT> defaultDirectReplication

refreshSeconds

protected int refreshSeconds

protectDomain

protected boolean protectDomain

signMessage

protected boolean signMessage

manualCleanup

protected boolean manualCleanup

directReplication

protected boolean directReplication

Constructor Detail

DHTBuilder

public DHTBuilder(Peer peer,
                  Number160 locationKey)

Method Detail

self

public void self(K self)

getDomainKey

public Number160 getDomainKey()

setDomainKey

public K setDomainKey(Number160 domainKey)

getRoutingConfiguration

public RoutingConfiguration getRoutingConfiguration()

setRoutingConfiguration

public K setRoutingConfiguration(RoutingConfiguration routingConfiguration)

getRequestP2PConfiguration

public RequestP2PConfiguration getRequestP2PConfiguration()

setRequestP2PConfiguration

public K setRequestP2PConfiguration(RequestP2PConfiguration requestP2PConfiguration)

getFutureCreate

public FutureCreate<FutureDHT> getFutureCreate()

setFutureCreate

public K setFutureCreate(FutureCreate<FutureDHT> futureCreate)

getFutureChannelCreator

public FutureChannelCreator getFutureChannelCreator()

setFutureChannelCreator

public K setFutureChannelCreator(FutureChannelCreator futureChannelCreator)

getRefreshSeconds

public int getRefreshSeconds()

setRefreshSeconds

public K setRefreshSeconds(int refreshSeconds)

getDefaultDirectReplication

public FutureCreator<FutureDHT> getDefaultDirectReplication()

setDefaultDirectReplication

public K setDefaultDirectReplication(FutureCreator<FutureDHT> defaultDirectReplication)

isProtectDomain

public boolean isProtectDomain()

setProtectDomain

public K setProtectDomain(boolean protectDomain)

setProtectDomain

public K setProtectDomain()

isSignMessage

public boolean isSignMessage()

setSignMessage

public K setSignMessage(boolean signMessage)

setSignMessage

public K setSignMessage()

isManualCleanup

public boolean isManualCleanup()

setManualCleanup

public K setManualCleanup(boolean isManualCleanup)

setManualCleanup

public K setManualCleanup()

isDirectReplication

public boolean isDirectReplication()

setDirectReplication

public K setDirectReplication(boolean directReplication)

setDirectReplication

public K setDirectReplication()

setupCancel

protected void setupCancel(FutureCleanup futureCleanup,
                           ScheduledFuture<?> future)

preBuild

protected void preBuild(String name)

start

public abstract FutureDHT start()