Hi Jordan,

First of all, thanks a lot for all the great work on Curator! I have started using it and it is amazingly simplifying my code!

I have just ran into this issue recently that I am using a Distributed Queue, a Path Cache and a Distributed Double Barrier in my code, and having some difficulties. I'm trying to run everything with the test framework Curator provides and it seems like when I enter() the barrier in one of my objects the other one (that is using a different client) is also blocked.
Is there a way to have the Queue consumer object as well as Event listeners for the Path Cache start in new threads?

Many thanks,
Amir

+ Jordan (My apologies if this is not the right mailing list... I looked around and couldn't find a mailing list for Curator)

I was also wondering if there are examples on how to use Curator. I have been following the tests and I'm worried that I'm doing something wrong...

Many thanks,
Amir

On Mar 5, 2012, at 8:18 PM, Amirhossein Kiani wrote:

> Hi Jordan,
>
> First of all, thanks a lot for all the great work on Curator! I have started using it and it is amazingly simplifying my code!
>
> I have just ran into this issue recently that I am using a Distributed Queue, a Path Cache and a Distributed Double Barrier in my code, and having some difficulties. I'm trying to run everything with the test framework Curator provides and it seems like when I enter() the barrier in one of my objects the other one (that is using a different client) is also blocked.
> Is there a way to have the Queue consumer object as well as Event listeners for the Path Cache start in new threads?
>
> Many thanks,
> Amir

+ Jordan (My apologies if this is not the right mailing list... I looked around and couldn't find a mailing list for Curator)

Generally, Curator issues should go here:
   https://github.com/Netflix/curator/issues

But, I follow this list as well.

-JZ

________________________________________
From: Amirhossein Kiani [[EMAIL PROTECTED]]
Sent: Monday, March 05, 2012 9:07 PM
To: Jordan Zimmerman; [EMAIL PROTECTED]
Subject: Re: Are curator framework consumers single threaded?

+ Jordan (My apologies if this is not the right mailing list... I looked around and couldn't find a mailing list for Curator)

I was also wondering if there are examples on how to use Curator. I have been following the tests and I'm worried that I'm doing something wrong...

Many thanks,
Amir

On Mar 5, 2012, at 8:18 PM, Amirhossein Kiani wrote:

> Hi Jordan,
>
> First of all, thanks a lot for all the great work on Curator! I have started using it and it is amazingly simplifying my code!
>
> I have just ran into this issue recently that I am using a Distributed Queue, a Path Cache and a Distributed Double Barrier in my code, and having some difficulties. I'm trying to run everything with the test framework Curator provides and it seems like when I enter() the barrier in one of my objects the other one (that is using a different client) is also blocked.
> Is there a way to have the Queue consumer object as well as Event listeners for the Path Cache start in new threads?
>
> Many thanks,
> Amir

The ListenerContainer for PathChildrenCache allows you to pass an Executor along with your listener. So, that will give you the desired behavior. DistributedQueue is _supposed_ to allow this as well, but it looks like it doesn't. I view that as a bug. If you don't mind, please post an issue on this here:

https://github.com/Netflix/curator/issues

-JZ

________________________________________
From: Amirhossein Kiani [[EMAIL PROTECTED]]
Sent: Monday, March 05, 2012 8:18 PM
To: [EMAIL PROTECTED]
Subject: Are curator framework consumers single threaded?

Hi Jordan,

First of all, thanks a lot for all the great work on Curator! I have started using it and it is amazingly simplifying my code!

I have just ran into this issue recently that I am using a Distributed Queue, a Path Cache and a Distributed Double Barrier in my code, and having some difficulties. I'm trying to run everything with the test framework Curator provides and it seems like when I enter() the barrier in one of my objects the other one (that is using a different client) is also blocked.
Is there a way to have the Queue consumer object as well as Event listeners for the Path Cache start in new threads?

Many thanks,
Amir

>I was also wondering if there are examples on how to use Curator.
That's something I need to work on.

________________________________________
From: Amirhossein Kiani [[EMAIL PROTECTED]]
Sent: Monday, March 05, 2012 9:07 PM
To: Jordan Zimmerman; [EMAIL PROTECTED]
Subject: Re: Are curator framework consumers single threaded?

+ Jordan (My apologies if this is not the right mailing list... I looked around and couldn't find a mailing list for Curator)

I was also wondering if there are examples on how to use Curator. I have been following the tests and I'm worried that I'm doing something wrong...

Many thanks,
Amir

On Mar 5, 2012, at 8:18 PM, Amirhossein Kiani wrote:

> Hi Jordan,
>
> First of all, thanks a lot for all the great work on Curator! I have started using it and it is amazingly simplifying my code!
>
> I have just ran into this issue recently that I am using a Distributed Queue, a Path Cache and a Distributed Double Barrier in my code, and having some difficulties. I'm trying to run everything with the test framework Curator provides and it seems like when I enter() the barrier in one of my objects the other one (that is using a different client) is also blocked.
> Is there a way to have the Queue consumer object as well as Event listeners for the Path Cache start in new threads?
>
> Many thanks,
> Amir

Thanks JZ!  So for using the Executor in the PathChildrenCache, how does that work? Because previously I had the logic in the listener. Who will run the executor and how do I get the info about the changed node there?

Cheers,
Amir

On Mar 6, 2012, at 12:02 AM, Jordan Zimmerman wrote:

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

Amirhossein, let's take this to the Curator Issues page:

https://github.com/Netflix/curator/issues

On 3/6/12 10:59 AM, "Amirhossein Kiani" <[EMAIL PROTECTED]> wrote:

>Thanks JZ!  So for using the Executor in the PathChildrenCache, how does
>that work? Because previously I had the logic in the listener. Who will
>run the executor and how do I get the info about the changed node there?
>
>Cheers,
>Amir
>
>On Mar 6, 2012, at 12:02 AM, Jordan Zimmerman wrote:
>
>> The ListenerContainer for PathChildrenCache allows you to pass an
>>Executor along with your listener. So, that will give you the desired
>>behavior. DistributedQueue is _supposed_ to allow this as well, but it
>>looks like it doesn't. I view that as a bug. If you don't mind, please
>>post an issue on this here:
>>
>> https://github.com/Netflix/curator/issues
>>
>> -JZ
>>
>> ________________________________________
>> From: Amirhossein Kiani [[EMAIL PROTECTED]]
>> Sent: Monday, March 05, 2012 8:18 PM
>> To: [EMAIL PROTECTED]
>> Subject: Are curator framework consumers single threaded?
>>
>> Hi Jordan,
>>
>> First of all, thanks a lot for all the great work on Curator! I have
>>started using it and it is amazingly simplifying my code!
>>
>> I have just ran into this issue recently that I am using a Distributed
>>Queue, a Path Cache and a Distributed Double Barrier in my code, and
>>having some difficulties. I'm trying to run everything with the test
>>framework Curator provides and it seems like when I enter() the barrier
>>in one of my objects the other one (that is using a different client) is
>>also blocked.
>> Is there a way to have the Queue consumer object as well as Event
>>listeners for the Path Cache start in new threads?
>>
>> Many thanks,
>> Amir
>