tessl/maven-com-embabel-agent--embabel-agent-a2a
A2A protocol integration for Embabel Agent Framework enabling agent-to-agent communication
overview.mddocs/api/
API Reference
Complete API documentation for embabel-agent-a2a module.
Core Interfaces
Request Handling
- A2ARequestHandler - JSON-RPC request processing
- AutonomyA2ARequestHandler - Autonomy integration
AgentCard Management
- AgentCardHandler - AgentCard exposure and routing
- EmbabelServerGoalsAgentCardHandler - Default implementation
Skill Factory
- AgentSkillFactory - Skill generation interface
- FromGoalsAgentSkillFactory - Goals-to-skills converter
Streaming
- A2AStreamingHandler - SSE stream management
- TaskStateManager - Task history tracking
Configuration
- A2AConfiguration - Spring auto-configuration
- A2AEndpointRegistrar - Dynamic endpoint registration
Events
- A2ARequestEvent - Request received
- A2AResponseEvent - Response sent
Supported A2A Methods
Implemented
| Method | Type | Description |
|---|---|---|
message/send | Non-streaming | Synchronous message execution |
message/stream | Streaming | Asynchronous streaming execution |
task/resubscribe | Streaming | Resubscribe to existing task |
Not Yet Implemented
| Method | Status |
|---|---|
task/get | Returns TODO() error |
task/cancel | Returns TODO() error |
Types and Constants
// Type Aliases
typealias GoalFilter = (Goal) -> Boolean
// Constants
const val DEFAULT_A2A_PATH = "a2a"
// TaskState Enum (from A2A specification)
enum class TaskState {
PENDING,
WORKING,
COMPLETED,
FAILED,
CANCELED
}
// TaskInfo Data Class
data class TaskInfo(
val taskId: String,
val contextId: String,
val streamId: String,
val events: MutableList<StreamingEventKind>,
val createdAt: Instant,
var completedAt: Instant?,
var currentState: TaskState
)Dependencies
Required External
- A2A Specification:
io.a2a.spec.* - Spring Boot: Web MVC, Context
- Spring Web:
SseEmitter - Jackson:
ObjectMapper - Jakarta Servlet:
ServletRequest
Required Internal
- embabel-agent-api:
Autonomy,AgenticEventListener,AgentPlatformEvent - embabel-agent-core:
AgentPlatform,Goal,ProcessOptions - embabel-common:
HasInfoString
Import Statements
Core:
import com.embabel.agent.a2a.server.A2ARequestHandler
import com.embabel.agent.a2a.server.AgentCardHandler
import com.embabel.agent.a2a.server.AgentSkillFactory
import com.embabel.agent.a2a.server.config.A2AConfigurationEvents:
import com.embabel.agent.a2a.server.A2ARequestEvent
import com.embabel.agent.a2a.server.A2AResponseEventImplementation:
import com.embabel.agent.a2a.server.support.A2AEndpointRegistrar
import com.embabel.agent.a2a.server.support.A2AStreamingHandler
import com.embabel.agent.a2a.server.support.AutonomyA2ARequestHandler
import com.embabel.agent.a2a.server.support.EmbabelServerGoalsAgentCardHandler
import com.embabel.agent.a2a.server.support.FromGoalsAgentSkillFactory
import com.embabel.agent.a2a.server.support.TaskStateManagerA2A Specification:
import io.a2a.spec.*Component Dependency Graph
A2AConfiguration
↓ creates
AgentCardHandler (EmbabelServerGoalsAgentCardHandler)
↓ uses
A2ARequestHandler (AutonomyA2ARequestHandler)
↓ uses
├─ Autonomy (from embabel-agent-api)
├─ AgenticEventListener (from embabel-agent-api)
└─ A2AStreamingHandler
↓ uses
TaskStateManagerSee Also
- Quick Start - Get started quickly
- Common Tasks - Common operations
- Integration Patterns - Architectural patterns
tessl i tessl/maven-com-embabel-agent--embabel-agent-a2a@0.3.3