org.jumpmind.symmetric.transport.http

Class HttpBandwidthUrlSelector

java.lang.Object

org.jumpmind.symmetric.transport.http.HttpBandwidthUrlSelector

All Implemented Interfaces:

org.jumpmind.extension.IBuiltInExtensionPoint, org.jumpmind.extension.IExtensionPoint, ISyncUrlExtension

public class HttpBandwidthUrlSelector
extends java.lang.Object
implements ISyncUrlExtension, org.jumpmind.extension.IBuiltInExtensionPoint

This ISyncUrlExtension is capable of measuring the bandwidth of a list of urls in order to select the one with the most bandwidth for use.

Use the URI notation of: ext://httpBandwidthUrlSelector?1=http://url.1.com&2=http://url.2.com¶m=value

Valid parameters are constants on this class that start with PARAM_. Any parameter that is a numeral will be designated a possible URL.

Field Summary

Fields

Modifier and Type	Field and Description
protected long	lastSampleTs
protected org.slf4j.Logger	log
static java.lang.String	PARAM_MAX_SAMPLE_DURATION
static java.lang.String	PARAM_PRELOAD_ONLY
static java.lang.String	PARAM_SAMPLE_SIZE
static java.lang.String	PARAM_SAMPLE_TTL

Constructor Summary

Constructors

Constructor and Description
HttpBandwidthUrlSelector(INodeService nodeService, IBandwidthService bandwidthService)

Method Summary

Modifier and Type	Method and Description
protected long	getMaxSampleDuration(java.util.Map<java.lang.String,java.lang.String> params)
protected java.util.Map<java.lang.String,java.lang.String>	getParameters(java.net.URI uri)
protected long	getSampleSize(java.util.Map<java.lang.String,java.lang.String> params)
protected long	getSampleTTL(java.util.Map<java.lang.String,java.lang.String> params)
protected java.util.List<org.jumpmind.symmetric.transport.http.HttpBandwidthUrlSelector.SyncUrl>	getUrls(java.util.Map<java.lang.String,java.lang.String> params)
protected boolean	isInitialLoadOnly(java.util.Map<java.lang.String,java.lang.String> params)
java.lang.String	resolveUrl(java.net.URI uri)
void	setDefaultMaxSampleDuration(long defaultMaxSampleDuration)
void	setDefaultSampleSize(long sampleSize)
void	setDefaultSampleTTL(long sampleTTL)

Methods inherited from class java.lang.Object

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

Field Detail

log

protected final org.slf4j.Logger log

PARAM_PRELOAD_ONLY

public static java.lang.String PARAM_PRELOAD_ONLY

PARAM_SAMPLE_SIZE

public static java.lang.String PARAM_SAMPLE_SIZE

PARAM_SAMPLE_TTL

public static java.lang.String PARAM_SAMPLE_TTL

PARAM_MAX_SAMPLE_DURATION

public static java.lang.String PARAM_MAX_SAMPLE_DURATION

lastSampleTs

protected long lastSampleTs

Constructor Detail

HttpBandwidthUrlSelector

public HttpBandwidthUrlSelector(INodeService nodeService,
                                IBandwidthService bandwidthService)

Method Detail

resolveUrl

public java.lang.String resolveUrl(java.net.URI uri)

Specified by:

resolveUrl in interface ISyncUrlExtension

getSampleSize

protected long getSampleSize(java.util.Map<java.lang.String,java.lang.String> params)

getMaxSampleDuration

protected long getMaxSampleDuration(java.util.Map<java.lang.String,java.lang.String> params)

getSampleTTL

protected long getSampleTTL(java.util.Map<java.lang.String,java.lang.String> params)

isInitialLoadOnly

protected boolean isInitialLoadOnly(java.util.Map<java.lang.String,java.lang.String> params)

getUrls

protected java.util.List<org.jumpmind.symmetric.transport.http.HttpBandwidthUrlSelector.SyncUrl> getUrls(java.util.Map<java.lang.String,java.lang.String> params)

getParameters

protected java.util.Map<java.lang.String,java.lang.String> getParameters(java.net.URI uri)

setDefaultSampleSize

public void setDefaultSampleSize(long sampleSize)

setDefaultSampleTTL

public void setDefaultSampleTTL(long sampleTTL)

setDefaultMaxSampleDuration

public void setDefaultMaxSampleDuration(long defaultMaxSampleDuration)