Package io.a2a.extras.queuemanager.replicated.core

Class ReplicatedQueueManager

java.lang.Object

io.a2a.extras.queuemanager.replicated.core.ReplicatedQueueManager

All Implemented Interfaces:

QueueManager

@ApplicationScoped
@Alternative
@Priority(50)
public class ReplicatedQueueManager
extends Object
implements QueueManager

Constructor Summary

Constructors

Constructor	Description
ReplicatedQueueManager(ReplicationStrategy replicationStrategy, TaskStateProvider taskStateProvider)

Method Summary

Modifier and Type	Method	Description
void	add(String taskId, EventQueue queue)
void	awaitQueuePollerStart(EventQueue eventQueue)
void	close(String taskId)
EventQueue	createOrTap(String taskId)
EventQueue	get(String taskId)
int	getActiveChildQueueCount(String taskId)
EventQueue.EventQueueBuilder	getEventQueueBuilder(String taskId)
void	onReplicatedEvent(ReplicatedEventQueueItem replicatedEvent)
void	onTaskFinalized(TaskFinalizedEvent event)	Observes task finalization events fired AFTER database transaction commits.
EventQueue	tap(String taskId)

Methods inherited from class java.lang.Object

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

Constructor Details

ReplicatedQueueManager

@Inject
public ReplicatedQueueManager(ReplicationStrategy replicationStrategy,
 TaskStateProvider taskStateProvider)

Method Details

add

public void add(String taskId,
 EventQueue queue)

Specified by:

add in interface QueueManager

get

public EventQueue get(String taskId)

Specified by:

get in interface QueueManager

tap

public EventQueue tap(String taskId)

Specified by:

tap in interface QueueManager

close

public void close(String taskId)

Specified by:

close in interface QueueManager

createOrTap

public EventQueue createOrTap(String taskId)

Specified by:

createOrTap in interface QueueManager

awaitQueuePollerStart

public void awaitQueuePollerStart(EventQueue eventQueue)
                           throws InterruptedException

Specified by:

awaitQueuePollerStart in interface QueueManager

Throws:

InterruptedException

onReplicatedEvent

public void onReplicatedEvent(@Observes
 ReplicatedEventQueueItem replicatedEvent)

onTaskFinalized

public void onTaskFinalized(@Observes(during=AFTER_SUCCESS)
 TaskFinalizedEvent event)

Observes task finalization events fired AFTER database transaction commits. This guarantees the task's final state is durably stored before sending the poison pill.

Parameters:

event - the task finalized event containing the task ID

getEventQueueBuilder

public EventQueue.EventQueueBuilder getEventQueueBuilder(String taskId)

Specified by:

getEventQueueBuilder in interface QueueManager

getActiveChildQueueCount

public int getActiveChildQueueCount(String taskId)

Specified by:

getActiveChildQueueCount in interface QueueManager