Package org.jgroups.stack

Examples of org.jgroups.stack.GossipClient$Refresher


    }

    public void init() throws Exception {
        super.init();
        if(gossip_hosts != null) {
            client=new GossipClient(gossip_hosts, gossip_refresh);
            client.setSocketConnectionTimeout(sock_conn_timeout);
            client.setSocketReadTimeout(sock_read_timeout);
        }
        else if(gossip_host != null && gossip_port != 0) {
            client=new GossipClient(new IpAddress(InetAddress.getByName(gossip_host), gossip_port), gossip_refresh);
            client.setSocketConnectionTimeout(sock_conn_timeout);
            client.setSocketReadTimeout(sock_read_timeout);
        }
    }
View Full Code Here


    }

    public void init() throws Exception {
        super.init();
        if(gossip_hosts != null) {
            client=new GossipClient(gossip_hosts, gossip_refresh);
            client.setSocketConnectionTimeout(sock_conn_timeout);
            client.setSocketReadTimeout(sock_read_timeout);
        }
        else if(gossip_host != null && gossip_port != 0) {
            client=new GossipClient(new IpAddress(InetAddress.getByName(gossip_host), gossip_port), gossip_refresh);
            client.setSocketConnectionTimeout(sock_conn_timeout);
            client.setSocketReadTimeout(sock_read_timeout);
        }
    }
View Full Code Here


    public void start() throws Exception {
        super.start();
        if(gossip_client == null) {
            gossip_client=new GossipClient(initial_hosts, gossip_refresh_rate, sock_conn_timeout);
            gossip_client.setSocketReadTimeout(sock_read_timeout);
        }
    }
View Full Code Here

    }

    public void init() throws Exception {
        super.init();
        if(gossip_hosts != null) {
            client=new GossipClient(gossip_hosts, gossip_refresh);
            client.setSocketConnectionTimeout(sock_conn_timeout);
            client.setSocketReadTimeout(sock_read_timeout);
        }
        else if(gossip_host != null && gossip_port != 0) {
            client=new GossipClient(new IpAddress(InetAddress.getByName(gossip_host), gossip_port), gossip_refresh);
            client.setSocketConnectionTimeout(sock_conn_timeout);
            client.setSocketReadTimeout(sock_read_timeout);
        }
    }
View Full Code Here

    }

    public void init() throws Exception {
        super.init();
        if(gossip_hosts != null) {
            client=new GossipClient(gossip_hosts, gossip_refresh);
            client.setSocketConnectionTimeout(sock_conn_timeout);
            client.setSocketReadTimeout(sock_read_timeout);
        }
        else if(gossip_host != null && gossip_port != 0) {
            client=new GossipClient(new IpAddress(InetAddress.getByName(gossip_host), gossip_port), gossip_refresh);
            client.setSocketConnectionTimeout(sock_conn_timeout);
            client.setSocketReadTimeout(sock_read_timeout);
        }
    }
View Full Code Here


    public void start() throws Exception {
        super.start();
        if(gossip_client == null) {
            gossip_client=new GossipClient(initial_hosts, gossip_refresh_rate, sock_conn_timeout);
            gossip_client.setSocketReadTimeout(sock_read_timeout);
        }
    }
View Full Code Here

            props.remove("gossip_refresh");
        }

        if(gossip_host != null && gossip_port != 0) {
            try {
                client=new GossipClient(new IpAddress(InetAddress.getByName(gossip_host), gossip_port), gossip_refresh);
            }
            catch(Exception e) {
                if(log.isErrorEnabled()) log.error("creation of GossipClient failed, exception=" + e);
                return false; // will cause stack creation to abort
            }
View Full Code Here


    public void start() throws Exception {
        super.start();
        if(gossip_client == null) {
            gossip_client=new GossipClient(initial_hosts, gossip_refresh_rate, sock_conn_timeout);
            gossip_client.setSocketReadTimeout(sock_read_timeout);
        }
    }
View Full Code Here


    public void start() throws Exception {
        super.start();
        if(gossip_client == null)
            gossip_client=new GossipClient(initial_hosts, gossip_refresh_rate);
    }
View Full Code Here


    public void start() throws Exception {
        super.start();
        if(gossip_client == null)
            gossip_client=new GossipClient(initial_hosts, gossip_refresh_rate);
    }
View Full Code Here

TOP

Related Classes of org.jgroups.stack.GossipClient$Refresher

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.