Mailing-List: contact user-help@zookeeper.apache.org; run by ezmlm
Precedence: bulk
Reply-To: user@zookeeper.apache.org
Received-SPF: pass (nike.apache.org: domain of jzimmerman@netflix.com
 designates 69.53.237.162 as permitted sender)
DomainKey-Signature: a=rsa-sha1; q=dns; c=nofws;
  s=s1024;d=netflix.com;
  h=from:to:subject:date:message-id:references:in-reply-to:content-type
    :mime-version;
  b=cvnHZKhH2JIkBStXUn4wg1cs5hty83dED2dBhn5XhD0k6jj6pkMMlbze9cIDFdCqmzYvbyxP
    s9jagjFdNmssGlFNDiv0vB9rDApWM6btmE+fiX5a6wd4UHulDMC0ISwXPEidPERd69+mFliJ
    NcJnim1fT6CSeNJdMATNeOFpQT0=
From: Jordan Zimmerman <jzimmerman@netflix.com>
To: "user@zookeeper.apache.org" <user@zookeeper.apache.org>
Subject: RE: Are curator framework consumers single threaded?
Thread-Topic: Are curator framework consumers single threaded?
Thread-Index: AQHM+1BLhrcH4ek7y0CPYcbQtX55uJZc53QU
Date: Tue, 6 Mar 2012 08:02:04 +0000
Message-ID: <D740E813D74C0C4BAE1EA2F471274D34C42018@exmb107.corp.netflix.com>
References: 
 <CB791657.15599%jzimmerman@netflix.com>,<08BF7E6B-DCC9-48C8-BDCF-097D8A56C496@gmail.com>
In-Reply-To: <08BF7E6B-DCC9-48C8-BDCF-097D8A56C496@gmail.com>
Accept-Language: en-US
Content-Language: en-US
Content-Type: text/plain; charset="us-ascii"
Content-Transfer-Encoding: quoted-printable
MIME-Version: 1.0

The ListenerContainer for PathChildrenCache allows you to pass an Executor =
along with your listener. So, that will give you the desired behavior. Dist=
ributedQueue is _supposed_ to allow this as well, but it looks like it does=
n't. I view that as a bug. If you don't mind, please post an issue on this =
here:=0A=
=0A=
https://github.com/Netflix/curator/issues=0A=
=0A=
-JZ=0A=
=0A=
________________________________________=0A=
From: Amirhossein Kiani [amirhkiani@gmail.com]=0A=
Sent: Monday, March 05, 2012 8:18 PM=0A=
To: user@zookeeper.apache.org=0A=
Subject: Are curator framework consumers single threaded?=0A=
=0A=
Hi Jordan,=0A=
=0A=
First of all, thanks a lot for all the great work on Curator! I have starte=
d using it and it is amazingly simplifying my code!=0A=
=0A=
I have just ran into this issue recently that I am using a Distributed Queu=
e, a Path Cache and a Distributed Double Barrier in my code, and having som=
e difficulties. I'm trying to run everything with the test framework Curato=
r provides and it seems like when I enter() the barrier in one of my object=
s the other one (that is using a different client) is also blocked.=0A=
Is there a way to have the Queue consumer object as well as Event listeners=
 for the Path Cache start in new threads?=0A=
=0A=
Many thanks,=0A=
Amir=0A=