code: def publish_command_success(self, duration, reply, command_name,
                                  request_id, connection_id, op_id=None):
          
          if op_id is None:
              op_id = request_id
          event = CommandSucceededEvent(
              duration, reply, command_name, request_id, connection_id, op_id)
          for subscriber in self.__command_listeners:
              try:
                  subscriber.succeeded(event)
              except Exception:
                  _handle_exception()
docs: Publish a CommandSucceededEvent to all command listeners.
  
          :Parameters:
            - `duration`: The command duration as a datetime.timedelta.
            - `reply`: The server reply document.
            - `command_name`: The command name.
            - `request_id`: The request id for this operation.
            - `connection_id`: The address (host, port) of the server this
              command was sent to.
            - `op_id`: The (optional) operation id for this operation.