code: def consume(self, msg):
          
          msg['body'] = crypto.sign(msg['body'], **self.hub.config)
          super(SigningRelayConsumer, self).consume(msg)
docs: Sign the message prior to sending the message.
  
          Args:
              msg (dict): The message to sign and relay.