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()

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)
EventQueue.EventQueueBuilder	getEventQueueBuilder(String taskId)
void	onReplicatedEvent(ReplicatedEvent replicatedEvent)
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

public ReplicatedQueueManager()

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
 ReplicatedEvent replicatedEvent)

getEventQueueBuilder

public EventQueue.EventQueueBuilder getEventQueueBuilder(String taskId)

Specified by:

getEventQueueBuilder in interface QueueManager