qpid/java/client-api/src/main/java/org/apache/qpid/messaging/util/failover/DefaultFailoverStrategyFactory.java


1
2
3
4
5
6
7
8
9
10
11
12
13
14

package org.apache.qpid.messaging.util.failover;

import org.apache.qpid.messaging.internal.ConnectionInternal;
import org.apache.qpid.messaging.internal.FailoverStrategy;
import org.apache.qpid.messaging.internal.FailoverStrategyFactory;

public class DefaultFailoverStrategyFactory extends FailoverStrategyFactory
{
    @Override
    public FailoverStrategy getFailoverStrategy(ConnectionInternal con)
    {
        return new DefaultFailoverStrategy(con.getConnectionURL(), con.getConnectionOptions());
    }
}