#NEWLINE# @ asyncio . coroutine #NEWLINE# def on_mqtt_packet_received( self , * args , **kwargs ) : #NEWLINE# #INDENT# packet = kwargs . get ( 'packet' ) #NEWLINE# session = kwargs . get ( 'session' , None ) #NEWLINE# if self . context . logger . isEnabledFor ( logging . DEBUG ) : #NEWLINE# #INDENT# if session : #NEWLINE# #INDENT# self . context . logger . debug ( ( '%s <-in-- %s' % ( session . client_id , repr ( packet ) ) ) ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# self . context . logger . debug ( ( '<-in-- %s' % repr ( packet ) ) )