#NEWLINE# def _on_message( self , client , userdata , msg ) : #NEWLINE# #INDENT# payload = { #NEWLINE# #INDENT# 'userdata' : userdata , #NEWLINE# 'topic' : msg . topic , #NEWLINE# 'message' : str ( client . payload ) , #NEWLINE# 'retain' : msg . retain , #NEWLINE# 'qos' : msg . qos , #NEWLINE# #UNINDENT# } #NEWLINE# self . _sensor_service . dispatch ( trigger = self . _trigger , payload = payload )