Package com.mulesoft.connectors.a2a.internal.server.agent.repository

Interface TaskRepository

All Known Implementing Classes:
DefaultTaskRepository, NullTaskRepository
public interface TaskRepository

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    apply(String key, org.mule.runtime.core.api.util.func.CheckedRunnable function)
    Applies a function to a task within a transactional context, ensuring thread-safe access to the task data.
    void
    close()
     
    Optional<RepositoryItem>
    get(String key)
     
    void
    remove(String key)
     
    void
    upsert(String key, RepositoryItem item)
     

  • Method Details

    • upsert

      void upsert(String key, RepositoryItem item) throws org.mule.runtime.api.store.ObjectStoreException
      Throws:
      org.mule.runtime.api.store.ObjectStoreException

    • get

      Optional<RepositoryItem> get(String key) throws org.mule.runtime.api.exception.ObjectNotFoundException, org.mule.runtime.api.store.ObjectStoreException
      Throws:
      org.mule.runtime.api.exception.ObjectNotFoundException
      org.mule.runtime.api.store.ObjectStoreException

    • remove

      void remove(String key) throws org.mule.runtime.api.store.ObjectStoreException
      Throws:
      org.mule.runtime.api.store.ObjectStoreException

    • close

      void close()

    • apply

      void apply(String key, org.mule.runtime.core.api.util.func.CheckedRunnable function) throws org.mule.runtime.api.store.ObjectStoreException
      Applies a function to a task within a transactional context, ensuring thread-safe access to the task data. This method provides atomic operations on task data by executing the provided function within a synchronized block or transaction boundary.

      The apply method is designed to handle concurrent access scenarios where multiple operations might need to read, modify, and write task data atomically. It ensures that the entire operation (read-modify-write cycle) is executed as a single unit, preventing race conditions and data inconsistencies.

      Parameters:
      key - the unique identifier of the task to operate on. Must not be null or empty.
      function - the function to execute within the transactional context. The function will be executed with exclusive access to the specified task, ensuring thread safety. Must not be null.
      Throws:
      RuntimeException - if the function execution fails with an unchecked exception.
      org.mule.runtime.api.store.ObjectStoreException