Class HttpCluster

java.lang.Object

one.nio.cluster.WeightCluster<HttpProvider>

one.nio.http.HttpCluster

All Implemented Interfaces:

Cluster<HttpProvider>

public class HttpCluster
extends WeightCluster<HttpProvider>

Nested Class Summary

Nested classes/interfaces inherited from class WeightCluster

WeightCluster.MonitoringTask, WeightCluster.ProviderSelector

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	logTimeouts
protected int	maxFailures
protected int	retries

Fields inherited from class WeightCluster

log, monitorTimeout, monitorTimer, providers, providerSelector

Constructor Summary

Constructors

Constructor	Description
HttpCluster()

Method Summary

Modifier and Type	Method	Description
void	configure(String configuration)
protected HttpProvider	createProvider(String provider)
protected Map<HttpProvider, Integer>	createProviders(String configuration)
Response	invoke(Request request)
void	setLogTimeouts(boolean logTimeouts)
void	setMaxFailures(int maxFailures)
void	setRetries(int retries)

Methods inherited from class WeightCluster

addProvider, addProviders, close, disableProvider, enableProvider, getMonitorTimeout, getProvider, getWeight, rebuildProviderSelector, removeProvider, removeProviders, replaceProviders, setMonitorTimeout

Methods inherited from class Object

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

Field Details

retries

protected volatile int retries

maxFailures

protected volatile int maxFailures

logTimeouts

protected volatile boolean logTimeouts

Constructor Details

HttpCluster

public HttpCluster()

Method Details

setRetries

public void setRetries(int retries)

setMaxFailures

public void setMaxFailures(int maxFailures)

setLogTimeouts

public void setLogTimeouts(boolean logTimeouts)

configure

public void configure(String configuration)

createProviders

protected Map<HttpProvider, Integer> createProviders(String configuration)

createProvider

protected HttpProvider createProvider(String provider)

invoke

public Response invoke(Request request)
                throws ServiceUnavailableException

Throws:

ServiceUnavailableException