Package io.agentscope.harness.agent.gateway

Class WakeupDispatcher

java.lang.Object

io.agentscope.harness.agent.gateway.WakeupDispatcher

All Implemented Interfaces:

AutoCloseable

public class WakeupDispatcher
extends Object
implements AutoCloseable

Per-process dispatcher that wakes idle sessions when background work completes.

Subscribes to the shared wakeup signal channel on MessageBus.subscribeWakeup() and drains the durable wakeup queue on each signal. For each queued entry whose target session is idle, triggers a new reasoning round via WakeupDispatcher.WakeupTarget.runWakeup(String). It serves as the universal activator for all cross-session communication:

• Background subagent task completion
• Async tool results (AsyncToolMiddleware)
• Team messages (future Agent Teams support)
• Scheduled task triggers

Lifecycle: call start() after the gateway is fully configured. Call close() on shutdown. Typically managed by the application bootstrap or gateway factory.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	WakeupDispatcher.WakeupTarget	Thin interface for the two gateway operations the dispatcher needs.

Constructor Summary

Constructors

Constructor	Description
WakeupDispatcher(MessageBus messageBus, WakeupDispatcher.WakeupTarget target)

Method Summary

Modifier and Type	Method	Description
void	close()
void	start()	Starts the dispatcher: performs an initial drain of any queued wakeups (to pick up signals produced while this process was down), then subscribes to the live signal channel.

Methods inherited from class java.lang.Object

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

Constructor Details

WakeupDispatcher

public WakeupDispatcher(MessageBus messageBus,
 WakeupDispatcher.WakeupTarget target)

Method Details

start

public void start()

Starts the dispatcher: performs an initial drain of any queued wakeups (to pick up signals produced while this process was down), then subscribes to the live signal channel.

close

public void close()

Specified by:

close in interface AutoCloseable