Catch and report if json parsing fails - using the reserved ':message…

… => ' param in a process will do this :(

RuoteAMQP/participant.py

@@ -62,7 +62,16 @@ def __init__(self, ruote_queue,
      def workitem_callback(self, msg):
           "This is where a workitem message is handled"
 
-          self.workitem = Workitem(msg.body)
+          try:
+               self.workitem = Workitem(msg.body)
+          except ValueError, e:
+               print "Exception decoding incoming json"
+               print '-'*60
+               print msg.body
+               print '-'*60
+               print "Note: Now re-raising exception"
+               raise e
+
           try:
                self.consume()
           except Exception, e: