Twisted service to manage polling a DirectoryQueue for new entries.
Install with setuptools:
$ easy_install -f http://www.psychofx.com/directory_queue_service/ DirectoryQueueService
Or download DirectoryQueueService-0.1.1dev_r8.egg
Also see source, wiki, tickets.
DirectoryQueueService is a Twisted IService that polls a DirectoryQueue and fires callbacks to process new queue items when they become available.
The DirectoryQueueService supports processing items concurrently, up to the concurrency level specified by the constructor parameter.
Note that the user-supplied callbacks must take care of the details of running asynchronously for actual concurrency to occur. See itemReadyCallback method.
© Chris Miles 2007. All rights reserved.