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

getError() - Method in class io.a2a.extras.queuemanager.replicated.core.ReplicatedEvent

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

getEventAsGeneric() - Method in class io.a2a.extras.queuemanager.replicated.core.ReplicatedEvent

Get the contained event as the generic Event interface for backward compatibility.

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

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

H

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

Check if this ReplicatedEvent contains an error.

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

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

I

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

O

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

R

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

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

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

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

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

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

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

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

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

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

T

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

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

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