Index

A C G H I O R S T
All Classes and Interfaces|All Packages

A

add(String, EventQueue) - Method in class io.a2a.extras.queuemanager.replicated.core.ReplicatedQueueManager

awaitQueuePollerStart(EventQueue) - Method in class io.a2a.extras.queuemanager.replicated.core.ReplicatedQueueManager

C

close(String) - Method in class io.a2a.extras.queuemanager.replicated.core.ReplicatedQueueManager

createOrTap(String) - Method in class io.a2a.extras.queuemanager.replicated.core.ReplicatedQueueManager

G

get(String) - Method in class io.a2a.extras.queuemanager.replicated.core.ReplicatedQueueManager

getActiveChildQueueCount(String) - Method in class io.a2a.extras.queuemanager.replicated.core.ReplicatedQueueManager

getErrorObject() - Method in class io.a2a.extras.queuemanager.replicated.core.ReplicatedEventQueueItem

Get the JSONRPCError field (for JSON serialization).

getEvent() - Method in class io.a2a.extras.queuemanager.replicated.core.ReplicatedEventQueueItem

Get the contained event as the generic Event interface (implements EventQueueItem).

getEventQueueBuilder(String) - Method in class io.a2a.extras.queuemanager.replicated.core.ReplicatedQueueManager

getStreamingEvent() - Method in class io.a2a.extras.queuemanager.replicated.core.ReplicatedEventQueueItem

Get the StreamingEventKind event field (for JSON serialization).

getTaskId() - Method in class io.a2a.extras.queuemanager.replicated.core.ReplicatedEventQueueItem

H

hasError() - Method in class io.a2a.extras.queuemanager.replicated.core.ReplicatedEventQueueItem

Check if this ReplicatedEvent contains an error.

hasEvent() - Method in class io.a2a.extras.queuemanager.replicated.core.ReplicatedEventQueueItem

Check if this ReplicatedEvent contains an event (vs an error).

I

io.a2a.extras.queuemanager.replicated.core - package io.a2a.extras.queuemanager.replicated.core

isClosedEvent() - Method in class io.a2a.extras.queuemanager.replicated.core.ReplicatedEventQueueItem

Check if this is a QueueClosedEvent (poison pill).

isReplicated() - Method in class io.a2a.extras.queuemanager.replicated.core.ReplicatedEventQueueItem

Indicates this is a replicated event (implements EventQueueItem).

O

onReplicatedEvent(ReplicatedEventQueueItem) - Method in class io.a2a.extras.queuemanager.replicated.core.ReplicatedQueueManager

onTaskFinalized(TaskFinalizedEvent) - Method in class io.a2a.extras.queuemanager.replicated.core.ReplicatedQueueManager

Observes task finalization events fired AFTER database transaction commits.

R

ReplicatedEventQueueItem - Class in io.a2a.extras.queuemanager.replicated.core

ReplicatedEventQueueItem() - Constructor for class io.a2a.extras.queuemanager.replicated.core.ReplicatedEventQueueItem

ReplicatedEventQueueItem(String, Event) - Constructor for class io.a2a.extras.queuemanager.replicated.core.ReplicatedEventQueueItem

ReplicatedEventQueueItem(String, JSONRPCError) - Constructor for class io.a2a.extras.queuemanager.replicated.core.ReplicatedEventQueueItem

ReplicatedEventQueueItem(String, StreamingEventKind) - Constructor for class io.a2a.extras.queuemanager.replicated.core.ReplicatedEventQueueItem

ReplicatedQueueManager - Class in io.a2a.extras.queuemanager.replicated.core

ReplicatedQueueManager(ReplicationStrategy, TaskStateProvider) - Constructor for class io.a2a.extras.queuemanager.replicated.core.ReplicatedQueueManager

ReplicationStrategy - Interface in io.a2a.extras.queuemanager.replicated.core

S

send(String, Event) - Method in interface io.a2a.extras.queuemanager.replicated.core.ReplicationStrategy

setClosedEvent(boolean) - Method in class io.a2a.extras.queuemanager.replicated.core.ReplicatedEventQueueItem

Set the closed event flag (for JSON deserialization).

setError(JSONRPCError) - Method in class io.a2a.extras.queuemanager.replicated.core.ReplicatedEventQueueItem

setEvent(StreamingEventKind) - Method in class io.a2a.extras.queuemanager.replicated.core.ReplicatedEventQueueItem

setTaskId(String) - Method in class io.a2a.extras.queuemanager.replicated.core.ReplicatedEventQueueItem

T

tap(String) - Method in class io.a2a.extras.queuemanager.replicated.core.ReplicatedQueueManager

toString() - Method in class io.a2a.extras.queuemanager.replicated.core.ReplicatedEventQueueItem

A C G H I O R S T
All Classes and Interfaces|All Packages