Package org.apache.karaf.cellar.core

Examples of org.apache.karaf.cellar.core.Node

21
22
23
24
25
26
27
28
29
30
*/
public class LocalGroupsCompleter extends GroupCompleterSupport {

    @Override
    protected boolean acceptsGroup(Group group) {
        Node node = groupManager.getNode();
        if (group.getMembers().contains(node))
            return true;
        else return false;
    }
View Full Code Here
21
22
23
24
25
26
27
28
29
30
*/
public class OtherGroupsCompleter extends GroupCompleterSupport {

    @Override
    protected boolean acceptsGroup(Group group) {
        Node node = groupManager.getNode();
        if (group.getMembers().contains(node))
            return false;
        else return true;
    }
View Full Code Here
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
        if (results == null || results.isEmpty()) {
            System.out.println("No result received within given timeout");
        } else {
            System.out.println(String.format(OUTPUT_FORMAT, "Node", "Status", "Event Handler"));
            for (Map.Entry<Node,ManageHandlersResult> handlersResultEntry : results.entrySet()) {
                Node node = handlersResultEntry.getKey();
                ManageHandlersResult result = handlersResultEntry.getValue();
                if (result != null && result.getHandlers() != null) {

                    for (Map.Entry<String,String>  handlerEntry: result.getHandlers().entrySet()) {
                        String handler =  handlerEntry.getKey();
                        String s = handlerEntry.getValue();
                        System.out.println(String.format(OUTPUT_FORMAT, node.getId(), s, handler));
                    }
                }
            }
        }
        return null;
View Full Code Here
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
    @Argument(index = 2, name = "interval", description = "The time in millis to wait between iterations", required = false, multiValued = false)
    Long interval = 1000L;

    @Override
    protected Object doExecute() throws Exception {
        Node node = clusterManager.findNodeById(nodeId);
        System.out.println("Pinging node :" + node.getId());
        for (int i = 1; i <= iterations; i++) {
            Long start = System.currentTimeMillis();
            Ping ping = new Ping(clusterManager.generateId());
            ping.setDestination(new HashSet(Arrays.asList(node)));
            executionContext.execute(ping);
            Long stop = System.currentTimeMillis();
            Long delay = stop - start;
            System.out.println(String.format("PING %s %s %sms", i, node.getId(), delay));
            Thread.sleep(interval);
        }
        return null;
    }
View Full Code Here
91
92
93
94
95
96
97
98
99
100
101
     * @param event
     */
    public void repositoryEvent(RepositoryEvent event) {
        if (event != null && event.getRepository() != null) {

            Node node = clusterManager.getNode();
            Set<Group> groups = groupManager.listLocalGroups();

            if (groups != null && !groups.isEmpty()) {
                for (Group group : groups) {
                    RemoteRepositoryEvent repositoryEvent = new RemoteRepositoryEvent(event.getRepository().getURI().toString(), event.getType());
View Full Code Here
79
80
81
82
83
84
85
86
87
88
89
            logger.error("Error reading group configuration");
        }
    }

    public Node getNode() {
        Node node = null;
        Cluster cluster = instance.getCluster();
        if (cluster != null) {
            Member member = cluster.getLocalMember();
            node = new HazelcastNode(member.getInetSocketAddress().getHostName(), member.getInetSocketAddress().getPort());
        }
View Full Code Here
105
106
107
108
109
110
111
112
113
114
115
        Group group = groupManager.findGroupByName(groupName);
        if (group == null) {
            throw new IllegalArgumentException("Cluster group " + groupName + " doesn't exist");
        }

        Node node = clusterManager.findNodeById(nodeId);
        if (node == null) {
            throw new IllegalArgumentException("Cluster node " + nodeId + " doesn't exist");
        }

        Set<Node> nodes = new HashSet<Node>();
View Full Code Here
127
128
129
130
131
132
133
134
135
136
137
        Group group = groupManager.findGroupByName(groupName);
        if (group == null) {
            throw new IllegalArgumentException("Cluster group " + groupName + " doesn't exist");
        }

        Node node = clusterManager.findNodeById(nodeId);
        if (node == null) {
            throw new IllegalArgumentException("Cluster node " + nodeId + " doesn't exist");
        }

        Set<Node> nodes = new HashSet<Node>();
View Full Code Here
57
58
59
60
61
62
63
64
65
66
67
    public void setExecutionContext(ExecutionContext executionContext) {
        this.executionContext = executionContext;
    }

    public long pingNode(String nodeId) throws Exception {
        Node node = clusterManager.findNodeById(nodeId);
        if (node == null) {
            throw new IllegalArgumentException("Cluster group " + nodeId + " doesn't exist");
        }
        Long start = System.currentTimeMillis();
        Ping ping = new Ping(clusterManager.generateId());
View Full Code Here
44
45
46
47
48
49
50
51
52
53
        createCellarChild("child1");
        Thread.sleep(DEFAULT_TIMEOUT);
        ClusterManager clusterManager = getOsgiService(ClusterManager.class);
        assertNotNull(clusterManager);

        Node localNode = clusterManager.getNode();
        Set<Node> nodes = clusterManager.listNodes();
        System.err.println(executeCommand("cluster:node-list"));
        assertTrue("There should be at least 2 cellar nodes running", 2 <= nodes.size());
    }
View Full Code Here
TOP

Related Classes of org.apache.karaf.cellar.core.Node

  • org.apache.karaf.cellar.core.control.ManageGroupCommandHandler
  • org.apache.karaf.cellar.core.shell.completer.LocalGroupsCompleter
  • org.apache.karaf.cellar.core.shell.completer.OtherGroupsCompleter
  • org.apache.karaf.cellar.core.shell.completers.LocalGroupsCompleter
  • org.apache.karaf.cellar.core.shell.completers.OtherGroupsCompleter
  • org.apache.karaf.cellar.features.LocalFeaturesListener
  • org.apache.karaf.cellar.hazelcast.HazelcastGroupManager
  • org.apache.karaf.cellar.itests.CellarChildNodesTest
  • org.apache.karaf.cellar.itests.CellarFeaturesTest
  • org.apache.karaf.cellar.itests.CellarGroupsTest
    • 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.