Revision cc92b70f snf-cyclades-app/synnefo/logic/management/commands/queue-retry.py
| b/snf-cyclades-app/synnefo/logic/management/commands/queue-retry.py | ||
|---|---|---|
| 43 | 43 |
help = "Resend messages from dead letter queues to original exchange""" |
| 44 | 44 |
|
| 45 | 45 |
option_list = BaseCommand.option_list + ( |
| 46 |
make_option('--keep-zombies',
|
|
| 47 |
action='store_true',
|
|
| 48 |
dest='keep_zombies',
|
|
| 49 |
default=False,
|
|
| 50 |
help="Do not remove messages that died more than one times"
|
|
| 51 |
), |
|
| 52 |
)
|
|
| 46 |
make_option(
|
|
| 47 |
'--keep-zombies',
|
|
| 48 |
action='store_true',
|
|
| 49 |
dest='keep_zombies',
|
|
| 50 |
default=False,
|
|
| 51 |
help="Do not remove messages that died more than one times"),
|
|
| 52 |
) |
|
| 53 | 53 |
|
| 54 | 54 |
def handle(self, *args, **options): |
| 55 | 55 |
verbose = (options["verbosity"] == "2") |
| ... | ... | |
| 97 | 97 |
headers = message['headers'] |
| 98 | 98 |
death = headers['x-death'][0] |
| 99 | 99 |
except KeyError: |
| 100 |
log.warning("Received message without death section %s. Removing..",
|
|
| 100 |
log.warning("Received message without death section %s."
|
|
| 101 |
"Removing..", |
|
| 101 | 102 |
message) |
| 102 | 103 |
self.client.basic_nack(message) |
| 103 | 104 |
|
Also available in: Unified diff