public interface Listener
FailoverProxy getProxy()
void setProxy(FailoverProxy proxy)
void initializeConnection() throws QueryException
QueryException
void preExecute() throws QueryException
QueryException
void preClose() throws SQLException
SQLException
void reconnectFailedConnection(SearchFilter filter) throws QueryException
QueryException
void switchReadOnlyConnection(Boolean readonly) throws QueryException
QueryException
HandleErrorResult primaryFail(Method method, Object[] args) throws Throwable
Throwable
HandleErrorResult handleFailover(Method method, Object[] args) throws Throwable
Throwable
void foundActiveMaster(Protocol protocol) throws QueryException
QueryException
Set<HostAddress> getBlacklistKeys()
void addToBlacklist(HostAddress hostAddress)
void removeFromBlacklist(HostAddress hostAddress)
void syncConnection(Protocol from, Protocol to) throws QueryException
QueryException
UrlParser getUrlParser()
void throwFailoverMessage(HostAddress failHostAddress, boolean wasMaster, QueryException queryException, boolean reconnected) throws QueryException
QueryException
boolean isAutoReconnect()
int getRetriesAllDown()
boolean isExplicitClosed()
void reconnect() throws QueryException
QueryException
boolean isReadOnly()
boolean isClosed()
Protocol getCurrentProtocol()
boolean hasHostFail()
boolean canRetryFailLoop()
SearchFilter getFilterForFailedHost()
boolean isMasterConnected()
boolean setMasterHostFail()
boolean isMasterHostFail()
long getLastQueryNanos()
boolean checkMasterStatus(SearchFilter searchFilter)
Copyright © 2016. All rights reserved.