Revision d5470cdd logic/dispatcher.py
| b/logic/dispatcher.py | ||
|---|---|---|
| 190 | 190 |
default=False, dest="purge_exchanges", |
| 191 | 191 |
help="Remove all exchanges. Implies deleting all queues \ |
| 192 | 192 |
first (DANGEROUS!)") |
| 193 |
parser.add_option("--drain-queue", dest="queue",
|
|
| 193 |
parser.add_option("--drain-queue", dest="drain_queue",
|
|
| 194 | 194 |
help="Strips a queue from all outstanding messages") |
| 195 | 195 |
|
| 196 | 196 |
return parser.parse_args(args) |
| ... | ... | |
| 325 | 325 |
purge_exchanges() |
| 326 | 326 |
return |
| 327 | 327 |
|
| 328 |
if opts.clean_queue:
|
|
| 329 |
drain_queue(opts.queue) |
|
| 328 |
if opts.drain_queue:
|
|
| 329 |
drain_queue(opts.drain_queue)
|
|
| 330 | 330 |
return |
| 331 | 331 |
|
| 332 | 332 |
# Debug mode, process messages without spawning workers |
Also available in: Unified diff