Package org.apache.geronimo.clustering

Examples of org.apache.geronimo.clustering.Node


    }

    public void testLeavingNodeTriggersLocalTrackerUnRegistration() throws Exception {
        recordStart();
       
        Node leavingNode = (Node) mock(Node.class);
        leavingNode.getName();
        String leavingNodeName = "leavingNode";
        modify().returnValue(leavingNodeName);

        localTracker.unregisterNetworkConnectorLocations(leavingNodeName);
       
View Full Code Here


        public void receive(ServiceSpaceLifecycleEvent event, Set<Peer> newHostingPeers) {
            LifecycleState state = event.getState();
            if (state == LifecycleState.STARTED) {
                Set<Node> newHostingNodes = mapToNodes(newHostingPeers);
                Node joiningNode = mapToNode(event.getHostingPeer());
                listener.onJoin(joiningNode, newHostingNodes);
            } else if (state == LifecycleState.STOPPED || state == LifecycleState.FAILED) {
                Set<Node> newHostingNodes = mapToNodes(newHostingPeers);
                Node leavingNode = mapToNode(event.getHostingPeer());
                listener.onLeave(leavingNode, newHostingNodes);
            }
        }
View Full Code Here

    }
   
    protected Set<Node> wrapAsNode(Collection<Peer> peers) {
        Set<Node> nodes = new HashSet<Node>();
        for (Peer peer : peers) {
            Node node = wrapAsNode(peer);
            nodes.add(node);
        }
        return nodes;
    }
View Full Code Here

        }
        return nodes;
    }

    protected Node wrapAsNode(Peer peer) {
        Node node = RemoteNode.retrieveOptionalAdaptor(peer);
        if (null == node) {
            node = newRemoteNode(peer);
        }
        return node;
    }
View Full Code Here

    }
   
    protected Set<Node> wrapAsNode(Collection<Peer> peers, boolean remove) {
        Set<Node> nodes = new HashSet<Node>();
        for (Peer peer : peers) {
            Node node = wrapAsNode(peer, remove);
            nodes.add(node);
        }
        return nodes;
    }
View Full Code Here

        }
        return nodes;
    }

    protected Node wrapAsNode(Peer peer, boolean remove) {
        Node node;
        synchronized (peerToNode) {
            if (remove) {
                node = peerToNode.remove(peer);
                if (null == node) {
                    throw new AssertionError("no node mapped to peer");
View Full Code Here

TOP

Related Classes of org.apache.geronimo.clustering.Node

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.