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

Class DefaultTaskStoreServiceImpl

java.lang.Object

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

All Implemented Interfaces:

TaskStoreService

public class DefaultTaskStoreServiceImpl
extends Object
implements TaskStoreService

Constructor Summary

Constructors

Constructor	Description
DefaultTaskStoreServiceImpl(TaskRepository taskRepository, A2ASerializer a2ASerializer)

Method Summary

Modifier and Type	Method	Description
void	clearPushNotificationConfigs(String taskId)
void	create(String taskId, String contextId, StreamingContext context)	Create new entry for provided taskId and contextId in object store along with StreamingContext
void	deletePushNotificationConfigs(String taskId, String pushNotificationConfigId)
String	getTask(String taskId, int historyLength)	Get task latest status with history.
void	updateHistory(String taskId, String historyObj)	Update the taskRepository item history list with the new history message.
void	updatePushNotificationConfig(String taskId, EffectivePushNotificationConfig config)
void	updateTask(String taskId, String taskObj)	Update the taskRepository item task string with the updated task.
void	upsert(String taskId, String contextId)	Create new entry for provided taskId and contextId in object store

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultTaskStoreServiceImpl

public DefaultTaskStoreServiceImpl(TaskRepository taskRepository,
 A2ASerializer a2ASerializer)

Method Details

updateHistory

public void updateHistory(String taskId,
 String historyObj)
                   throws org.mule.runtime.api.store.ObjectStoreException

Update the taskRepository item history list with the new history message.

Specified by:

updateHistory in interface TaskStoreService

Throws:

org.mule.runtime.api.store.ObjectStoreException

updateTask

public void updateTask(String taskId,
 String taskObj)
                throws org.mule.runtime.api.store.ObjectStoreException

Update the taskRepository item task string with the updated task.

Specified by:

updateTask in interface TaskStoreService

Throws:

org.mule.runtime.api.store.ObjectStoreException

getTask

public String getTask(String taskId,
 int historyLength)
               throws org.mule.runtime.api.store.ObjectStoreException

Get task latest status with history.

Specified by:

getTask in interface TaskStoreService

Throws:

org.mule.runtime.api.store.ObjectStoreException

updatePushNotificationConfig

public void updatePushNotificationConfig(String taskId,
 EffectivePushNotificationConfig config)
                                  throws org.mule.runtime.api.store.ObjectStoreException

Specified by:

updatePushNotificationConfig in interface TaskStoreService

Throws:

org.mule.runtime.api.store.ObjectStoreException

clearPushNotificationConfigs

public void clearPushNotificationConfigs(String taskId)
                                  throws org.mule.runtime.api.store.ObjectStoreException

Specified by:

clearPushNotificationConfigs in interface TaskStoreService

Throws:

org.mule.runtime.api.store.ObjectStoreException

deletePushNotificationConfigs

public void deletePushNotificationConfigs(String taskId,
 String pushNotificationConfigId)
                                   throws org.mule.runtime.api.store.ObjectStoreException

Specified by:

deletePushNotificationConfigs in interface TaskStoreService

Throws:

org.mule.runtime.api.store.ObjectStoreException

upsert

public void upsert(String taskId,
 String contextId)
            throws org.mule.runtime.api.store.ObjectStoreException

Create new entry for provided taskId and contextId in object store

Specified by:

upsert in interface TaskStoreService

Parameters:

taskId - task id

contextId - context id

Throws:

org.mule.runtime.api.store.ObjectStoreException

create

public void create(String taskId,
 String contextId,
 StreamingContext context)
            throws org.mule.runtime.api.store.ObjectStoreException

Create new entry for provided taskId and contextId in object store along with StreamingContext

Specified by:

create in interface TaskStoreService

Parameters:

taskId - task id

contextId - context id

context - streaming context

Throws:

org.mule.runtime.api.store.ObjectStoreException