Package org.apache.cxf.clustering

Examples of org.apache.cxf.clustering.FailoverFeature


        }
    }
   
    @Test   
    public void testMultipleAltAddresses() throws Exception {
        FailoverFeature feature = getFeature(Server.ADDRESS2, Server.ADDRESS3);
        strategyTest(Server.ADDRESS1, feature);
    }
View Full Code Here


        assertEquals("unexpected id", 123L, book.getId());
    }
   
   
    private FailoverFeature getFeature(String ...address) {
        FailoverFeature feature = new FailoverFeature();
        List<String> alternateAddresses = new ArrayList<String>();
        for (String s : address) {
            alternateAddresses.add(s);
        }
        SequentialStrategy strategy = new SequentialStrategy();
        strategy.setAlternateAddresses(alternateAddresses);
        feature.setStrategy(strategy);
       
        LoadDistributorTargetSelector selector = new LoadDistributorTargetSelector();
        selector.setFailover(false);
       
        feature.setTargetSelector(selector);
       
        return feature;
    }
View Full Code Here

        }
    }
   
    @Test   
    public void testSequentialStrategy() throws Exception {
        FailoverFeature feature =
            getFeature(false, false, Server.ADDRESS2, Server.ADDRESS3);
        strategyTest(Server.ADDRESS1, feature, Server.ADDRESS2, null, false, false, false);
    }
View Full Code Here

        strategyTest(Server.ADDRESS1, feature, Server.ADDRESS2, null, false, false, false);
    }
   
    @Test   
    public void testSequentialStrategyWithCustomTargetSelector() throws Exception {
        FailoverFeature feature =
            getFeature(true, false, Server.ADDRESS2, Server.ADDRESS3);
        strategyTest("resolver://info", feature, Server.ADDRESS3, null, false, false, false);
    }
View Full Code Here

        strategyTest("resolver://info", feature, Server.ADDRESS3, null, false, false, false);
    }
   
    @Test   
    public void testSequentialStrategyWithCustomTargetSelector2() throws Exception {
        FailoverFeature feature =
            getFeature(true, false, Server.ADDRESS2, Server.ADDRESS3);
        strategyTest("resolver://info", feature, Server.ADDRESS3, null, false, false, true);
    }
View Full Code Here

        strategyTest("resolver://info", feature, Server.ADDRESS3, null, false, false, true);
    }
   
    @Test
    public void testSequentialStrategyWebClient() throws Exception {
        FailoverFeature feature =
            getFeature(false, false, Server.ADDRESS2, Server.ADDRESS3);
        strategyTestWebClient(Server.ADDRESS1, feature, Server.ADDRESS2, null, false, false);
    }
View Full Code Here

        strategyTestWebClient(Server.ADDRESS1, feature, Server.ADDRESS2, null, false, false);
    }
   
    @Test
    public void testRandomStrategyWebClient() throws Exception {
        FailoverFeature feature =
            getFeature(false, true, Server.ADDRESS3, Server.ADDRESS2);
        strategyTestWebClient(Server.ADDRESS1, feature, Server.ADDRESS3, Server.ADDRESS2, false, true);
    }
View Full Code Here

        strategyTestWebClient(Server.ADDRESS1, feature, Server.ADDRESS3, Server.ADDRESS2, false, true);
    }
   
    @Test   
    public void testRandomStrategy() throws Exception {
        FailoverFeature feature =
            getFeature(false, true, Server.ADDRESS2, Server.ADDRESS3);
        strategyTest(Server.ADDRESS1, feature, Server.ADDRESS2, Server.ADDRESS3, false, true, true);
    }
View Full Code Here

        strategyTest(Server.ADDRESS1, feature, Server.ADDRESS2, Server.ADDRESS3, false, true, true);
    }
   
    @Test   
    public void testRandomStrategy2() throws Exception {
        FailoverFeature feature =
            getFeature(false, true, Server.ADDRESS2, Server.ADDRESS3);
        strategyTest(Server.ADDRESS1, feature, Server.ADDRESS2, Server.ADDRESS3, false, true, false);
    }
View Full Code Here

        strategyTest(Server.ADDRESS1, feature, Server.ADDRESS2, Server.ADDRESS3, false, true, false);
    }
   
    @Test   
    public void testSequentialStrategyWithDiffBaseAddresses() throws Exception {
        FailoverFeature feature =
            getFeature(false, false, Server.ADDRESS3, null);
        strategyTest(Server.ADDRESS1, feature, Server.ADDRESS3, Server.ADDRESS2, false, false, false);
    }
View Full Code Here

TOP

Related Classes of org.apache.cxf.clustering.FailoverFeature

Copyright © 2018 www.massapicom. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.