public abstract class AbstractOfflineDetectorService extends AbstractService implements IOfflineDetectorService
| Modifier and Type | Field and Description |
|---|---|
protected IExtensionService |
extensionService |
log, parameterService, platform, sqlTemplate, sqlTemplateDirty, symmetricDialect, tablePrefix| Constructor and Description |
|---|
AbstractOfflineDetectorService(IParameterService parameterService,
ISymmetricDialect symmetricDialect,
IExtensionService extensionService) |
| 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) |
assertNotNull, buildBatchWhere, close, createSqlReplacementTokens, createSqlReplacementTokens, getJdbcTemplate, getParameterService, getSql, getSymmetricDialect, getTablePrefix, getTargetDialect, getTargetPlatform, getTargetPlatform, isCalledFromSymmetricAdminTool, isSet, isStreamClosedByClient, isSymmetricTable, logOnce, maxDate, readAcks, sendAck, setSqlMap, synchronize, toNodeIds, toNodeIdsprotected IExtensionService extensionService
public AbstractOfflineDetectorService(IParameterService parameterService, ISymmetricDialect symmetricDialect, IExtensionService extensionService)
protected void fireOnline(Node remoteNode, RemoteNodeStatus status)
protected void fireOffline(java.lang.Exception exception,
Node remoteNode,
RemoteNodeStatus status)
protected boolean shouldLogTransportError(java.lang.String nodeId)
protected boolean isOffline(java.lang.Exception ex)
Exception was caused by an offline scenario.ex - The exception to check. Nested exception will also be checked.Node being offline.protected boolean isNotAuthenticated(java.lang.Exception ex)
protected boolean isAuthenticationExpired(java.lang.Exception ex)
protected boolean isBusy(java.lang.Exception ex)
protected boolean isServiceUnavailable(java.lang.Exception ex)
protected boolean isSyncDisabled(java.lang.Exception ex)
protected boolean isRegistrationRequired(java.lang.Exception ex)
protected boolean isRegistrationPending(java.lang.Exception ex)
protected boolean isRegistrationNotOpen(java.lang.Exception ex)
protected boolean isNoReservation(java.lang.Exception ex)
protected org.jumpmind.exception.HttpException getHttpException(java.lang.Exception ex)
protected java.lang.Throwable getRootCause(java.lang.Exception ex)