Package io.a2a.extras.queuemanager.replicated.tests.multiinstance.common

Class MultiInstanceReplicationAgentExecutor

java.lang.Object

io.a2a.extras.queuemanager.replicated.tests.multiinstance.common.MultiInstanceReplicationAgentExecutor

All Implemented Interfaces:

AgentExecutor

public class MultiInstanceReplicationAgentExecutor
extends Object
implements AgentExecutor

Shared test agent executor for multi-instance replication tests. Behavior: 1. Creates task in SUBMITTED state on first message 2. Adds messages as artifacts on subsequent messages 3. Completes task when message contains "close"

Constructor Summary

Constructors

Constructor	Description
MultiInstanceReplicationAgentExecutor()

Method Summary

Modifier and Type	Method	Description
void	cancel(RequestContext context, EventQueue eventQueue)
void	execute(RequestContext context, EventQueue eventQueue)

Methods inherited from class java.lang.Object

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

Constructor Details

MultiInstanceReplicationAgentExecutor

public MultiInstanceReplicationAgentExecutor()

Method Details

execute

public void execute(RequestContext context,
 EventQueue eventQueue)
             throws JSONRPCError

Specified by:

execute in interface AgentExecutor

Throws:

JSONRPCError

cancel

public void cancel(RequestContext context,
 EventQueue eventQueue)
            throws JSONRPCError

Specified by:

cancel in interface AgentExecutor

Throws:

JSONRPCError