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.
|
HostAddress |
getClusterHostAddress() |
void |
reconnectFailedConnection(SearchFilter searchFilter)
Search a valid connection for failed one.
|
void |
retrieveAllEndpointsAndSet(Protocol protocol)
Retrieves the information necessary to add a new endpoint.
|
HostAddress |
searchByStartName(Protocol secondaryProtocol,
List<HostAddress> loopAddress)
Looks for the current master/writer instance via the secondary protocol if it is found within 3 attempts.
|
checkInitialConnection, checkWaitingConnection, connectedHosts, foundActiveMaster, foundActiveSecondary, handleFailLoop, initializeConnection, isMasterConnected, lockAndSwitchMaster, lockAndSwitchSecondary, preClose, preExecute, primaryFail, reconnect, removeListenerFromSchedulers, rePrepareOnSlave, secondaryFail, switchReadOnlyConnection
getFilterForFailedHost, getSecondaryHostFailNanos, handleFailover, hasHostFail, isMasterHostFailReconnect, isSecondaryHostFail, isSecondaryHostFailReconnect, resetMasterFailoverData, resetSecondaryFailoverData, setSecondaryHostFail
addToBlacklist, canRetryFailLoop, clearBlacklist, closeConnection, getBlacklistKeys, getCurrentProtocol, getLastQueryNanos, getMasterHostFailNanos, getProxy, getRetriesAllDown, getUrlParser, invoke, invoke, isAutoReconnect, isClosed, isExplicitClosed, isMasterHostFail, isQueryRelaunchable, isReadOnly, pingMasterProtocol, preAutoReconnect, relaunchOperation, removeFromBlacklist, resetOldsBlackListHosts, setMasterHostFail, setProxy, setSessionReadOnly, syncConnection, throwFailoverMessage
public AuroraListener(UrlParser urlParser) throws SQLException
urlParser
- connection informationsSQLException
- when connection string contain host with different clusterpublic HostAddress getClusterHostAddress()
public void reconnectFailedConnection(SearchFilter searchFilter) throws SQLException
reconnectFailedConnection
in interface Listener
reconnectFailedConnection
in class MastersSlavesListener
SQLException
- if a connection asked is not foundpublic void retrieveAllEndpointsAndSet(Protocol protocol) throws SQLException
protocol
- current protocol connected toSQLException
- if connection error occurpublic 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 © 2017. All rights reserved.