Revision 960c15e0

b/logic/callbacks.py
207 207

  
208 208
def dummy_proc(message):
209 209
    try:
210
        msg = _logger.debug(message.body)
211
        _logger.debug("Msg (exchange:%s) ", msg)
210
        _logger.debug("Msg: %s" %(message.body))
212 211
        message.channel.basic_ack(message.delivery_tag)
213 212
    except Exception as e:
214
        _logger.error("Could not receive message %s" % e.message)
213
        _logger.exception("Could not receive message")
215 214
        pass
216 215

  
217 216
def _parse_json(data):
b/settings.d/15-queues.conf
56 56

  
57 57
    BINDINGS = [
58 58
    # Queue                     # Exchange          # RouteKey              # Handler
59
    (QUEUE_GANETI_EVENTS_OP,    EXCHANGE_GANETI,    'ganeti.*.event.op',    'update_db'),
60
    (QUEUE_GANETI_EVENTS_NET,   EXCHANGE_GANETI,    'ganeti.*.event.net',   'update_net'),
59
    (QUEUE_GANETI_EVENTS_OP,    EXCHANGE_GANETI,    DB_HANDLER_KEY_OP,    'update_db'),
60
    (QUEUE_GANETI_EVENTS_NET,   EXCHANGE_GANETI,    DB_HANDLER_KEY_NET,   'update_net'),
61 61
    (QUEUE_CRON_CREDITS,        EXCHANGE_CRON,      '*.credits.*',          'update_credits'),
62 62
    (QUEUE_EMAIL,               EXCHANGE_API,       '*.email.*',            'send_email'),
63 63
    (QUEUE_EMAIL,               EXCHANGE_CRON,      '*.email.*',            'send_email'),

Also available in: Unified diff