#NEWLINE# def register_json_consumer( self , queue_name , callback ) : #NEWLINE# #INDENT# def wrapped_callback( ch , method , properties , body ) : #NEWLINE# #INDENT# return callback ( ujson . loads ( body ) ) #NEWLINE# #UNINDENT# return self . register_consumer ( queue_name , wrapped_callback )