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

Class NullTaskRepository

java.lang.Object

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

All Implemented Interfaces:

TaskRepository

public class NullTaskRepository
extends Object
implements TaskRepository

Field Summary

Fields

Modifier and Type	Field	Description
static final NullTaskRepository	INSTANCE

Constructor Summary

Constructors

Constructor	Description
NullTaskRepository()

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

INSTANCE

public static final NullTaskRepository INSTANCE

Constructor Details

NullTaskRepository

public NullTaskRepository()

Method Details

upsert

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

Specified by:

upsert in interface TaskRepository

Throws:

org.mule.runtime.api.store.ObjectStoreException

get

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

Specified by:

get in interface TaskRepository

Throws:

org.mule.runtime.api.exception.ObjectNotFoundException

org.mule.runtime.api.store.ObjectStoreException

remove

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

Specified by:

remove in interface TaskRepository

Throws:

org.mule.runtime.api.store.ObjectStoreException

close

public void close()

Specified by:

close in interface TaskRepository

apply

public void apply(String key,
 org.mule.runtime.core.api.util.func.CheckedRunnable function)
           throws org.mule.runtime.api.store.ObjectStoreException

Description copied from interface: TaskRepository

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.

Specified by:

apply in interface TaskRepository

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:

org.mule.runtime.api.store.ObjectStoreException