feat: add initial A2A runtime integration by rdobrik · Pull Request #1 · dscope-io/dscope-camel-agent

rdobrik · 2026-03-12T20:30:55Z

Summary

This PR adds the first end-to-end Camel Agent A2A integration slice: it exposes local plans over the existing camel-a2a-component runtime surface and lets agent tools call remote A2A runtimes through a2a: endpoints while preserving correlation and audit metadata.

Scope

add A2A runtime configuration and bootstrap wiring
expose POST /a2a/rpc, GET /a2a/sse/{taskId}, and GET /.well-known/agent-card.json
load a separate exposed-agent catalog that maps public A2A identities to local {planName, planVersion}
create linked local conversations/tasks for inbound A2A work and persist A2A task snapshots
add outbound a2a: tool execution over JSON-RPC HTTP with correlation reuse for follow-up task calls
surface A2A agent/task/conversation identifiers through correlation and audit views

Implementation notes

agents.yaml remains the internal local plan catalog
public A2A exposure is configured separately through the exposed-agent catalog
inbound routing is explicit: only configured exposed agents are published and routable
outbound tool calls intercept a2a: targets in the Camel tool executor, call the remote runtime over JSON-RPC, and bind returned remote task identifiers back into the local conversation correlation state

Verification

./mvnw -q -pl camel-agent-core -Dtest=A2AExposedAgentCatalogLoaderTest,AgentA2ATaskRepositoryTest,A2AToolClientTest test
./mvnw -q -pl camel-agent-core,camel-agent-starter -am -DskipTests compile
./mvnw -q -pl camel-agent-core,camel-agent-persistence-dscope -am -DskipTests compile

Known gaps

sample/runtime wiring for demonstrating A2A in the support sample is still pending
full reactor compile still fails in samples/agent-support-service because of pre-existing missing sample classes in src/main/java/io/dscope/camel/agent/samples/Main.java

Copilot

Pull request overview

Adds initial inbound A2A runtime integration to Camel Agent, including runtime routes, exposed-agent publishing, and persistence/audit correlation of A2A task & conversation metadata.

Changes:

Introduces A2A runtime bootstrap/binding and Undertow routes for /a2a/rpc, /a2a/sse/{taskId}, and /.well-known/agent-card.json.
Adds an exposed-agent catalog (YAML loader + agent-card generation) mapping public A2A agent cards to local plan name/version.
Persists and surfaces A2A correlation metadata in persistence/audit views, with focused unit tests.

Reviewed changes

Copilot reviewed 22 out of 22 changed files in this pull request and generated 4 comments.

Show a summary per file

File	Description
pom.xml	Adds `${a2a.version}` property for the new A2A component dependency.
camel-agent-core/pom.xml	Adds `camel-a2a-component` dependency to core runtime.
docs/roadmap.md	Adds roadmap entry referencing the A2A integration work.
docs/pr-drafts/a2a-runtime-integration.md	Adds PR draft/design notes for the A2A runtime integration.
camel-agent-persistence-dscope/.../DscopePersistenceFacade.java	Extends stored correlation metadata to include A2A identifiers.
camel-agent-core/.../runtime/RuntimeResourceBootstrapper.java	Stages remote exposed-agent config when configured via HTTP URL.
camel-agent-core/.../runtime/AgentRuntimeBootstrap.java	Wires A2A protocol beans + A2A runtime route builder when enabled.
camel-agent-core/.../runtime/AgentA2ARuntimeRouteBuilder.java	Adds Undertow routes that dispatch to A2A component processors via beans.
camel-agent-core/.../runtime/A2ARuntimeProperties.java	Adds A2A runtime configuration parsing and URL/path helpers.
camel-agent-core/.../config/CorrelationKeys.java	Adds A2A correlation key constants.
camel-agent-core/.../config/AgentHeaders.java	Adds A2A header constants for propagating correlation into the agent component.
camel-agent-core/.../component/AgentProducer.java	Binds incoming A2A correlation headers into the correlation registry.
camel-agent-core/.../audit/AuditMetadataSupport.java	Derives A2A correlation from events and surfaces it in conversation metadata.
camel-agent-core/.../audit/AuditConversationViewProcessor.java	Adds `a2a` metadata block to conversation view responses.
camel-agent-core/.../a2a/AgentA2ATaskRepository.java	Adds in-memory + persisted A2A task storage and conversation event appends.
camel-agent-core/.../a2a/AgentA2AProtocolSupport.java	Binds A2A processors/services/agent-card catalog into Camel Main when enabled.
camel-agent-core/.../a2a/AgentA2AAgentCardCatalog.java	Generates discovery/extended agent cards from exposed-agent catalog.
camel-agent-core/.../a2a/A2AExposedAgentSpec.java	Defines exposed-agent spec model for YAML config.
camel-agent-core/.../a2a/A2AExposedAgentCatalogLoader.java	Loads exposed-agent YAML config from classpath/file/http(s).
camel-agent-core/.../a2a/A2AExposedAgentCatalog.java	Validates and provides lookup/default behavior for exposed agents.
camel-agent-core/src/test/.../A2AExposedAgentCatalogLoaderTest.java	Tests exposed-agent catalog loading and validation.
camel-agent-core/src/test/.../AgentA2ATaskRepositoryTest.java	Tests task create/cancel + persisted conversation audit event behavior.

💡 Add Copilot custom instructions for smarter, more guided reviews. Learn how to get started.

Copilot · 2026-03-12T20:35:59Z

camel-agent-core/src/main/java/io/dscope/camel/agent/a2a/AgentA2AProtocolSupport.java

+        bind(main, A2AComponentApplicationSupport.BEAN_TASK_EVENT_SERVICE, taskEventService);
+        bind(main, A2AComponentApplicationSupport.BEAN_PUSH_CONFIG_SERVICE, pushConfigService);
+        bind(main, A2AComponentApplicationSupport.BEAN_TASK_SERVICE, taskRepository);
+        bind(main, A2AComponentApplicationSupport.BEAN_AGENT_CARD_CATALOG, agentCardCatalog);
+        bind(main, A2AComponentApplicationSupport.BEAN_CREATE_PUSH_CONFIG_PROCESSOR, createPushConfigProcessor);
+        bind(main, A2AComponentApplicationSupport.BEAN_GET_PUSH_CONFIG_PROCESSOR, getPushConfigProcessor);
+        bind(main, A2AComponentApplicationSupport.BEAN_LIST_PUSH_CONFIGS_PROCESSOR, listPushConfigsProcessor);
+        bind(main, A2AComponentApplicationSupport.BEAN_DELETE_PUSH_CONFIG_PROCESSOR, deletePushConfigProcessor);
+        bind(main, A2AComponentApplicationSupport.BEAN_ENVELOPE_PROCESSOR, new A2AJsonRpcEnvelopeProcessor(A2AProtocolMethods.CORE_METHODS));
+        bind(main, A2AComponentApplicationSupport.BEAN_ERROR_PROCESSOR, new A2AErrorProcessor());
+        bind(main, A2AComponentApplicationSupport.BEAN_METHOD_PROCESSOR, new A2AMethodDispatchProcessor(methods));
+        bind(main, A2AComponentApplicationSupport.BEAN_SSE_PROCESSOR, new A2ATaskSseProcessor(taskEventService));
+        bind(main, A2AComponentApplicationSupport.BEAN_AGENT_CARD_DISCOVERY_PROCESSOR, new AgentCardDiscoveryProcessor(agentCardCatalog));
+        bind(main, A2AComponentApplicationSupport.BEAN_GET_EXTENDED_AGENT_CARD_PROCESSOR, getExtendedAgentCardProcessor);


The A2A beans are only bound if missing, but this method still constructs new taskEventService, taskRepository, agentCardCatalog, and processors that are wired together. If any of the A2AComponentApplicationSupport.BEAN_* names are already present in the Main registry, you can end up with routes using the pre-existing beans while other newly-created processors/services are used elsewhere, causing inconsistent state (e.g., SSE processor using a different event service than the task repository publishes to). Consider either (1) treating these beans as an atomic set (fail fast if any already exist), (2) always overriding them when A2A is enabled, or (3) looking up and reusing existing beans instead of creating new ones.

docs/roadmap.md

Copilot · 2026-03-12T20:36:00Z

camel-agent-core/src/main/java/io/dscope/camel/agent/a2a/AgentA2ATaskRepository.java

+        current.setUpdatedAt(Instant.now().toString());
+        tasks.put(taskId, current);
+        historyByTaskId.computeIfAbsent(taskId, ignored -> new ArrayList<>()).add(copyStatus(canceled));
+        eventService.publishTaskUpdate(current);


historyByTaskId stores mutable ArrayList instances inside a ConcurrentMap and later mutates them (e.g., .add(...)). This is not thread-safe and can lead to lost updates or ConcurrentModificationException when history is read while another thread updates it. Use a thread-safe list (e.g., CopyOnWriteArrayList) or update the map with a new immutable list on each change.

@copilot open a new pull request to apply changes based on this feedback

camel-agent-core/src/main/java/io/dscope/camel/agent/a2a/AgentA2ATaskRepository.java

Copilot

Pull request overview

Copilot reviewed 64 out of 65 changed files in this pull request and generated 7 comments.

💡 Add Copilot custom instructions for smarter, more guided reviews. Learn how to get started.

camel-agent-core/src/main/java/io/dscope/camel/agent/runtime/A2ARuntimeProperties.java

camel-agent-core/src/main/java/io/dscope/camel/agent/runtime/AgentRuntimeBootstrap.java

camel-agent-core/src/main/java/io/dscope/camel/agent/a2a/AgentA2AProtocolSupport.java

camel-agent-core/src/main/java/io/dscope/camel/agent/a2a/A2AToolClient.java

docs/roadmap.md

...gent-support-service/src/main/java/io/dscope/camel/agent/samples/SampleAdminMcpBindings.java

camel-agent-core/src/main/java/io/dscope/camel/agent/a2a/A2AExposedAgentCatalog.java

rdobrik · 2026-03-17T19:02:27Z

@copilot open a new pull request to apply changes based on the comments in this thread

Copilot · 2026-03-17T19:02:36Z

@rdobrik I've opened a new pull request, #2, to work on those changes. Once the pull request is ready, I'll request review from you.

… issues Co-authored-by: rdobrik <8812511+rdobrik@users.noreply.github.com>

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

Copilot · 2026-03-17T19:34:40Z

@rdobrik I've opened a new pull request, #3, to work on those changes. Once the pull request is ready, I'll request review from you.

Co-authored-by: Copilot Autofix powered by AI <175728472+Copilot@users.noreply.github.com>

… InMemoryPersistenceFacade Co-authored-by: rdobrik <8812511+rdobrik@users.noreply.github.com>

Co-authored-by: rdobrik <8812511+rdobrik@users.noreply.github.com>

Copilot · 2026-03-17T20:41:23Z

@rdobrik I've opened a new pull request, #4, to work on those changes. Once the pull request is ready, I'll request review from you.

Copilot · 2026-03-17T20:41:36Z

@rdobrik I've opened a new pull request, #5, to work on those changes. Once the pull request is ready, I'll request review from you.

Copilot · 2026-03-17T20:41:45Z

@rdobrik I've opened a new pull request, #6, to work on those changes. Once the pull request is ready, I'll request review from you.

Co-authored-by: rdobrik <8812511+rdobrik@users.noreply.github.com>

Normalize whitespace for all required fields in A2AExposedAgentCatalog

Fix broken absolute filesystem path in roadmap.md

fix: use CopyOnWriteArrayList for thread-safe conversation history in InMemoryPersistenceFacade

fix: address A2A runtime review feedback — interface types, port fallback, reflection, and field normalization

feat: add initial A2A runtime integration

5be939f

Copilot AI review requested due to automatic review settings March 12, 2026 20:30

Copilot started reviewing on behalf of rdobrik March 12, 2026 20:31 View session

Copilot AI reviewed Mar 12, 2026

View reviewed changes

rdobrik added 3 commits March 12, 2026 17:01

feat: add outbound A2A tool client support

1f14452

Align agent A2A with 1.0.0

1f86198

Document multi-agent catalog setup

c79eef6

rdobrik requested a review from Copilot March 17, 2026 18:11

Copilot started reviewing on behalf of rdobrik March 17, 2026 18:11 View session

Copilot AI reviewed Mar 17, 2026

View reviewed changes

Initial plan

58da109

Copilot AI mentioned this pull request Mar 17, 2026

fix: address A2A runtime review feedback — interface types, port fallback, reflection, and field normalization #2

Merged

Copilot AI and others added 3 commits March 17, 2026 19:17

Address PR review feedback: fix A2A runtime, tool client, and catalog…

17799f9

… issues Co-authored-by: rdobrik <8812511+rdobrik@users.noreply.github.com>

Update docs/roadmap.md

b039537

Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>

Initial plan

881b8ba

Copilot AI mentioned this pull request Mar 17, 2026

fix: use CopyOnWriteArrayList for thread-safe conversation history in InMemoryPersistenceFacade #3

Merged

rdobrik and others added 8 commits March 17, 2026 12:36

Potential fix for pull request finding

f3d5e93

Co-authored-by: Copilot Autofix powered by AI <175728472+Copilot@users.noreply.github.com>

Potential fix for pull request finding

9981ce1

Co-authored-by: Copilot Autofix powered by AI <175728472+Copilot@users.noreply.github.com>

Potential fix for pull request finding

1c07aaa

Co-authored-by: Copilot Autofix powered by AI <175728472+Copilot@users.noreply.github.com>

Potential fix for pull request finding

6f3b362

Co-authored-by: Copilot Autofix powered by AI <175728472+Copilot@users.noreply.github.com>

fix: use CopyOnWriteArrayList for thread-safe conversation history in…

282ec11

… InMemoryPersistenceFacade Co-authored-by: rdobrik <8812511+rdobrik@users.noreply.github.com>

fix: use CopyOnWriteArrayList for thread-safe conversation history in…

03503d2

… InMemoryPersistenceFacade Co-authored-by: rdobrik <8812511+rdobrik@users.noreply.github.com>

chore: remove accidentally committed maven wrapper binaries

11d5c78

Co-authored-by: rdobrik <8812511+rdobrik@users.noreply.github.com>

Initial plan

ee19bfb

Copilot AI mentioned this pull request Mar 17, 2026

Fix broken absolute filesystem path in roadmap.md #4

Merged

Copilot AI mentioned this pull request Mar 17, 2026

Remove reflection-based registry lookup in favor of Camel's public API #5

Closed

Initial plan

bfbe89c

Copilot AI mentioned this pull request Mar 17, 2026

Normalize whitespace for all required fields in A2AExposedAgentCatalog #6

Merged

Copilot AI and others added 7 commits March 17, 2026 20:45

Normalize trimmed values for all required A2AExposedAgentSpec fields

20f063a

Co-authored-by: rdobrik <8812511+rdobrik@users.noreply.github.com>

Fix persistence backend compatibility and response gateway tests

9fa7ea2

Merge pull request #6 from dscope-io/copilot/sub-pr-1-one-more-time

54a688c

Normalize whitespace for all required fields in A2AExposedAgentCatalog

Merge pull request #4 from dscope-io/copilot/sub-pr-1-another-one

0c49bdd

Fix broken absolute filesystem path in roadmap.md

Merge pull request #3 from dscope-io/copilot/sub-pr-1-again

4b35fe8

fix: use CopyOnWriteArrayList for thread-safe conversation history in InMemoryPersistenceFacade

Merge branch 'codex/add-a2a-support' into copilot/sub-pr-1

9f4377a

Merge pull request #2 from dscope-io/copilot/sub-pr-1

ef12136

fix: address A2A runtime review feedback — interface types, port fallback, reflection, and field normalization

rdobrik merged commit 4dcf00b into master Mar 18, 2026

rdobrik deleted the codex/add-a2a-support branch March 18, 2026 16:31

Conversation

rdobrik commented Mar 12, 2026 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Summary

Scope

Implementation notes

Verification

Known gaps

Uh oh!

Copilot AI left a comment

Choose a reason for hiding this comment

Pull request overview

Reviewed changes

Uh oh!

Copilot AI Mar 12, 2026

Choose a reason for hiding this comment

Uh oh!

Uh oh!

Copilot AI Mar 12, 2026

Choose a reason for hiding this comment

Uh oh!

rdobrik Mar 17, 2026

Choose a reason for hiding this comment

Uh oh!

Uh oh!

Copilot AI left a comment

Choose a reason for hiding this comment

Pull request overview

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

rdobrik commented Mar 17, 2026

Uh oh!

Copilot AI commented Mar 17, 2026

Uh oh!

Copilot AI commented Mar 17, 2026

Uh oh!

Copilot AI commented Mar 17, 2026

Uh oh!

Copilot AI commented Mar 17, 2026

Uh oh!

Copilot AI commented Mar 17, 2026

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

3 participants

rdobrik commented Mar 12, 2026 •

edited

Loading