Examples of assignClusterNode()

Examples of org.apache.s4.comm.topology.Assignment.assignClusterNode()

55
56
57
58
59
60
61
62
63
64
65
        bind(RemoteSenders.class).toInstance(Mockito.mock(RemoteSenders.class));
        bind(RemoteEmitters.class).toInstance(Mockito.mock(RemoteEmitters.class));
        bind(RemoteEmitterFactory.class).toInstance(Mockito.mock(RemoteEmitterFactory.class));
        bind(Clusters.class).toInstance(Mockito.mock(Clusters.class));
        Assignment mockedAssignment = Mockito.mock(Assignment.class);
        Mockito.when(mockedAssignment.assignClusterNode()).thenReturn(new ClusterNode(0, 0, "machine", "Task-0"));
        bind(Assignment.class).toInstance(mockedAssignment);
        Names.bindProperties(binder(), ImmutableMap.of("s4.cluster.name", "testCluster"));
    }

}
View Full Code Here

Examples of org.apache.s4.comm.topology.Assignment.assignClusterNode()

60
61
62
63
64
65
66
67
68
69
70
        bind(Clusters.class).toInstance(Mockito.mock(Clusters.class));
        Cluster mockedCluster = Mockito.mock(Cluster.class);
        Mockito.when(mockedCluster.getPhysicalCluster()).thenReturn(new PhysicalCluster(1));
        bind(Cluster.class).toInstance(mockedCluster);
        Assignment mockedAssignment = Mockito.mock(Assignment.class);
        Mockito.when(mockedAssignment.assignClusterNode()).thenReturn(new ClusterNode(0, 0, "machine", "Task-0"));
        bind(Assignment.class).toInstance(mockedAssignment);
        Names.bindProperties(binder(), ImmutableMap.of("s4.cluster.name", "testCluster", "s4.comm.timeout", "10000"));
        bind(Emitter.class).toInstance(Mockito.mock(Emitter.class));
        install(new FactoryModuleBuilder().implement(RemoteEmitter.class, Mockito.mock(RemoteEmitter.class).getClass())
                .build(RemoteEmitterFactory.class));
View Full Code Here

Examples of org.apache.s4.comm.topology.AssignmentFromZK.assignClusterNode()

45
46
47
48
49
50
51
52
53
54
55
        taskSetup.setup(clusterName, 10);
        String zookeeperAddress = "localhost:2181";
        for (int i = 0; i < 10; i++) {
            AssignmentFromZK assignmentFromZK = new AssignmentFromZK(
                    clusterName, zookeeperAddress, 30000, 30000);
            ClusterNode assignClusterNode = assignmentFromZK
                    .assignClusterNode();
            System.out.println(i+"-->"+assignClusterNode);
        }
        TopologyFromZK topologyFromZK=new TopologyFromZK(clusterName, zookeeperAddress, 30000, 30000);
        Thread.sleep(3000);
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.