Fix error message when treat a message
This commit is contained in:
parent
f5c0913bf0
commit
c3c0b216d4
@ -18,6 +18,8 @@
|
|||||||
|
|
||||||
import queue
|
import queue
|
||||||
import threading
|
import threading
|
||||||
|
import traceback
|
||||||
|
import sys
|
||||||
|
|
||||||
from message import Message
|
from message import Message
|
||||||
|
|
||||||
@ -38,7 +40,7 @@ class Consumer(threading.Thread):
|
|||||||
msg.treat(self.context.hooks)
|
msg.treat(self.context.hooks)
|
||||||
except:
|
except:
|
||||||
print ("\033[1;31mERROR:\033[0m occurred during the "
|
print ("\033[1;31mERROR:\033[0m occurred during the "
|
||||||
"processing of the message: %s" % line)
|
"processing of the message: %s" % raw)
|
||||||
exc_type, exc_value, exc_traceback = sys.exc_info()
|
exc_type, exc_value, exc_traceback = sys.exc_info()
|
||||||
traceback.print_exception(exc_type, exc_value,
|
traceback.print_exception(exc_type, exc_value,
|
||||||
exc_traceback)
|
exc_traceback)
|
||||||
|
Loading…
x
Reference in New Issue
Block a user