feat(samples): add real-estate-agent sample

This commit introduces a new, self-contained sample for a real-estate agent.

The sample demonstrates an agent capable of understanding natural language queries to search for rental properties. It is composed of three services orchestrated with Docker Compose:
- A core Python A2A agent (`real-estate-agent`).
- A Node.js MCP tool server (`dafty-mcp`) for interacting with a real-estate service.
- A local LLM service (`ollama`) for natural language understanding.

The sample is fully self-contained, with all necessary code and configuration included. The README provides detailed instructions for setup, usage, and testing, and directs contributions back to the original source repositories.

Author: tedwon

demo/ui/main.py

@@ -4,6 +4,10 @@
 """
 
 import os
+import sys
+
+# Add the project root to the Python path
+sys.path.append(os.path.abspath(os.path.join(os.path.dirname(__file__), '..', '..', 'samples', 'python')))
 
 from contextlib import asynccontextmanager
 

samples/java/README.md

@@ -79,7 +79,7 @@ The project implements an intelligent translation agent supporting multi-languag
 Complete implementation of A2A protocol specifications:
 
 **Core Operations**:
-- `tasks/send`: Send task messages
+- `message/send`: Send task messages
 - `tasks/get`: Query task status
 - `tasks/cancel`: Cancel task execution
 
@@ -172,7 +172,7 @@ curl -X POST http://localhost:8080/a2a \
   -d '{
     "jsonrpc": "2.0",
     "id": "request-1",
-    "method": "tasks/send",
+    "method": "message/send",
     "params": {
       "id": "translation-task-1",
       "message": {
@@ -199,7 +199,7 @@ curl -X POST http://localhost:8080/a2a/stream \
   -d '{
     "jsonrpc": "2.0",
     "id": "stream-request-1",
-    "method": "tasks/send",
+    "method": "message/send",
     "params": {
       "id": "streaming-translation-task",
       "message": {

samples/java/client/src/main/java/com/google/a2a/client/A2AClient.java

@@ -60,7 +60,7 @@ public JSONRPCResponse sendTask(TaskSendParams params) throws A2AClientException
         JSONRPCRequest request = new JSONRPCRequest(
             generateRequestId(),
             "2.0",
-            "tasks/send",
+            "message/send",
             params
         );
 
@@ -116,7 +116,7 @@ public CompletableFuture<Void> sendTaskStreaming(TaskSendParams params, Streamin
                 JSONRPCRequest request = new JSONRPCRequest(
                     generateRequestId(),
                     "2.0",
-                    "tasks/send",
+                    "message/send",
                     params
                 );
 

samples/java/server/README.md

@@ -54,7 +54,7 @@ Content-Type: application/json
 {
   "jsonrpc": "2.0",
   "id": "request-1",
-  "method": "tasks/send",
+  "method": "message/send",
   "params": {
     "id": "task-1",
     "message": {

samples/java/server/src/main/java/com/google/a2a/server/A2AController.java

@@ -65,7 +65,7 @@ public ResponseEntity<JSONRPCResponse> handleJsonRpcRequest(@RequestBody JSONRPC
         }
 
         JSONRPCResponse response = switch (request.method()) {
-            case "tasks/send" -> server.handleTaskSend(request);
+            case "message/send" -> server.handleTaskSend(request);
             case "tasks/get" -> server.handleTaskGet(request);
             case "tasks/cancel" -> server.handleTaskCancel(request);
             default -> {
@@ -101,7 +101,7 @@ public SseEmitter handleStreamingTask(@RequestBody JSONRPCRequest request) {
         // Process task asynchronously
         CompletableFuture.runAsync(() -> {
             try {
-                if (!"tasks/send".equals(request.method())) {
+                if (!"message/send".equals(request.method())) {
                     sendErrorEvent(emitter, request.id(), ErrorCode.METHOD_NOT_FOUND, "Method not found");
                     return;
                 }

samples/java/server/src/test/java/com/google/a2a/server/A2AServerTest.java

@@ -104,7 +104,7 @@ void testHandleTaskSend() {
         JSONRPCRequest request = new JSONRPCRequest(
             "request-1",
             "2.0",
-            "tasks/send",
+            "message/send",
             params
         );
 
@@ -156,7 +156,7 @@ void testHandleTaskGet() {
         JSONRPCRequest sendRequest = new JSONRPCRequest(
             "request-1",
             "2.0",
-            "tasks/send",
+            "message/send",
             sendParams
         );
 
@@ -216,7 +216,7 @@ void testHandleTaskCancel() {
         JSONRPCRequest sendRequest = new JSONRPCRequest(
             "request-1",
             "2.0",
-            "tasks/send",
+            "message/send",
             sendParams
         );
 

samples/multi_language/python_and_java_multiagent/README.md

@@ -40,7 +40,7 @@ The `AgentCard` and `AgentExecutor` classes mentioned above are part of the [A2A
 ```xml
 ...
 <properties>
-    <io.a2a.sdk.version>0.2.3</io.a2a.sdk.version>
+    <io.a2a.sdk.version>0.2.3.Beta</io.a2a.sdk.version>
     ...
 </properties>    
 ...
@@ -138,16 +138,16 @@ uv run .
 
 > *⚠️ This is a temporary step until our A2A Java SDK is released.
 > The A2A Java SDK isn't available yet in Maven Central but will be soon. For now, be
-> sure to check out the latest tag (you can see the tags [here](https://github.com/a2aproject/a2a-java/tags)), build from the tag, and reference that version below. For example, if the latest tag is `0.2.3`, you can use
-`git checkout 0.2.3` as shown below.*
+> sure to check out the latest tag (you can see the tags [here](https://github.com/a2aproject/a2a-java/tags)), build from the tag, and reference that version below. For example, if the latest tag is `0.2.3.Beta`, you can use
+`git checkout 0.2.3.Beta` as shown below.*
 
 Open a new terminal and build the A2A Java SDK:
 
 ```bash
 git clone https://github.com/a2aproject/a2a-java
 cd a2a-java
 git fetch --tags
-git checkout 0.2.3
+git checkout 0.2.3.Beta
 mvn clean install
 ```
 

samples/multi_language/python_and_java_multiagent/weather_agent/pom.xml

@@ -12,7 +12,7 @@
         <maven.compiler.source>17</maven.compiler.source>
         <maven.compiler.target>17</maven.compiler.target>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
-        <io.a2a.sdk.version>0.2.3</io.a2a.sdk.version>
+        <io.a2a.sdk.version>0.2.3.Beta</io.a2a.sdk.version>
         <jakarta.enterprise.cdi-api.version>4.1.0</jakarta.enterprise.cdi-api.version>
         <quarkus.platform.version>3.22.3</quarkus.platform.version>
         <quarkus.langchain4j.version>1.0.0</quarkus.langchain4j.version>

samples/python/agents/README.md

@@ -8,10 +8,10 @@ To interact with the servers, use an A2AClient in a host app (such as the CLI).
 
 ## Agents Directory
 
-* [**Google ADK Facts**](/samples/python/agents/adk-facts/README.md)  
+* [**Google ADK Facts**](/samples/python/agents/adk_facts/README.md)  
 Sample agent to give fun facts using Grounding with Google Search and ADK
 
-* [**Google ADK Expense Reimbursement**](/samples/python/agents/adk-expense-reimbursement/README.md)  
+* [**Google ADK Expense Reimbursement**](/samples/python/agents/adk_expense_reimbursement/README.md)  
 Sample agent to (mock) fill out expense reports. Showcases multi-turn interactions and returning/replying to webforms through A2A.
 
 * [**AG2 MCP Agent with A2A Protocol**](/samples/python/agents/ag2/README.md)  

samples/python/agents/real_estate_agent/.dockerignore

@@ -0,0 +1,7 @@
+.git
+.gitignore
+tests
+.env
+.vscode
+__pycache__
+*.pyc