public abstract class AbstractMastersListener extends Object implements Listener
Modifier and Type | Field and Description |
---|---|
protected AtomicInteger |
currentConnectionAttempts |
protected Protocol |
currentProtocol |
protected boolean |
currentReadOnlyAsked |
protected AtomicBoolean |
explicitClosed |
protected long |
lastQueryNanos |
protected long |
lastRetry |
protected FailoverProxy |
proxy |
UrlParser |
urlParser |
Modifier | Constructor and Description |
---|---|
protected |
AbstractMastersListener(UrlParser urlParser) |
Modifier and Type | Method and Description |
---|---|
void |
addToBlacklist(HostAddress hostAddress)
After a failover, put the hostAddress in a static list so the other connection will not take this host in account for a time.
|
boolean |
canRetryFailLoop() |
abstract boolean |
checkMasterStatus(SearchFilter searchFilter) |
static void |
clearBlacklist()
Clear blacklist data.
|
void |
closeConnection(Protocol protocol)
Utility to close existing connection.
|
Set<HostAddress> |
getBlacklistKeys() |
Protocol |
getCurrentProtocol() |
SearchFilter |
getFilterForFailedHost() |
long |
getLastQueryNanos() |
long |
getMasterHostFailNanos() |
FailoverProxy |
getProxy() |
int |
getRetriesAllDown() |
UrlParser |
getUrlParser() |
abstract void |
handleFailLoop() |
HandleErrorResult |
handleFailover(Method method,
Object[] args)
Call when a failover is detected on master connection.
|
boolean |
hasHostFail() |
void |
initializeConnection()
Initialize Listener.
|
Object |
invoke(Method method,
Object[] args) |
boolean |
isAutoReconnect() |
boolean |
isClosed() |
boolean |
isExplicitClosed() |
boolean |
isMasterHostFail() |
boolean |
isQueryRelaunchable(Method method,
Object[] args)
Check if query can be re-executed.
|
boolean |
isReadOnly() |
protected boolean |
pingMasterProtocol(Protocol protocol) |
protected void |
preAutoReconnect() |
abstract void |
preClose() |
abstract void |
preExecute() |
abstract HandleErrorResult |
primaryFail(Method method,
Object[] args) |
abstract void |
reconnect() |
abstract void |
reconnectFailedConnection(SearchFilter filter) |
HandleErrorResult |
relaunchOperation(Method method,
Object[] args)
After a failover that has bean done, relaunch the operation that was in progress.
|
void |
removeFromBlacklist(HostAddress hostAddress)
After a successfull connection, permit to remove a hostAddress from blacklist.
|
protected void |
removeListenerFromSchedulers() |
protected void |
resetMasterFailoverData() |
void |
resetOldsBlackListHosts()
Permit to remove Host to blacklist after loadBalanceBlacklistTimeout seconds.
|
boolean |
setMasterHostFail()
Set master fail variables.
|
void |
setProxy(FailoverProxy proxy) |
protected void |
setSessionReadOnly(boolean readOnly,
Protocol protocol) |
abstract void |
switchReadOnlyConnection(Boolean readonly) |
void |
syncConnection(Protocol from,
Protocol to)
When switching between 2 connections, report existing connection parameter to the new used connection.
|
void |
throwFailoverMessage(HostAddress failHostAddress,
boolean wasMaster,
QueryException queryException,
boolean reconnected)
Throw a human readable message after a failoverException.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
foundActiveMaster, isMasterConnected
public final UrlParser urlParser
protected AtomicInteger currentConnectionAttempts
protected volatile boolean currentReadOnlyAsked
protected Protocol currentProtocol
protected FailoverProxy proxy
protected long lastRetry
protected AtomicBoolean explicitClosed
protected long lastQueryNanos
protected AbstractMastersListener(UrlParser urlParser)
public void initializeConnection() throws QueryException
initializeConnection
in interface Listener
QueryException
- if any exception occur.protected void removeListenerFromSchedulers()
protected void preAutoReconnect() throws QueryException
QueryException
public FailoverProxy getProxy()
public void setProxy(FailoverProxy proxy)
public Set<HostAddress> getBlacklistKeys()
getBlacklistKeys
in interface Listener
public HandleErrorResult handleFailover(Method method, Object[] args) throws Throwable
handleFailover
in interface Listener
method
- called methodargs
- methods parametersThrowable
- when method and parameters does not exist.public void addToBlacklist(HostAddress hostAddress)
addToBlacklist
in interface Listener
hostAddress
- the HostAddress to add to blacklistpublic void removeFromBlacklist(HostAddress hostAddress)
removeFromBlacklist
in interface Listener
hostAddress
- the host address tho be remove of blacklistpublic void resetOldsBlackListHosts()
protected void resetMasterFailoverData()
protected void setSessionReadOnly(boolean readOnly, Protocol protocol) throws QueryException
QueryException
public abstract void handleFailLoop()
public Protocol getCurrentProtocol()
getCurrentProtocol
in interface Listener
public long getMasterHostFailNanos()
public boolean setMasterHostFail()
setMasterHostFail
in interface Listener
public boolean isMasterHostFail()
isMasterHostFail
in interface Listener
public boolean hasHostFail()
hasHostFail
in interface Listener
public SearchFilter getFilterForFailedHost()
getFilterForFailedHost
in interface Listener
public HandleErrorResult relaunchOperation(Method method, Object[] args) throws IllegalAccessException, InvocationTargetException
method
- the methode accessedargs
- the parametersIllegalAccessException
- if the initial call is not permitInvocationTargetException
- if there is any error relaunching initial methodpublic boolean isQueryRelaunchable(Method method, Object[] args)
method
- invoke methodargs
- invoke argumentspublic void syncConnection(Protocol from, Protocol to) throws QueryException
syncConnection
in interface Listener
from
- used connectionto
- will-be-current connectionQueryException
- if catalog cannot be setpublic boolean isReadOnly()
isReadOnly
in interface Listener
public boolean isExplicitClosed()
isExplicitClosed
in interface Listener
public int getRetriesAllDown()
getRetriesAllDown
in interface Listener
public boolean isAutoReconnect()
isAutoReconnect
in interface Listener
public UrlParser getUrlParser()
getUrlParser
in interface Listener
public abstract void preExecute() throws QueryException
preExecute
in interface Listener
QueryException
public abstract void preClose() throws SQLException
preClose
in interface Listener
SQLException
public abstract void reconnectFailedConnection(SearchFilter filter) throws QueryException
reconnectFailedConnection
in interface Listener
QueryException
public abstract void switchReadOnlyConnection(Boolean readonly) throws QueryException
switchReadOnlyConnection
in interface Listener
QueryException
public abstract HandleErrorResult primaryFail(Method method, Object[] args) throws Throwable
primaryFail
in interface Listener
Throwable
public void throwFailoverMessage(HostAddress failHostAddress, boolean wasMaster, QueryException queryException, boolean reconnected) throws QueryException
throwFailoverMessage
in interface Listener
failHostAddress
- failedHostAddresswasMaster
- was failed connection masterqueryException
- internal errorreconnected
- connection statusQueryException
- error with failover informationpublic boolean canRetryFailLoop()
canRetryFailLoop
in interface Listener
public abstract void reconnect() throws QueryException
reconnect
in interface Listener
QueryException
public abstract boolean checkMasterStatus(SearchFilter searchFilter)
checkMasterStatus
in interface Listener
public static void clearBlacklist()
public long getLastQueryNanos()
getLastQueryNanos
in interface Listener
protected boolean pingMasterProtocol(Protocol protocol)
public void closeConnection(Protocol protocol)
protocol
- connection to close.Copyright © 2016. All rights reserved.