def on_message(self, message):
    'Callback for processing a P2P payload. Must be overridden by derived class.'
    raise NotImplementedError
Callback for processing a P2P payload. Must be overridden by derived class.
def on_message(self, message):
    
    raise NotImplementedError