Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
 Search Hadoop and all its subprojects:

Switch to Threaded View
Zookeeper >> mail # user >> Are curator framework consumers single threaded?


Copy link to this message
-
Re: Are curator framework consumers single threaded?
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
>
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB