#NEWLINE# def handle_message( self , body , message ) : #NEWLINE# #INDENT# args = ( body , ) #NEWLINE# kwargs = { #NEWLINE# #INDENT# #NEWLINE# #UNINDENT# } #NEWLINE# worker_ctx_cls = self . container . worker_ctx_cls #NEWLINE# context_data = self . unpack_message_headers ( worker_ctx_cls , message ) #NEWLINE# handle_result = partial ( self . handle_result , message ) #NEWLINE# try : #NEWLINE# #INDENT# self . container . spawn_worker ( self , args , kwargs , context_data = self , handle_result = handle_result ) #NEWLINE# #UNINDENT# except ContainerBeingKilled : #NEWLINE# #INDENT# self . queue_consumer . requeue_message ( message )