Examples of org.axonframework.eventhandling.ClusterSelector

        // and we initialize a simple cluster
        Cluster standardCluster = new SimpleCluster("simple");


        // to make sure Listeners are assigned to their respective cluster, we create a number of selectors that we
        // combine into a single ClusterSelector using a CompositeClusterSelector
        ClusterSelector clusterSelector = new CompositeClusterSelector(Arrays.<ClusterSelector>asList(
                // this one will accept
                new ClassNamePatternClusterSelector(Pattern.compile(".*Another.*"), asyncCluster),
                new DefaultClusterSelector(standardCluster)
        ));

        Cluster cluster1 = applicationContext.getBean("firstCluster", Cluster.class);
        Cluster cluster2 = applicationContext.getBean("defaultCluster", Cluster.class);
        Cluster cluster3 = applicationContext.getBean("replayingCluster", Cluster.class);
        Cluster cluster4 = applicationContext.getBean("defaultOrderedCluster", Cluster.class);
        Cluster cluster5 = applicationContext.getBean("customOrderedCluster", Cluster.class);
        ClusterSelector selector1 = applicationContext.getBean("firstCluster$selector", ClusterSelector.class);
        ClusterSelector selector2 = applicationContext.getBean("defaultCluster$defaultSelector", ClusterSelector.class);


        assertNotNull(cluster1);
        assertNotNull(cluster2);
        assertNotNull(cluster3);
        assertNotNull(cluster4);

Related Classes of org.axonframework.eventhandling.ClusterSelector

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.