org.apache.qpid.jms
Class FailoverPolicy
java.lang.Object
org.apache.qpid.jms.FailoverPolicy
public class FailoverPolicy
- extends Object
FailoverPolicy
public FailoverPolicy(ConnectionURL connectionDetails,
AMQConnection conn)
FailoverPolicy
public FailoverPolicy(FailoverMethod method)
FailoverPolicy
public FailoverPolicy(FailoverMethod method,
int retries)
failoverAllowed
public boolean failoverAllowed()
attainedConnection
public void attainedConnection()
- Notification that connection was successful.
getCurrentBrokerDetails
public BrokerDetails getCurrentBrokerDetails()
getNextBrokerDetails
public BrokerDetails getNextBrokerDetails()
setBroker
public void setBroker(BrokerDetails broker)
addMethod
public void addMethod(FailoverMethod method)
setMethodRetries
public void setMethodRetries(int retries)
getCurrentMethod
public FailoverMethod getCurrentMethod()
toString
public String toString()
- Overrides:
toString
in class Object
Licensed to the Apache Software Foundation