code: def _succeed(self, request_id, reply, duration):
          
          self.listeners.publish_command_success(
              duration, reply, self.name,
              request_id, self.sock_info.address, self.op_id)
docs: Publish a CommandSucceededEvent.