Package 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	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	Description
AbstractOfflineDetectorService()
AbstractOfflineDetectorService(IParameterService parameterService, ISymmetricDialect symmetricDialect, IExtensionService extensionService)

Method Summary

Modifier and Type	Method	Description
protected void	fireOffline(Exception exception, Node remoteNode, RemoteNodeStatus status)
protected void	fireOnline(Node remoteNode, RemoteNodeStatus status)
protected String	getExceptionMessage(Exception e)
protected HttpException	getHttpException(Exception ex)
protected boolean	is(Exception e, Class<?>... exceptions)
protected boolean	isAuthenticationExpired(Exception ex)
protected boolean	isBusy(Exception ex)
protected boolean	isDuplicateConnection(Exception ex)
protected boolean	isInitialLoadPending(Exception ex)
protected boolean	isNoReservation(Exception ex)
protected boolean	isNotAuthenticated(Exception ex)
protected boolean	isOffline(Exception ex)
protected boolean	isRegistrationNotOpen(Exception ex)
protected boolean	isRegistrationPending(Exception ex)
protected boolean	isRegistrationRequired(Exception ex)
protected boolean	isServiceNotReady(Exception ex)
protected boolean	isServiceUnavailable(Exception ex)
protected boolean	isSyncDisabled(Exception ex)
protected void	logTransportMessage(Node remoteNode, String message, Object... args)
protected boolean	shouldLogTransportError(String nodeId)

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

extensionService

protected IExtensionService extensionService

Constructor Details

AbstractOfflineDetectorService

public AbstractOfflineDetectorService()

AbstractOfflineDetectorService

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

Method Details

fireOnline

protected void fireOnline(Node remoteNode,
 RemoteNodeStatus status)

fireOffline

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

getExceptionMessage

protected String getExceptionMessage(Exception e)

logTransportMessage

protected void logTransportMessage(Node remoteNode,
 String message,
 Object... args)

shouldLogTransportError

protected boolean shouldLogTransportError(String nodeId)

isOffline

protected boolean isOffline(Exception ex)

isNotAuthenticated

protected boolean isNotAuthenticated(Exception ex)

isAuthenticationExpired

protected boolean isAuthenticationExpired(Exception ex)

isBusy

protected boolean isBusy(Exception ex)

isDuplicateConnection

protected boolean isDuplicateConnection(Exception ex)

isServiceUnavailable

protected boolean isServiceUnavailable(Exception ex)

isServiceNotReady

protected boolean isServiceNotReady(Exception ex)

isSyncDisabled

protected boolean isSyncDisabled(Exception ex)

isRegistrationRequired

protected boolean isRegistrationRequired(Exception ex)

isRegistrationPending

protected boolean isRegistrationPending(Exception ex)

isInitialLoadPending

protected boolean isInitialLoadPending(Exception ex)

isRegistrationNotOpen

protected boolean isRegistrationNotOpen(Exception ex)

isNoReservation

protected boolean isNoReservation(Exception ex)

is

protected boolean is(Exception e,
 Class<?>... exceptions)

getHttpException

protected HttpException getHttpException(Exception ex)