Commit c9b04b62 authored by Federico Sismondi's avatar Federico Sismondi

minor changes

parent 59576e5d
...@@ -10,7 +10,7 @@ try: ...@@ -10,7 +10,7 @@ try:
except: except:
from .messages import * from .messages import *
VERSION = '0.0.8' VERSION = '0.0.9'
AMQP_EXCHANGE = 'amq.topic' AMQP_EXCHANGE = 'amq.topic'
...@@ -59,8 +59,8 @@ class AmqpListener(threading.Thread): ...@@ -59,8 +59,8 @@ class AmqpListener(threading.Thread):
@classmethod @classmethod
def default_message_handler(cls, message_as_dict): def default_message_handler(cls, message_as_dict):
clean_dict = dict((k, v) for k, v in message_as_dict.items() if v) clean_dict = dict((k, v) for k, v in message_as_dict.items() if v)
print('-'*120) print('-' * 120)
print(' %s : %s *' %('routing_key',clean_dict.pop('routing_key'))) print('%s : %s' % ('routing_key', clean_dict.pop('routing_key')))
print('-' * 120) print('-' * 120)
print(json.dumps(clean_dict, indent=4, sort_keys=True)) print(json.dumps(clean_dict, indent=4, sort_keys=True))
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment