public class AuroraListener extends MastersSlavesListener
masterProtocol, secondaryProtocol
waitNewMasterProtocol, waitNewSecondaryProtocol
currentConnectionAttempts, currentProtocol, currentReadOnlyAsked, explicitClosed, lastQueryNanos, lastRetry, proxy, urlParser
Constructor and Description |
---|
AuroraListener(UrlParser urlParser)
Constructor for Aurora.
|
Modifier and Type | Method and Description |
---|---|
boolean |
checkMasterStatus(SearchFilter searchFilter)
Check master status.
|
void |
reconnectFailedConnection(SearchFilter searchFilter)
Search a valid connection for failed one.
|
HostAddress |
searchByStartName(Protocol secondaryProtocol,
List<HostAddress> loopAddress)
Aurora replica doesn't have the master endpoint but the master instance name.
|
checkInitialConnection, checkWaitingConnection, foundActiveMaster, foundActiveSecondary, handleFailLoop, initializeConnection, isMasterConnected, lockAndSwitchMaster, lockAndSwitchSecondary, preClose, preExecute, primaryFail, reconnect, removeListenerFromSchedulers, secondaryFail, switchReadOnlyConnection
getFilterForFailedHost, getSecondaryHostFailNanos, handleFailover, hasHostFail, isMasterHostFailReconnect, isSecondaryHostFail, isSecondaryHostFailReconnect, resetMasterFailoverData, resetSecondaryFailoverData, setSecondaryHostFail
addToBlacklist, canRetryFailLoop, clearBlacklist, closeConnection, getBlacklistKeys, getCurrentProtocol, getLastQueryNanos, getMasterHostFailNanos, getProxy, getRetriesAllDown, getUrlParser, invoke, isAutoReconnect, isClosed, isExplicitClosed, isMasterHostFail, isQueryRelaunchable, isReadOnly, pingMasterProtocol, preAutoReconnect, relaunchOperation, removeFromBlacklist, resetOldsBlackListHosts, setMasterHostFail, setProxy, setSessionReadOnly, syncConnection, throwFailoverMessage
public AuroraListener(UrlParser urlParser)
urlParser
- connection informationspublic void reconnectFailedConnection(SearchFilter searchFilter) throws QueryException
reconnectFailedConnection
in interface Listener
reconnectFailedConnection
in class MastersSlavesListener
QueryException
- if a connection asked is not foundpublic HostAddress searchByStartName(Protocol secondaryProtocol, List<HostAddress> loopAddress)
secondaryProtocol
- the current secondary protocolloopAddress
- list of possible hostspublic boolean checkMasterStatus(SearchFilter searchFilter)
MastersSlavesListener
checkMasterStatus
in interface Listener
checkMasterStatus
in class MastersSlavesListener
searchFilter
- search filterCopyright © 2016. All rights reserved.