Package org.jumpmind.symmetric.service.impl

Class UpdateService

java.lang.Object

org.jumpmind.symmetric.service.impl.AbstractService

org.jumpmind.symmetric.service.impl.UpdateService

All Implemented Interfaces:

IService, IUpdateService

public class UpdateService
extends AbstractService
implements IUpdateService

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	checkUpdates
protected String	downloadUrl
protected ISymmetricEngine	engine
protected String	latestVersion
protected final long	MILLIS_AFTER_NODE_OFFLINE
protected final long	MILLIS_BETWEEN_CHECKS
protected boolean	sendUsage
protected Thread	sleepThread
protected boolean	stopped

Fields inherited from class org.jumpmind.symmetric.service.impl.AbstractService

log, parameterService, platform, sqlTemplate, sqlTemplateDirty, symmetricDialect, tablePrefix

Constructor Summary

Constructors

Constructor	Description
UpdateService(ISymmetricEngine engine)

Method Summary

Modifier and Type	Method	Description
protected void	addUsageProperties(Map<String,Object> prop)
void	checkForUpdates()
String	getDownloadUrl()
String	getLatestVersion()
protected byte[]	getPostData(Map<String,Object> prop)
protected Map<String,Object>	getProperties()
protected URL	getUpdateUrl()
void	init()
boolean	isNewVersionAvailable()
protected void	parseHeaders(HttpURLConnection conn)
protected void	parseResponse(HttpURLConnection conn)
protected void	postDataForVersion(URL url, byte[] postData)
void	stop()

Methods inherited from class org.jumpmind.symmetric.service.impl.AbstractService

assertNotNull, buildBatchOrderBy, buildBatchParams, buildBatchWhere, buildBatchWhereFromFilter, close, createSqlReplacementTokens, getJdbcTemplate, getParameterService, getSql, getSymmetricDialect, getTablePrefix, getTargetDialect, getTargetPlatform, getTargetPlatform, isCalledFromSymmetricAdminTool, isSet, isStreamClosedByClient, isSymmetricTable, logOnce, maxDate, readAcks, sendAck, setSqlMap, synchronize, toNodeIds, toNodeIds

Methods inherited from class java.lang.Object

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

Field Details

MILLIS_BETWEEN_CHECKS

protected final long MILLIS_BETWEEN_CHECKS

See Also:

• Constant Field Values

MILLIS_AFTER_NODE_OFFLINE

protected final long MILLIS_AFTER_NODE_OFFLINE

See Also:

• Constant Field Values

engine

protected ISymmetricEngine engine

sendUsage

protected boolean sendUsage

checkUpdates

protected boolean checkUpdates

latestVersion

protected String latestVersion

downloadUrl

protected String downloadUrl

sleepThread

protected Thread sleepThread

stopped

protected boolean stopped

Constructor Details

UpdateService

public UpdateService(ISymmetricEngine engine)

Method Details

init

public void init()

Specified by:

init in interface IUpdateService

checkForUpdates

public void checkForUpdates()

Specified by:

checkForUpdates in interface IUpdateService

getPostData

protected byte[] getPostData(Map<String,Object> prop)
                      throws UnsupportedEncodingException

Throws:

UnsupportedEncodingException

postDataForVersion

protected void postDataForVersion(URL url,
 byte[] postData)
                           throws IOException

Throws:

IOException

parseHeaders

protected void parseHeaders(HttpURLConnection conn)

parseResponse

protected void parseResponse(HttpURLConnection conn)
                      throws IOException

Throws:

IOException

getProperties

protected Map<String,Object> getProperties()

addUsageProperties

protected void addUsageProperties(Map<String,Object> prop)

getUpdateUrl

protected URL getUpdateUrl()
                    throws MalformedURLException

Throws:

MalformedURLException

isNewVersionAvailable

public boolean isNewVersionAvailable()

Specified by:

isNewVersionAvailable in interface IUpdateService

getLatestVersion

public String getLatestVersion()

Specified by:

getLatestVersion in interface IUpdateService

getDownloadUrl

public String getDownloadUrl()

Specified by:

getDownloadUrl in interface IUpdateService

stop

public void stop()

Specified by:

stop in interface IUpdateService