use correct queue for gather stage

2012-11-15 14:21:09 +00:00 · 2012-11-15 14:21:09 +00:00 · 202c9d9fcc
parent c9c1eb4848
commit 202c9d9fcc
1 changed files with 1 additions and 1 deletions
--- a/ckanext/harvest/commands/harvester.py
+++ b/ckanext/harvest/commands/harvester.py
@ -114,7 +114,7 @@ class Harvester(CkanCommand):
            from ckanext.harvest.queue import get_gather_consumer, gather_callback
            logging.getLogger('amqplib').setLevel(logging.INFO)
            consumer = get_gather_consumer()
-            for method, header, body in consumer.consume(queue='ckan.harvest.fetch'):
+            for method, header, body in consumer.consume(queue='ckan.harvest.gather'):
               gather_callback(consumer, method, header, body)
        elif cmd == 'fetch_consumer':
            import logging