Return-Path: 
 <user-return-2820-apmail-ignite-user-archive=ignite.apache.org@ignite.apache.org>
X-Original-To: apmail-ignite-user-archive@minotaur.apache.org
Delivered-To: apmail-ignite-user-archive@minotaur.apache.org
Received: from mail.apache.org (hermes.apache.org [140.211.11.3])
	by minotaur.apache.org (Postfix) with SMTP id CAF9B1851F
	for <apmail-ignite-user-archive@minotaur.apache.org>;
 Fri, 19 Feb 2016 22:18:41 +0000 (UTC)
Received: (qmail 92636 invoked by uid 500); 19 Feb 2016 22:18:41 -0000
Delivered-To: apmail-ignite-user-archive@ignite.apache.org
Received: (qmail 92595 invoked by uid 500); 19 Feb 2016 22:18:41 -0000
Mailing-List: contact user-help@ignite.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:user-help@ignite.apache.org>
List-Unsubscribe: <mailto:user-unsubscribe@ignite.apache.org>
List-Post: <mailto:user@ignite.apache.org>
List-Id: <user.ignite.apache.org>
Reply-To: user@ignite.apache.org
Delivered-To: mailing list user@ignite.apache.org
Received: (qmail 92585 invoked by uid 99); 19 Feb 2016 22:18:41 -0000
Received: from pnap-us-west-generic-nat.apache.org (HELO
 spamd4-us-west.apache.org) (209.188.14.142)
    by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 19 Feb 2016 22:18:41 +0000
Received: from localhost (localhost [127.0.0.1])
	by spamd4-us-west.apache.org (ASF Mail Server at spamd4-us-west.apache.org)
 with ESMTP id E7F23C0CC3
	for <user@ignite.apache.org>; Fri, 19 Feb 2016 22:18:40 +0000 (UTC)
X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org
X-Spam-Flag: NO
X-Spam-Score: 2.173
X-Spam-Level: **
X-Spam-Status: No, score=2.173 tagged_above=-999 required=6.31
	tests=[DKIM_ADSP_CUSTOM_MED=0.001, NML_ADSP_CUSTOM_MED=1.2,
	RCVD_IN_DNSWL_NONE=-0.0001, SPF_SOFTFAIL=0.972] autolearn=disabled
Received: from mx1-lw-us.apache.org ([10.40.0.8])
	by localhost (spamd4-us-west.apache.org [10.40.0.11]) (amavisd-new,
 port 10024)
	with ESMTP id yWw85APldF7N for <user@ignite.apache.org>;
	Fri, 19 Feb 2016 22:18:40 +0000 (UTC)
Received: from mbob.nabble.com (mbob.nabble.com [162.253.133.15])
	by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with ESMTP
 id 0C4225FAD4
	for <user@ignite.apache.org>; Fri, 19 Feb 2016 22:18:40 +0000 (UTC)
Received: from malf.nabble.com (unknown [162.253.133.59])
	by mbob.nabble.com (Postfix) with ESMTP id 52B35212032D
	for <user@ignite.apache.org>; Fri, 19 Feb 2016 14:11:44 -0800 (PST)
Date: Fri, 19 Feb 2016 14:06:38 -0800 (PST)
From: vkulichenko <valentin.kulichenko@gmail.com>
To: user@ignite.apache.org
Message-ID: <1455919598931-3104.post@n6.nabble.com>
In-Reply-To: 
 <CADgKzdyRQ1GtXzGGa4jCYM=__K2fL3XT2=jx6wrjfgjGN8oKXA@mail.gmail.com>
References: 
 <CADgKzdyRQ1GtXzGGa4jCYM=__K2fL3XT2=jx6wrjfgjGN8oKXA@mail.gmail.com>
Subject: Re: Wait for nodes to join the cluster
MIME-Version: 1.0
Content-Type: text/plain; charset=us-ascii
Content-Transfer-Encoding: 7bit

Hi Paolo,

You can register a discovery event listener and check the topology size
there:

ignite.events().localListen(new IgnitePredicate<Event>() {
    @Override public boolean apply(Event event) {
        if (ignite.cluster().nodes().size() >= 10) {
            // GO!
        }

        return true;
    }
}, EventType.EVT_NODE_JOINED);

Note that it's better to run execution asynchronously in this case, not to
block the Ignite's internal thread that processes events.

Let me know if this helps.

-Val



--
View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Wait-for-nodes-to-join-the-cluster-tp3103p3104.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.