public class ParallelRequestBuilder extends DHTBuilder<ParallelRequestBuilder>
DEFAULT_DOMAIN, defaultDirectReplication, directReplication, domainKey, FUTURE_DHT_SHUTDOWN, futureChannelCreator, futureCreate, locationKey, manualCleanup, peer, protectDomain, refreshSeconds, requestP2PConfiguration, routingConfiguration, signMessage
Constructor and Description |
---|
ParallelRequestBuilder(Peer peer,
Number160 locationKey) |
Modifier and Type | Method and Description |
---|---|
ParallelRequestBuilder |
add(PeerAddress peerAddress) |
DistributedHashTable.Operation |
getOperation() |
NavigableSet<PeerAddress> |
getQueue() |
boolean |
isCancelOnFinish() |
ParallelRequestBuilder |
setCancelOnFinish() |
ParallelRequestBuilder |
setCancelOnFinish(boolean cancelOnFinish) |
ParallelRequestBuilder |
setOperation(DistributedHashTable.Operation operation) |
ParallelRequestBuilder |
setQueue(NavigableSet<PeerAddress> queue) |
FutureDHT |
start() |
getDefaultDirectReplication, getDomainKey, getFutureChannelCreator, getFutureCreate, getRefreshSeconds, getRequestP2PConfiguration, getRoutingConfiguration, isDirectReplication, isManualCleanup, isProtectDomain, isSignMessage, preBuild, self, setDefaultDirectReplication, setDirectReplication, setDirectReplication, setDomainKey, setFutureChannelCreator, setFutureCreate, setManualCleanup, setManualCleanup, setProtectDomain, setProtectDomain, setRefreshSeconds, setRequestP2PConfiguration, setRoutingConfiguration, setSignMessage, setSignMessage, setupCancel
public NavigableSet<PeerAddress> getQueue()
public ParallelRequestBuilder setQueue(NavigableSet<PeerAddress> queue)
public ParallelRequestBuilder add(PeerAddress peerAddress)
public DistributedHashTable.Operation getOperation()
public ParallelRequestBuilder setOperation(DistributedHashTable.Operation operation)
public boolean isCancelOnFinish()
public ParallelRequestBuilder setCancelOnFinish()
public ParallelRequestBuilder setCancelOnFinish(boolean cancelOnFinish)
public FutureDHT start()
start
in class DHTBuilder<ParallelRequestBuilder>
Copyright © 2013. All Rights Reserved.