Revision c626e1d0
b/logic/dispatcher.py | ||
---|---|---|
36 | 36 |
handled in the dispatched functions. |
37 | 37 |
|
38 | 38 |
""" |
39 |
|
|
40 | 39 |
from django.core.management import setup_environ |
41 | 40 |
|
42 | 41 |
import sys |
... | ... | |
279 | 278 |
signal(SIGTERM, _exit_handler) |
280 | 279 |
signal(SIGINT, _exit_handler) |
281 | 280 |
|
281 |
num_processed = 0 |
|
282 | 282 |
while True: |
283 | 283 |
chan.wait() |
284 |
num_processed += 1 |
|
285 |
sys.stderr.write("Ignored %d messages\r" % num_processed) |
|
286 |
|
|
284 | 287 |
chan.basic_cancel(tag) |
285 | 288 |
chan.connection.close() |
286 | 289 |
|
Also available in: Unified diff