public abstract class AbstractMastersSlavesListener extends AbstractMastersListener
Modifier and Type | Field and Description |
---|---|
protected AtomicReference<Protocol> |
waitNewMasterProtocol |
protected AtomicReference<Protocol> |
waitNewSecondaryProtocol |
currentConnectionAttempts, currentProtocol, currentReadOnlyAsked, explicitClosed, lastQueryNanos, lastRetry, proxy, urlParser
Modifier | Constructor and Description |
---|---|
protected |
AbstractMastersSlavesListener(UrlParser urlParser) |
Modifier and Type | Method and Description |
---|---|
abstract void |
foundActiveSecondary(Protocol newSecondaryProtocol) |
SearchFilter |
getFilterForFailedHost() |
long |
getSecondaryHostFailNanos() |
HandleErrorResult |
handleFailover(Method method,
Object[] args)
Handle failover on master or slave connection.
|
boolean |
hasHostFail() |
boolean |
isMasterHostFailReconnect() |
boolean |
isSecondaryHostFail() |
boolean |
isSecondaryHostFailReconnect() |
protected void |
resetMasterFailoverData() |
protected void |
resetSecondaryFailoverData() |
abstract HandleErrorResult |
secondaryFail(Method method,
Object[] args) |
boolean |
setSecondaryHostFail()
Set slave connection lost variables.
|
addToBlacklist, canRetryFailLoop, checkMasterStatus, clearBlacklist, closeConnection, getBlacklistKeys, getCurrentProtocol, getLastQueryNanos, getMasterHostFailNanos, getProxy, getRetriesAllDown, getUrlParser, handleFailLoop, initializeConnection, invoke, isAutoReconnect, isClosed, isExplicitClosed, isMasterHostFail, isQueryRelaunchable, isReadOnly, pingMasterProtocol, preAutoReconnect, preClose, preExecute, primaryFail, reconnect, reconnectFailedConnection, relaunchOperation, removeFromBlacklist, removeListenerFromSchedulers, resetOldsBlackListHosts, setMasterHostFail, setProxy, setSessionReadOnly, switchReadOnlyConnection, syncConnection, throwFailoverMessage
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
foundActiveMaster, isMasterConnected
protected AtomicReference<Protocol> waitNewSecondaryProtocol
protected AtomicReference<Protocol> waitNewMasterProtocol
protected AbstractMastersSlavesListener(UrlParser urlParser)
public HandleErrorResult handleFailover(Method method, Object[] args) throws Throwable
handleFailover
in interface Listener
handleFailover
in class AbstractMastersListener
method
- called methodargs
- methods parametersThrowable
- if method with parameters doesn't existprotected void resetMasterFailoverData()
resetMasterFailoverData
in class AbstractMastersListener
protected void resetSecondaryFailoverData()
public long getSecondaryHostFailNanos()
public boolean setSecondaryHostFail()
public boolean isSecondaryHostFail()
public boolean isSecondaryHostFailReconnect()
public boolean isMasterHostFailReconnect()
public boolean hasHostFail()
hasHostFail
in interface Listener
hasHostFail
in class AbstractMastersListener
public SearchFilter getFilterForFailedHost()
getFilterForFailedHost
in interface Listener
getFilterForFailedHost
in class AbstractMastersListener
public abstract HandleErrorResult secondaryFail(Method method, Object[] args) throws Throwable
Throwable
public abstract void foundActiveSecondary(Protocol newSecondaryProtocol) throws QueryException
QueryException
Copyright © 2016. All rights reserved.