code: def send(self, task_path, args, kwargs):
          
          message = {
                  'task_path': task_path,
                  'capture_response': self.capture_response,
                  'response_id': self.response_id,
                  'args': args,
                  'kwargs': kwargs
              }
          self._send(message)
          return self
docs: Create the message object and pass it to the actual sender.