public class FailoverPolicy extends Object
Constructor and Description |
---|
FailoverPolicy(ConnectionURL connectionDetails,
Connection conn) |
FailoverPolicy(FailoverMethod method) |
FailoverPolicy(FailoverMethod method,
int retries) |
Modifier and Type | Method and Description |
---|---|
void |
addMethod(FailoverMethod method) |
void |
attainedConnection()
Notification that connection was successful.
|
boolean |
failoverAllowed() |
BrokerDetails |
getCurrentBrokerDetails() |
FailoverMethod |
getCurrentMethod() |
BrokerDetails |
getNextBrokerDetails() |
void |
setBroker(BrokerDetails broker) |
void |
setMethodRetries(int retries) |
String |
toString() |
public FailoverPolicy(ConnectionURL connectionDetails, Connection conn)
public FailoverPolicy(FailoverMethod method)
public FailoverPolicy(FailoverMethod method, int retries)
public boolean failoverAllowed()
public void attainedConnection()
public BrokerDetails getCurrentBrokerDetails()
public BrokerDetails getNextBrokerDetails()
public void setBroker(BrokerDetails broker)
public void addMethod(FailoverMethod method)
public void setMethodRetries(int retries)
public FailoverMethod getCurrentMethod()
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.