org.jumpmind.symmetric.service.impl

Class AbstractOfflineDetectorService

java.lang.Object

org.jumpmind.symmetric.service.impl.AbstractService

org.jumpmind.symmetric.service.impl.AbstractOfflineDetectorService

All Implemented Interfaces:

IOfflineDetectorService, IService

Direct Known Subclasses:

FileSyncService, PullService, PushService

public abstract class AbstractOfflineDetectorService
extends AbstractService
implements IOfflineDetectorService

Abstract service that provides help methods for detecting offline status.

Field Summary

Fields

Modifier and Type	Field and Description
protected IExtensionService	extensionService

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

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

Constructor Summary

Constructors

Constructor and Description
AbstractOfflineDetectorService(IParameterService parameterService, ISymmetricDialect symmetricDialect, IExtensionService extensionService)

Method Summary

Modifier and Type	Method and Description
protected void	fireOffline(java.lang.Exception exception, Node remoteNode, RemoteNodeStatus status)
protected void	fireOnline(Node remoteNode, RemoteNodeStatus status)
protected org.jumpmind.exception.HttpException	getHttpException(java.lang.Exception ex)
protected java.lang.Throwable	getRootCause(java.lang.Exception ex)
protected boolean	isAuthenticationExpired(java.lang.Exception ex)
protected boolean	isBusy(java.lang.Exception ex)
protected boolean	isNoReservation(java.lang.Exception ex)
protected boolean	isNotAuthenticated(java.lang.Exception ex)
protected boolean	isOffline(java.lang.Exception ex) Check to see if the Exception was caused by an offline scenario.
protected boolean	isRegistrationNotOpen(java.lang.Exception ex)
protected boolean	isRegistrationPending(java.lang.Exception ex)
protected boolean	isRegistrationRequired(java.lang.Exception ex)
protected boolean	isServiceUnavailable(java.lang.Exception ex)
protected boolean	isSyncDisabled(java.lang.Exception ex)
protected boolean	shouldLogTransportError(java.lang.String nodeId)

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

assertNotNull, buildBatchWhere, close, createSqlReplacementTokens, 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 Detail

extensionService

protected IExtensionService extensionService

Constructor Detail

AbstractOfflineDetectorService

public AbstractOfflineDetectorService(IParameterService parameterService,
                                      ISymmetricDialect symmetricDialect,
                                      IExtensionService extensionService)

Method Detail

fireOnline

protected void fireOnline(Node remoteNode,
                          RemoteNodeStatus status)

fireOffline

protected void fireOffline(java.lang.Exception exception,
                           Node remoteNode,
                           RemoteNodeStatus status)

shouldLogTransportError

protected boolean shouldLogTransportError(java.lang.String nodeId)

isOffline

protected boolean isOffline(java.lang.Exception ex)

Check to see if the Exception was caused by an offline scenario.

Parameters:

ex - The exception to check. Nested exception will also be checked.

Returns:

true if this exception was caused by the Node being offline.

isNotAuthenticated

protected boolean isNotAuthenticated(java.lang.Exception ex)

isAuthenticationExpired

protected boolean isAuthenticationExpired(java.lang.Exception ex)

isBusy

protected boolean isBusy(java.lang.Exception ex)

isServiceUnavailable

protected boolean isServiceUnavailable(java.lang.Exception ex)

isSyncDisabled

protected boolean isSyncDisabled(java.lang.Exception ex)

isRegistrationRequired

protected boolean isRegistrationRequired(java.lang.Exception ex)

isRegistrationPending

protected boolean isRegistrationPending(java.lang.Exception ex)

isRegistrationNotOpen

protected boolean isRegistrationNotOpen(java.lang.Exception ex)

isNoReservation

protected boolean isNoReservation(java.lang.Exception ex)

getHttpException

protected org.jumpmind.exception.HttpException getHttpException(java.lang.Exception ex)

getRootCause

protected java.lang.Throwable getRootCause(java.lang.Exception ex)