code: def notify_peer_message(self, message, sender_id):
          
          payload = message.SerializeToString()
          self._notify(
              "consensus_notifier_notify_peer_message",
              payload,
              len(payload),
              sender_id,
              len(sender_id))
docs: A new message was received from a peer