All Classes and Interfaces
Class
Description
Configuration for A2A adapter using official SDK types.
Skill configuration.
Main A2A adapter coordinating internal and external agent communication.
A2A Client wrapper using official A2A Java SDK (v0.3.2.Final).
Exception for A2A client errors.
Callback interface for streaming status updates.
Implements A2A SDK AgentExecutor to expose Agenor agents as A2A servers.
Spring Boot auto-configuration for Agenor.
Main CLI entry point for Agenor framework.
Configuration object for the Agenor framework.
Agent discovery and scanning configuration.
Agent directory provider configuration.
Messaging provider configuration.
Runtime identity settings.
Behavior scheduler configuration.
Wrapper for YAML/JSON configuration files.
Base exception for all Agenor framework exceptions
Actuator
HealthIndicator for the Agenor runtime.Agenor
McpClient that delegates to the official MCP Java SDK's
McpSyncClient, bridging its blocking calls to CompletableFuture
via supplyAsync().Marks a method as a message handler that is automatically subscribed to the
specified topic when the agent starts.
Spring Boot configuration properties for Agenor (prefix:
agenor).Agents
base-package and scan-packages are both merged into
AgenorConfiguration.AgentsConfig by the core constructor.Directory
JDBC directory configuration.
HITL (Human-In-The-Loop) approval queue.
JDBC HITL configuration.
LLM
Messaging
Redis Streams configuration.
Runtime
Scheduler
Telemetry (OpenTelemetry tracing).
Main runtime for the Agenor framework with automatic agent discovery.
Runtime statistics record
Service-provider interface for distributed tracing in Agenor.
Core agent interface defining the lifecycle and basic operations of an agent
in the Agenor multi-agent framework.
Marks a class as a Agenor agent eligible for automatic discovery and registration.
Processor for handling
@Behavior and @AgenorMessageHandler
annotations on agent classes.Aggregates the core services available to every agent.
Immutable descriptor containing agent metadata for discovery.
Builds an
AgentDescriptor from an agent class's @Agent
annotation.Composite directory facade — extends all four capability interfaces.
Capability for querying the agent directory.
Optional package-scanning and DI-based agent construction engine, discovered via
ServiceLoader.Transport endpoint descriptor for a registered agent.
Exception thrown during agent operations
Factory for creating agent instances from annotated classes.
Sends periodic heartbeats for the agents a runtime is currently running (ADR-028 D-3).
The single inbound path of one agent.
Thrown when a message cannot be delivered because the target agent is not registered
in the directory or has no resolvable endpoint.
Capability for agent liveness signalling and status queries.
Query object for searching agents in the
AgentDirectory.Fluent builder for constructing
AgentQuery instances.Extension point invoked once per
AgenorRuntime.registerAgent() call,
discovered via ServiceLoader.Capability for registering, unregistering, and updating agents in the directory.
Hot-path capability for resolving an agent ID to its transport endpoint.
Scanner for discovering classes annotated with @Agent.
Immutable record representing the complete persisted state of an agent.
Fluent builder for constructing
AgentState instances.Enumeration of possible agent states
Outcome of a human approval request.
The action is approved; the agent proceeds with the original payload.
The action is approved with a modified payload; the agent executes with
ApprovalDecision.Modified.newPayload() instead of the original.The action is rejected; the agent must not execute it.
Suspends the calling virtual thread until a human decision is received or the
request times out.
Receives human decisions from external systems (HTTP handlers, webhooks, tests)
for pending HITL approval requests.
SPI for notifying an external observer that a human approval request is pending.
Immutable description of a human approval request.
Facade that receives human decisions from external systems (HTTP handlers,
webhooks, tests) and forwards them to
InMemoryApprovalGate.Thrown when no human decision is submitted before an
ApprovalRequest
expires.Result of a single assertion in an evaluation scenario.
Base implementation for all agents in the Agenor framework.
Base implementation of Behavior interface.
Base command providing common API client functionality.
Marks a method as a Agenor behavior that the runtime will schedule and execute
automatically according to the specified
BehaviorType.Base interface for agent behaviors in the Agenor multi-agent framework.
Optional
@Behavior extension covering behavior types whose implementation
classes live outside agenor-runtime (CONDITIONAL, THROTTLED, BATCH, RETRY,
SEQUENTIAL, PARALLEL, FSM — all in agenor-runtime-ext), discovered via
ServiceLoader.Scheduler interface for managing behavior execution in the Agenor framework.
How the scheduler should drive a behavior.
Represents a social commitment between two agents.
Records a state transition in a commitment's lifecycle.
States of a social commitment between agents.
Tracks and manages commitments across conversations.
Strategy for determining when a parallel behavior completes
Assembles four separate capability implementations into a single
AgentDirectory.Base class for behaviors that coordinate other behaviors.
Manage Agenor configuration.
Contract for loading and validating Agenor configuration.
Listener for console events, typically broadcast via WebSocket.
Filter messages by content
Blocks content that matches a configurable blocklist loaded from a YAML file.
Thrown when the YAML policy file cannot be found or parsed.
Factory for built-in context window strategies.
Strategy for selecting messages to include in LLM context window.
Contract Net Protocol for task delegation and negotiation.
Represents an ongoing dialogue conversation between agents.
Manages dialogue conversations for an agent.
Creates the
ConversationManager an agent's DialogueCapability runs on.Immutable result produced by a
ReflectionStrategy after critiquing an output.Behavior that executes repeatedly at fixed intervals.
A message the framework has stopped trying to deliver, and why.
Where a message goes when the framework stops trying to deliver it.
The default
AgentMailbox: a bounded queue drained by one consumer thread.Sentinel class used as the default value of
RequiresApproval.notifier().Default implementation of
Commitment.Default implementation of
CommitmentTracker.Default implementation of
ConfigurationLoader.Default implementation of
Conversation.Default implementation of
ConversationManager.Default
HitlSupportProvider, discovered via ServiceLoader.Default implementation of LLMMemoryManager.
Default
DefaultLLMMemoryManagerProvider, discovered via
ServiceLoader.Supplies the default
LLMMemoryManager implementation backing
LLMMemoryAware agents, discovered via
ServiceLoader.Default
ReflectionStrategy implementation backed by an LLMProvider.Converts between Agenor DialogueMessage and A2A SDK types.
Provides dialogue capabilities to agents via composition.
Builder for a
DialogueCapability with non-default collaborators.Marks a method as a handler for dialogue messages.
Registry for dialogue message handlers discovered from @DialogueHandler annotations.
A dialogue-aware wrapper around
Message.Capability for sending a message directly to a specific agent by its ID.
Runs Flyway migrations for the agent directory schema on startup.
Capability for receiving direct (point-to-point) messages addressed to a local agent.
Typed exception thrown by
EmbeddingProvider implementations.Classifies the root cause of an embedding failure.
Provider-agnostic interface for generating text embeddings.
Factory for
EmbeddingProvider instances.Shared machinery behind
OpenAIEmbeddingProvider and OllamaEmbeddingProvider.Context provided to scenario verification phase.
Generates reports from evaluation results.
Result of evaluating a scenario against an agent or system.
Evaluation status.
BehaviorAnnotationExtension implementation covering the @Behavior types
whose implementation classes live in agenor-runtime-ext.File-based persistence service using JSON format.
Statistics about persisted data
Optional capability for subscribing with an arbitrary Java predicate.
Fixed window strategy - includes last N messages that fit in budget.
Finite State Machine behavior with state transitions.
Builder for FSM construction
Represents a function call requested by an LLM.
Defines a function that can be called by an LLM.
Builder for creating FunctionDefinition instances.
Reads the
WithGuardrails annotation from an LLMAgent subclass
and injects a GuardrailChain into the agent at registration time.Thrown when a guardrail class listed in
@WithGuardrails cannot be
instantiated at agent bootstrap time.Ordered chain of
InputGuardrails and OutputGuardrails executed
sequentially inside the LLMAgent pipeline.Fluent builder for
GuardrailChain.Immutable contextual metadata passed to every guardrail during chain execution.
Result produced by a guardrail evaluation.
The guardrail rejected the content.
The guardrail transformed the content.
The content passed validation without modification.
Thrown when a guardrail in the chain returns
GuardrailResult.Blocked,
indicating that the content must not proceed through the pipeline.Filter messages by header values
Health check service for monitoring runtime health.
Check runtime health.
Reads the
RequiresApproval annotation from behavior classes registered
with a BaseAgent and wraps each annotated behavior in a
HumanCheckpointBehavior at agent registration time.Thrown when a behavior class listed in
@RequiresApproval cannot be
wired at agent bootstrap time.Wraps
@RequiresApproval-annotated behaviors at agent registration time,
discovered via ServiceLoader.Runs Flyway migrations for the HITL approval queue schema on startup.
Optional HITL (human-in-the-loop) support, discovered via
ServiceLoader.A ONE_SHOT behavior that suspends execution until a human approves, rejects, or
modifies the wrapped critical action.
In-memory implementation of
AgentDirectory.In-memory implementation of
ApprovalGate.A
DeadLetterQueue holding a bounded window of recent entries in memory.In-memory
KnowledgeStore backed by a ConcurrentHashMap.In-memory implementation of
MessageDispatcher and FilterableSubscriber.In-memory implementation of MemoryStore.
Validates or transforms user input before it reaches the LLM.
Factory and lifecycle holder for JDBC-backed agent directory capabilities.
JDBC implementation of
AgentDiscovery.JDBC implementation of
AgentPresence (ADR-028 Phase A).JDBC implementation of
AgentRegistry.JDBC implementation of
AgentResolver.JDBC-backed implementation of
ApprovalGate.Configuration for the JDBC agent directory backend.
Internal JDBC utility shared across all persistence adapters.
Jetty-based web console for Agenor runtime management.
Immutable document stored in a
KnowledgeStore.Storage and retrieval interface for
KnowledgeDocument instances.Exception thrown during lifecycle operations
Opt-in extension point for components that need to run code when an agent starts or stops,
without the agent having to override
start()/stop() for them.Interface for listening to agent lifecycle events
Manager for agent lifecycle operations with timeout and error handling.
List all registered agents.
Base class for LLM-powered agents that use language model memory.
Exception thrown during LLM operations.
Type of LLM error.
Marks an agent as a receiver of an injected
LLMMemoryManager.Manages agent memory specifically for LLM contexts.
Represents a single message in an LLM conversation.
Message role in the conversation.
Core interface for Large Language Model providers.
Factory for creating LLM providers.
Injects the
@WithGuardrails chain and installs telemetry on
LLMAgent instances at agent registration time, discovered via
ServiceLoader.Immutable request object for LLM chat completions.
Builder for creating LLMRequest instances.
Immutable response object from an LLM chat completion.
Builder for creating LLMResponse instances.
Token usage information.
Opt-in extension point for a
MessageDispatcher that knows how agents on its own node
are reachable from other nodes.Default
ApprovalNotifier that logs pending approval requests via SLF4J
at WARN level.Default lifecycle listener that logs status changes
Bounds and overflow behaviour for one agent's mailbox.
Thrown when a message arrives at a full mailbox configured to reject rather than drop.
Enforces a maximum token budget on user input before it reaches the LLM.
Controls which portion of the input is preserved when truncation is needed.
Agenor abstraction over an MCP server connection.
Factory for
AgenorMcpClientAdapter.Adapts MCP tools for use in LLM function-calling workflows.
Immutable representation of a tool advertised by an MCP server.
Thread-safe cache layer over
McpClient.Immutable result of an MCP tool invocation.
Represents a single memory entry stored in the memory system.
Builder for creating MemoryEntry instances.
Base exception for memory storage operations.
Types of memory errors.
Query parameters for searching memory entries.
Builder for creating MemoryQuery instances.
Defines the scope and lifecycle of memory entries.
Statistics and metrics about memory usage.
Builder for creating MemoryStats instances.
Core interface for agent memory storage.
Immutable message object for agent communication in the Agenor framework.
Fluent builder for constructing
Message instances.Primary messaging interface for agents — hides routing details.
Defines criteria for filtering messages during routing and subscription.
Builder for creating complex message filters with fluent API.
Logical operator for combining filters
Functional interface for handling received messages in the Agenor framework.
Functional interface for synchronous message handling.
Thread-safe service for storing and querying recent message history.
Stored message wrapper with additional metadata.
System agent that captures and stores messages for monitoring purposes.
Low-level transport primitive used by the message dispatcher — not by agents directly.
Collects the methods of a class the way annotation scanning needs to see them.
Metrics collection service for Agenor runtime.
Registry of LLM model context window sizes (in tokens).
No-op implementation of
AgenorTelemetry that produces zero overhead.Default
ApprovalHandle used when no HITL provider (e.g.EmbeddingProvider backed by a local Ollama instance.Behavior that executes once and then stops.
EmbeddingProvider backed by the OpenAI Embeddings API.AgenorTelemetry implementation backed by the OpenTelemetry SDK.Factory for creating
OtelAgenorTelemetry instances.Fluent builder for
OtelAgenorTelemetry.Validates or transforms LLM output before it reaches the consumer.
What a mailbox does with a message it has no room for.
A single page of results from a paginated query.
Pagination parameters for directory queries.
Executes multiple child behaviors in parallel using virtual threads.
Communicative act types for agent dialogue.
Marks a field or method for automatic inclusion in agent state persistence.
Configures the persistence behavior for an agent class.
Exception thrown during persistence operations
Manages automatic persistence for agents based on their configuration.
Core interface for agent state persistence in the Agenor framework.
Strategy for when to persist agent state
Detects and masks Personally Identifiable Information (PII) in text content.
Enumeration of supported PII categories.
Listens for cross-node HITL decisions via Postgres
LISTEN/NOTIFY.Defines an interaction protocol as a finite state machine.
Registry for interaction protocols.
States for interaction protocol state machines.
Expands search queries with synonyms to improve recall.
Query protocol for information retrieval.
The
DeadLetterQueue backed by the dead-letter streams the Redis adapter already writes.Redis Streams implementation of
MessageDispatcher.Redis Streams implementation of
MessageTransport.Immutable configuration for the Redis messaging adapter.
Factory for creating Redis messaging adapter instances.
Fluent builder for
RedisMessagingFactory.Redis Streams implementation of
TopicPublisher and TopicSubscriber.Configuration for the Generate → Critique → Revise reflection loop.
Strategy for critiquing an LLM-generated output and deciding whether revision is needed.
Services made available to
AgentRegistrationExtension implementations
during AgenorRuntime.registerAgent().Request protocol for action execution.
Marks an agent behavior as requiring human approval before execution.
REST API handler for web console.
Defines an evaluation scenario for testing agent behavior.
Fluent builder for creating evaluation scenarios.
Executes evaluation scenarios against a Agenor runtime.
Declares how a
CompositeBehavior wants to be driven by the scheduler
when registered via agent.addBehavior().Executes child behaviors sequentially, one after another.
Simple implementation of
BehaviorScheduler backed by a
ScheduledThreadPoolExecutor.Simple character-based token estimator.
Sliding window strategy - includes recent messages plus important older ones.
Utility class for accessing MessageSnifferAgent from runtime.
A single unit of work tracked for distributed tracing.
Fluent builder for creating a
Span.A handle to the active span context set by
Span.makeCurrent().Status for a completed
Span.Pre-built standard scenarios for common evaluation patterns.
Start an agent.
Mixin interface for agents that support state persistence.
Serves static resources (HTML, CSS, JS) from classpath.
Show detailed status of an agent or runtime.
Stop an agent.
Represents a chunk of content in a streaming LLM response.
Handle representing an active message subscription.
Summarization strategy - includes recent messages plus LLM-generated summary of old conversation.
Simple ASCII table formatter for CLI output.
Estimates token counts for text and messages.
Utility class for converting Agenor function definitions to LangChain4j tool specifications.
Filter messages by topic patterns
Capability for publishing messages to named topics (one-to-many).
Capability for subscribing to messages on a named topic.
Transport-layer handle used by
MessageTransport.CLI command to watch real-time events via WebSocket.
Web-based management console for Agenor agents.
WebSocket handler for real-time updates.
Declaratively attaches guardrails to an
LLMAgent subclass.