celery/celery — pull request #825 by dctrwatson (2012-06-27 08:22:07+00:00)
Title: Add filtering, queue migration and ack'ing to migrate tool

- Add ability limit to number of tasks to consume
- Configurable timeout to wait/poll for new tasks
- Ability to ack messages in source broker
- Filter what tasks to migrate (good for splitting up a queue)
- Choose which queues to migrate
- Migrate to different queue
- Never stop polling for new messages

#### Change queue name
celery migrate -Q celery:new_queue -a

#### Move tasks from one queue to another
celery migrate -Q celery:slow_tasks -T myapp.slow_task -a