This is an automated email from the ASF dual-hosted git repository.
ShannonDing pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-ai.git
from 3c19764 Open Issue
new 8d249bc Init Project
new e485862 Open issues
new 9e81fa5 update
new 8807181 optimize the code
new 790809d update
new f94bd9e Push init code into rocketmq-a2a (#1)
new db8a3b7 Merge branch 'main' into main
new b577e13 Change the NOTICE (#2)
new 7f261a3 Polish README.md
new 192c4b4 Polish example README.md
new e9609a7 Merge branch 'apache:main' into main
new bd710c4 Add some necessary information in the root pom file.
new 18ee957 Remove duplicate organization
new 63abb88 Merge branch 'apache:main' into main
new 678862c update
new d2073eb add spring web demo
new 044e7dc update example
new b315211 update
new 532e2f4 update
new b9d6527 update demo
new efa133e optimzie the code
new bf7c419 update
new beec330 Optimize the code style (#3)
new 519c2d8 Modify version to 1.0.5-SNAPSHOT
new 00130cc [maven-release-plugin] prepare release rocketmq-a2a-1.0.5
new 688a616 [maven-release-plugin] prepare for next development iteration
new 1109139 Add description
new 5522242 Fix .asf.yaml
new 6eaf9ee Add web-ui chat demo (#4)
new a670194 Update demo (#5)
new 4dc8133 Optimize the code (#6)
new 01dc746 Update version to 1.0.6-SNAPSHOT
new 60dd832 [maven-release-plugin] prepare release rocketmq-a2a-1.0.6
new fc23ca5 [maven-release-plugin] prepare for next development iteration
new 1d8538e update code
new a49d0a8 change the version
new 59d105c update
new cdd449d update
new 9eb59ae Optimize the code (#8)
new 08c6b1c build: remove duplicate POM dependencies (#7)
new 4e10256 Refine some naming in pom file
new aab1aa5 [maven-release-plugin] prepare release rocketmq-a2a-1.0.7
new 74e655d [maven-release-plugin] prepare for next development iteration
new 94cabdb Merge branch 'apache:main' into main
new 375b148 Merge branch 'main' of github.com:zk-drizzle/rocketmq-a2a
new f534e17 update
new 35df70c Optimize the readme (#9)
new 917ea9a Optimize the readme (#11)
new 07949c8 Fix an incorrect cleanup logic
new 9053028 Merge pull request #10 from yx9o/dev-1217
new b29b8df Merge branch 'main' into main
new ce3952e Merge pull request #12 from zk-drizzle/main
new 5d2648b Optimize the example (#13)
new b21f1cb Optimize the RocketMQTransport (#14)
new 645f770 Update version to 1.0.8-SNAPSHOT
new d47a508 Delete rocketmq-a2a 3.0.1-SNAPSHOT dependency
new 42d5c31 [maven-release-plugin] prepare release rocketmq-a2a-1.0.8
new b02606d [maven-release-plugin] prepare for next development iteration
new 655cad4 Add CI workflows
new 91d23f5 Fix CI workflow execution failures.
new cc804dd Optimize the code and add example about using agentscope (#15)
new 130b163 Update version to 1.0.9-SNAPSHOT
new d8111fd Optimize the code (#16)
new 91bcc85 Update version to 1.0.9-SNAPSHOT
new da33d18 optimize the code (#17)
new 1d17ebe Update version to 1.0.9-SNAPSHOT
new fd40354 Optimize the code and add sample about
rocketmq-multiagent-session-consistency (#18)
new 111a5e9 Optimize the code and add example (#19)
new 3127d7e Update version to 1.0.9-SNAPSHOT
new eaf7280 [maven-release-plugin] prepare release rocketmq-a2a-1.0.9
new 4d20a16 [maven-release-plugin] prepare for next development iteration
new ae3c36e Optimize the frontend code. (#20)
new ef37a99 Optimize the code (#21)
new 7df4e76 Fix spell error
new 70a74f2 Merge pull request #22 from RongtongJin/main-0211
new 3fa3575 Add Apache RocketMQ + LangGraph sample
new 767e62b Fix typo in package name: uitl -> util (#31)
new 570d51d Add mcp-tasks-rocketmq Python module and reorganize
repository into two peer modules (#42)
new ca46d9e Merge rocketmq-a2a history into rocketmq-ai
The 79 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/workflows/maven.yaml | 39 +
.github/workflows/misspell_check.yml | 19 +
.gitignore | 45 +
LICENSE | 202 +++
NOTICE | 5 +
README.md | 110 +-
mcp-tasks-rocketmq/.gitignore | 15 +
mcp-tasks-rocketmq/README.md | 276 +++
mcp-tasks-rocketmq/docs/ledger-topology.svg | 107 ++
mcp-tasks-rocketmq/examples/README.md | 22 +
mcp-tasks-rocketmq/examples/demo_tools.py | 71 +
mcp-tasks-rocketmq/examples/merged_deployment.py | 116 ++
mcp-tasks-rocketmq/examples/offline_walkthrough.py | 297 +++
mcp-tasks-rocketmq/pyproject.toml | 53 +
.../src/mcp_tasks_rocketmq/__init__.py | 37 +-
.../src/mcp_tasks_rocketmq/__main__.py | 85 +
.../src/mcp_tasks_rocketmq/client.py | 136 ++
.../src/mcp_tasks_rocketmq/config.py | 105 ++
.../src/mcp_tasks_rocketmq/rocketmq.py | 843 +++++++++
.../src/mcp_tasks_rocketmq/server.py | 169 ++
mcp-tasks-rocketmq/src/mcp_tasks_rocketmq/tasks.py | 429 +++++
mcp-tasks-rocketmq/src/mcp_tasks_rocketmq/wire.py | 143 ++
.../src/mcp_tasks_rocketmq/worker.py | 82 +
.asf.yaml => mcp-tasks-rocketmq/tests/conftest.py | 18 +-
mcp-tasks-rocketmq/tests/test_client.py | 176 ++
mcp-tasks-rocketmq/tests/test_examples.py | 52 +
mcp-tasks-rocketmq/tests/test_rocketmq_tasks.py | 1135 ++++++++++++
.../java/rocketmq-multiagent-base-adk/README.md | 212 +++
.../common-base-adk/pom.xml | 58 +
.../src/main/java/common/model/Mission.java | 206 +++
.../src/main/java/common/qwen/QwenModel.java | 274 +++
.../main/java/common/qwen/QwenModelRegistry.java | 90 +
.../main/java/common/util/AgentInteraction.java | 85 +
.../docs/images/img.png | Bin 0 -> 390601 bytes
.../docs/images/img_1.png | Bin 0 -> 431600 bytes
.../docs/images/img_10.png | Bin 0 -> 686207 bytes
.../docs/images/img_11.png | Bin 0 -> 846904 bytes
.../docs/images/img_12.png | Bin 0 -> 2042840 bytes
.../docs/images/img_13.png | Bin 0 -> 272917 bytes
.../docs/images/img_14.png | Bin 0 -> 686207 bytes
.../docs/images/img_15.png | Bin 0 -> 148560 bytes
.../docs/images/img_16.png | Bin 0 -> 148560 bytes
.../docs/images/img_2.png | Bin 0 -> 1149856 bytes
.../docs/images/img_3.png | Bin 0 -> 1476406 bytes
.../docs/images/img_4.png | Bin 0 -> 1512815 bytes
.../docs/images/img_5.png | Bin 0 -> 685426 bytes
.../docs/images/img_6.png | Bin 0 -> 846904 bytes
.../docs/images/img_7.png | Bin 0 -> 2042840 bytes
.../docs/images/img_8.png | Bin 0 -> 272917 bytes
.../docs/images/img_9.png | Bin 0 -> 606947 bytes
.../java/rocketmq-multiagent-base-adk/pom.xml | 123 ++
.../supervisor-agent-web/pom.xml | 155 ++
.../org/example/RocketMQA2AChatApplication.java | 27 +
.../org/example/controller/A2AChatController.java | 121 ++
.../src/main/java/org/example/model/TaskInfo.java | 245 +++
.../java/org/example/service/AgentService.java | 695 +++++++
.../src/main/resources/application.yml | 17 +-
.../src/main/resources/static/index.html | 963 ++++++++++
.../supervisor-agent/pom.xml | 114 ++
.../src/main/java/agent/SupervisorAgentMain.java | 529 ++++++
.../travel-agent/pom.xml | 107 ++
.../src/main/java/agent/AgentCardProducer.java | 96 +
.../src/main/java/agent/AgentExecutorProducer.java | 130 ++
.../src/main/resources/application.properties | 18 +-
.../weather-agent/pom.xml | 125 ++
.../src/main/java/agent/AgentCardProducer.java | 95 +
.../src/main/java/agent/AgentExecutorProducer.java | 129 ++
.../src/main/resources/application.properties | 18 +-
.../rocketmq-multiagent-base-agentscope/README.md | 69 +
.../agentscope-client/pom.xml | 92 +
.../java/io/agentscope/A2aAgentCallerExample.java | 140 ++
.../src/main/resources/logback.xml | 26 +
.../agentscope-server/pom.xml | 107 ++
.../AgentScopeDeployRocketMQExample.java | 177 ++
.../docs/img.png | Bin 0 -> 189958 bytes
.../rocketmq-multiagent-base-agentscope/pom.xml | 71 +
.../README.md | 100 +
.../common-session-consistency/pom.xml | 41 +
.../src/main/java/model/RocketMQRequest.java | 237 +++
.../src/main/java/model/RocketMQResponse.java | 268 +++
.../src/main/java/qwen/QwenUtil.java | 105 ++
.../src/main/java/util/RocketMQUtil.java | 228 +++
.../docs/img.png | Bin 0 -> 454378 bytes
.../docs/img1.png | Bin 0 -> 1174021 bytes
.../llm-agent/pom.xml | 82 +
.../src/main/java/org/example/LLMApplication.java | 27 +
.../java/org/example/service/AgentService.java | 185 ++
.../llm-agent/src/main/resources/application.yml | 17 +-
.../pom.xml | 70 +
.../web-gateway/pom.xml | 83 +
.../org/example/RocketMQA2AChatApplication.java | 27 +
.../org/example/controller/ChatController.java | 132 ++
.../main/java/org/example/service/ChatService.java | 109 ++
.../java/org/example/service/RocketMQService.java | 336 ++++
.../java/org/example/stream/event/StreamEvent.java | 112 ++
.../example/stream/handle/StreamingTaskHandle.java | 335 ++++
.../stream/recovery/StreamRecoveryContext.java | 117 ++
.../web-gateway/src/main/resources/application.yml | 17 +-
.../src/main/resources/static/favicon.png | Bin 0 -> 6290 bytes
.../src/main/resources/static/index.html | 1 +
.../resources/static/static/css/index.bdb65db3.css | 1 +
.../resources/static/static/js/512.e06f6b7f.js | 283 +++
.../static/static/js/512.e06f6b7f.js.LICENSE.txt | 61 +
.../resources/static/static/js/index.12961cc8.js | 1 +
.../resources/static/static/js/index.20f6dd2e.js | 1 +
.../resources/static/static/js/index.2a7e4c3f.js | 1 +
.../resources/static/static/js/index.2eedb438.js | 1 +
.../resources/static/static/js/index.ad32df60.js | 1 +
.../resources/static/static/js/index.d6849955.js | 1 +
.../resources/static/static/js/index.decdd8e1.js | 1 +
.../resources/static/static/js/index.e48798e3.js | 1 +
.../static/static/js/lib-react.3e22a6ef.js | 2 +
.../static/js/lib-react.3e22a6ef.js.LICENSE.txt | 49 +
.../rocketmq-multiagent-base-langgraph/.gitignore | 31 +
.../.python-version | 1 +
.../rocketmq-multiagent-base-langgraph/.uv.toml | 3 +
.../rocketmq-multiagent-base-langgraph/README.md | 272 +++
.../common/__init__.py | 17 +
.../common/model/models.py | 71 +
.../common/rocketmq/rocketmq_utils.py | 277 +++
.../docs/images/img.png | Bin 0 -> 1945460 bytes
.../docs/images/img_1.png | Bin 0 -> 1129805 bytes
.../docs/images/img_10.png | Bin 0 -> 75007 bytes
.../docs/images/img_2.png | Bin 0 -> 390982 bytes
.../docs/images/img_3.png | Bin 0 -> 551104 bytes
.../docs/images/img_4.png | Bin 0 -> 607510 bytes
.../docs/images/img_5.png | Bin 0 -> 78713 bytes
.../docs/images/img_6.png | Bin 0 -> 568825 bytes
.../docs/images/img_7.png | Bin 0 -> 437687 bytes
.../docs/images/img_8.png | Bin 0 -> 567898 bytes
.../docs/images/img_9.png | Bin 0 -> 72898 bytes
.../pyproject.toml | 92 +
.../scripts/build_packages.py | 242 +++
.../supervisor_agent/__init__.py | 18 +
.../supervisor_agent/api/routes.py | 565 ++++++
.../supervisor_agent/static/index.html | 944 ++++++++++
.../supervisor_agent/supervisor_agent_start.py | 75 +
.../supervisor_agent/utils/config/config.py | 47 +
.../supervisor_agent/utils/constants/constants.py | 61 +
.../supervisor_agent/utils/models/models.py | 17 +
.../supervisor_agent/utils/rocketmq/mq_service.py | 228 +++
.../utils/session/session_manager.py | 186 ++
.../utils/stream/stream_manager.py | 154 ++
.../utils/workflow/workflow_graph.py | 68 +
.../utils/workflow/workflow_nodes.py | 417 +++++
.../travel_agent/__init__.py | 17 +
.../travel_agent/bailian/bailian_service.py | 151 ++
.../travel_agent/config/config.py | 34 +
.../travel_agent/handler/message_handler.py | 50 +
.../travel_agent/rocketmq/mq_service.py | 151 ++
.../travel_agent/travel_agent_start.py | 44 +
.../rocketmq-multiagent-base-langgraph/uv.lock | 1910 ++++++++++++++++++++
.../weather_agent/__init__.py | 16 +
.../weather_agent/bailian/bailian_service.py | 137 ++
.../weather_agent/config/config.py | 33 +
.../weather_agent/handler/message_handler.py | 49 +
.../weather_agent/rocketmq/mq_service.py | 151 ++
.../weather_agent/weather_agent_start.py | 44 +
rocketmq-a2a/pom.xml | 199 ++
.../a2a/common/constant/RocketMQA2AConstant.java | 129 ++
.../a2a/common/future/A2AResponseFuture.java | 121 ++
.../rocketmq/a2a/common/model/RocketMQRequest.java | 301 +++
.../a2a/common/model/RocketMQResource.java | 155 ++
.../a2a/common/model/RocketMQResponse.java | 346 ++++
.../rocketmq/a2a/common/model/ServerReceipt.java | 113 ++
.../a2a/common/util/RequestIdGenerator.java | 70 +
.../rocketmq/a2a/common/util/RocketMQUtil.java | 789 ++++++++
.../a2a/server/RocketMQA2AServerRoutes.java | 570 ++++++
.../transport/config/RocketMQTransportConfig.java | 469 +++++
.../a2a/transport/impl/RocketMQTransport.java | 550 ++++++
.../metadata/RocketMQTransportMetadata.java | 37 +
.../provider/RocketMQTransportProvider.java | 73 +
...2a.client.transport.spi.ClientTransportProvider | 2 +
.../services/io.a2a.server.TransportMetadata | 1 +
rocketmq-a2a/style/copyright/Apache.xml | 23 +
rocketmq-a2a/style/copyright/profiles_settings.xml | 64 +
rocketmq-a2a/style/rmq_checkstyle.xml | 135 ++
rocketmq-a2a/style/rmq_codeStyle.xml | 157 ++
178 files changed, 23910 insertions(+), 101 deletions(-)
create mode 100644 .github/workflows/maven.yaml
create mode 100644 .github/workflows/misspell_check.yml
create mode 100644 .gitignore
create mode 100644 LICENSE
create mode 100644 NOTICE
create mode 100644 mcp-tasks-rocketmq/.gitignore
create mode 100644 mcp-tasks-rocketmq/README.md
create mode 100644 mcp-tasks-rocketmq/docs/ledger-topology.svg
create mode 100644 mcp-tasks-rocketmq/examples/README.md
create mode 100644 mcp-tasks-rocketmq/examples/demo_tools.py
create mode 100644 mcp-tasks-rocketmq/examples/merged_deployment.py
create mode 100644 mcp-tasks-rocketmq/examples/offline_walkthrough.py
create mode 100644 mcp-tasks-rocketmq/pyproject.toml
copy .asf.yaml => mcp-tasks-rocketmq/src/mcp_tasks_rocketmq/__init__.py (54%)
create mode 100644 mcp-tasks-rocketmq/src/mcp_tasks_rocketmq/__main__.py
create mode 100644 mcp-tasks-rocketmq/src/mcp_tasks_rocketmq/client.py
create mode 100644 mcp-tasks-rocketmq/src/mcp_tasks_rocketmq/config.py
create mode 100644 mcp-tasks-rocketmq/src/mcp_tasks_rocketmq/rocketmq.py
create mode 100644 mcp-tasks-rocketmq/src/mcp_tasks_rocketmq/server.py
create mode 100644 mcp-tasks-rocketmq/src/mcp_tasks_rocketmq/tasks.py
create mode 100644 mcp-tasks-rocketmq/src/mcp_tasks_rocketmq/wire.py
create mode 100644 mcp-tasks-rocketmq/src/mcp_tasks_rocketmq/worker.py
copy .asf.yaml => mcp-tasks-rocketmq/tests/conftest.py (67%)
create mode 100644 mcp-tasks-rocketmq/tests/test_client.py
create mode 100644 mcp-tasks-rocketmq/tests/test_examples.py
create mode 100644 mcp-tasks-rocketmq/tests/test_rocketmq_tasks.py
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-base-adk/README.md
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-base-adk/common-base-adk/pom.xml
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-base-adk/common-base-adk/src/main/java/common/model/Mission.java
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-base-adk/common-base-adk/src/main/java/common/qwen/QwenModel.java
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-base-adk/common-base-adk/src/main/java/common/qwen/QwenModelRegistry.java
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-base-adk/common-base-adk/src/main/java/common/util/AgentInteraction.java
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-base-adk/docs/images/img.png
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-base-adk/docs/images/img_1.png
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-base-adk/docs/images/img_10.png
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-base-adk/docs/images/img_11.png
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-base-adk/docs/images/img_12.png
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-base-adk/docs/images/img_13.png
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-base-adk/docs/images/img_14.png
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-base-adk/docs/images/img_15.png
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-base-adk/docs/images/img_16.png
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-base-adk/docs/images/img_2.png
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-base-adk/docs/images/img_3.png
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-base-adk/docs/images/img_4.png
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-base-adk/docs/images/img_5.png
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-base-adk/docs/images/img_6.png
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-base-adk/docs/images/img_7.png
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-base-adk/docs/images/img_8.png
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-base-adk/docs/images/img_9.png
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-base-adk/pom.xml
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-base-adk/supervisor-agent-web/pom.xml
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-base-adk/supervisor-agent-web/src/main/java/org/example/RocketMQA2AChatApplication.java
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-base-adk/supervisor-agent-web/src/main/java/org/example/controller/A2AChatController.java
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-base-adk/supervisor-agent-web/src/main/java/org/example/model/TaskInfo.java
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-base-adk/supervisor-agent-web/src/main/java/org/example/service/AgentService.java
copy .asf.yaml =>
rocketmq-a2a/example/java/rocketmq-multiagent-base-adk/supervisor-agent-web/src/main/resources/application.yml
(67%)
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-base-adk/supervisor-agent-web/src/main/resources/static/index.html
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-base-adk/supervisor-agent/pom.xml
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-base-adk/supervisor-agent/src/main/java/agent/SupervisorAgentMain.java
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-base-adk/travel-agent/pom.xml
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-base-adk/travel-agent/src/main/java/agent/AgentCardProducer.java
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-base-adk/travel-agent/src/main/java/agent/AgentExecutorProducer.java
copy .asf.yaml =>
rocketmq-a2a/example/java/rocketmq-multiagent-base-adk/travel-agent/src/main/resources/application.properties
(67%)
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-base-adk/weather-agent/pom.xml
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-base-adk/weather-agent/src/main/java/agent/AgentCardProducer.java
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-base-adk/weather-agent/src/main/java/agent/AgentExecutorProducer.java
copy .asf.yaml =>
rocketmq-a2a/example/java/rocketmq-multiagent-base-adk/weather-agent/src/main/resources/application.properties
(67%)
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-base-agentscope/README.md
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-base-agentscope/agentscope-client/pom.xml
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-base-agentscope/agentscope-client/src/main/java/io/agentscope/A2aAgentCallerExample.java
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-base-agentscope/agentscope-client/src/main/resources/logback.xml
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-base-agentscope/agentscope-server/pom.xml
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-base-agentscope/agentscope-server/src/main/java/io/agentscope/AgentScopeDeployRocketMQExample.java
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-base-agentscope/docs/img.png
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-base-agentscope/pom.xml
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-session-consistency/README.md
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-session-consistency/common-session-consistency/pom.xml
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-session-consistency/common-session-consistency/src/main/java/model/RocketMQRequest.java
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-session-consistency/common-session-consistency/src/main/java/model/RocketMQResponse.java
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-session-consistency/common-session-consistency/src/main/java/qwen/QwenUtil.java
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-session-consistency/common-session-consistency/src/main/java/util/RocketMQUtil.java
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-session-consistency/docs/img.png
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-session-consistency/docs/img1.png
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-session-consistency/llm-agent/pom.xml
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-session-consistency/llm-agent/src/main/java/org/example/LLMApplication.java
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-session-consistency/llm-agent/src/main/java/org/example/service/AgentService.java
copy .asf.yaml =>
rocketmq-a2a/example/java/rocketmq-multiagent-session-consistency/llm-agent/src/main/resources/application.yml
(67%)
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-session-consistency/pom.xml
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-session-consistency/web-gateway/pom.xml
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-session-consistency/web-gateway/src/main/java/org/example/RocketMQA2AChatApplication.java
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-session-consistency/web-gateway/src/main/java/org/example/controller/ChatController.java
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-session-consistency/web-gateway/src/main/java/org/example/service/ChatService.java
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-session-consistency/web-gateway/src/main/java/org/example/service/RocketMQService.java
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-session-consistency/web-gateway/src/main/java/org/example/stream/event/StreamEvent.java
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-session-consistency/web-gateway/src/main/java/org/example/stream/handle/StreamingTaskHandle.java
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-session-consistency/web-gateway/src/main/java/org/example/stream/recovery/StreamRecoveryContext.java
copy .asf.yaml =>
rocketmq-a2a/example/java/rocketmq-multiagent-session-consistency/web-gateway/src/main/resources/application.yml
(67%)
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-session-consistency/web-gateway/src/main/resources/static/favicon.png
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-session-consistency/web-gateway/src/main/resources/static/index.html
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-session-consistency/web-gateway/src/main/resources/static/static/css/index.bdb65db3.css
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-session-consistency/web-gateway/src/main/resources/static/static/js/512.e06f6b7f.js
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-session-consistency/web-gateway/src/main/resources/static/static/js/512.e06f6b7f.js.LICENSE.txt
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-session-consistency/web-gateway/src/main/resources/static/static/js/index.12961cc8.js
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-session-consistency/web-gateway/src/main/resources/static/static/js/index.20f6dd2e.js
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-session-consistency/web-gateway/src/main/resources/static/static/js/index.2a7e4c3f.js
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-session-consistency/web-gateway/src/main/resources/static/static/js/index.2eedb438.js
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-session-consistency/web-gateway/src/main/resources/static/static/js/index.ad32df60.js
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-session-consistency/web-gateway/src/main/resources/static/static/js/index.d6849955.js
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-session-consistency/web-gateway/src/main/resources/static/static/js/index.decdd8e1.js
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-session-consistency/web-gateway/src/main/resources/static/static/js/index.e48798e3.js
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-session-consistency/web-gateway/src/main/resources/static/static/js/lib-react.3e22a6ef.js
create mode 100644
rocketmq-a2a/example/java/rocketmq-multiagent-session-consistency/web-gateway/src/main/resources/static/static/js/lib-react.3e22a6ef.js.LICENSE.txt
create mode 100644
rocketmq-a2a/example/python/rocketmq-multiagent-base-langgraph/.gitignore
create mode 100644
rocketmq-a2a/example/python/rocketmq-multiagent-base-langgraph/.python-version
create mode 100644
rocketmq-a2a/example/python/rocketmq-multiagent-base-langgraph/.uv.toml
create mode 100644
rocketmq-a2a/example/python/rocketmq-multiagent-base-langgraph/README.md
create mode 100644
rocketmq-a2a/example/python/rocketmq-multiagent-base-langgraph/common/__init__.py
create mode 100644
rocketmq-a2a/example/python/rocketmq-multiagent-base-langgraph/common/model/models.py
create mode 100644
rocketmq-a2a/example/python/rocketmq-multiagent-base-langgraph/common/rocketmq/rocketmq_utils.py
create mode 100644
rocketmq-a2a/example/python/rocketmq-multiagent-base-langgraph/docs/images/img.png
create mode 100644
rocketmq-a2a/example/python/rocketmq-multiagent-base-langgraph/docs/images/img_1.png
create mode 100644
rocketmq-a2a/example/python/rocketmq-multiagent-base-langgraph/docs/images/img_10.png
create mode 100644
rocketmq-a2a/example/python/rocketmq-multiagent-base-langgraph/docs/images/img_2.png
create mode 100644
rocketmq-a2a/example/python/rocketmq-multiagent-base-langgraph/docs/images/img_3.png
create mode 100644
rocketmq-a2a/example/python/rocketmq-multiagent-base-langgraph/docs/images/img_4.png
create mode 100644
rocketmq-a2a/example/python/rocketmq-multiagent-base-langgraph/docs/images/img_5.png
create mode 100644
rocketmq-a2a/example/python/rocketmq-multiagent-base-langgraph/docs/images/img_6.png
create mode 100644
rocketmq-a2a/example/python/rocketmq-multiagent-base-langgraph/docs/images/img_7.png
create mode 100644
rocketmq-a2a/example/python/rocketmq-multiagent-base-langgraph/docs/images/img_8.png
create mode 100644
rocketmq-a2a/example/python/rocketmq-multiagent-base-langgraph/docs/images/img_9.png
create mode 100644
rocketmq-a2a/example/python/rocketmq-multiagent-base-langgraph/pyproject.toml
create mode 100644
rocketmq-a2a/example/python/rocketmq-multiagent-base-langgraph/scripts/build_packages.py
create mode 100644
rocketmq-a2a/example/python/rocketmq-multiagent-base-langgraph/supervisor_agent/__init__.py
create mode 100644
rocketmq-a2a/example/python/rocketmq-multiagent-base-langgraph/supervisor_agent/api/routes.py
create mode 100644
rocketmq-a2a/example/python/rocketmq-multiagent-base-langgraph/supervisor_agent/static/index.html
create mode 100644
rocketmq-a2a/example/python/rocketmq-multiagent-base-langgraph/supervisor_agent/supervisor_agent_start.py
create mode 100644
rocketmq-a2a/example/python/rocketmq-multiagent-base-langgraph/supervisor_agent/utils/config/config.py
create mode 100644
rocketmq-a2a/example/python/rocketmq-multiagent-base-langgraph/supervisor_agent/utils/constants/constants.py
create mode 100644
rocketmq-a2a/example/python/rocketmq-multiagent-base-langgraph/supervisor_agent/utils/models/models.py
create mode 100644
rocketmq-a2a/example/python/rocketmq-multiagent-base-langgraph/supervisor_agent/utils/rocketmq/mq_service.py
create mode 100644
rocketmq-a2a/example/python/rocketmq-multiagent-base-langgraph/supervisor_agent/utils/session/session_manager.py
create mode 100644
rocketmq-a2a/example/python/rocketmq-multiagent-base-langgraph/supervisor_agent/utils/stream/stream_manager.py
create mode 100644
rocketmq-a2a/example/python/rocketmq-multiagent-base-langgraph/supervisor_agent/utils/workflow/workflow_graph.py
create mode 100644
rocketmq-a2a/example/python/rocketmq-multiagent-base-langgraph/supervisor_agent/utils/workflow/workflow_nodes.py
create mode 100644
rocketmq-a2a/example/python/rocketmq-multiagent-base-langgraph/travel_agent/__init__.py
create mode 100644
rocketmq-a2a/example/python/rocketmq-multiagent-base-langgraph/travel_agent/bailian/bailian_service.py
create mode 100644
rocketmq-a2a/example/python/rocketmq-multiagent-base-langgraph/travel_agent/config/config.py
create mode 100644
rocketmq-a2a/example/python/rocketmq-multiagent-base-langgraph/travel_agent/handler/message_handler.py
create mode 100644
rocketmq-a2a/example/python/rocketmq-multiagent-base-langgraph/travel_agent/rocketmq/mq_service.py
create mode 100644
rocketmq-a2a/example/python/rocketmq-multiagent-base-langgraph/travel_agent/travel_agent_start.py
create mode 100644
rocketmq-a2a/example/python/rocketmq-multiagent-base-langgraph/uv.lock
create mode 100644
rocketmq-a2a/example/python/rocketmq-multiagent-base-langgraph/weather_agent/__init__.py
create mode 100644
rocketmq-a2a/example/python/rocketmq-multiagent-base-langgraph/weather_agent/bailian/bailian_service.py
create mode 100644
rocketmq-a2a/example/python/rocketmq-multiagent-base-langgraph/weather_agent/config/config.py
create mode 100644
rocketmq-a2a/example/python/rocketmq-multiagent-base-langgraph/weather_agent/handler/message_handler.py
create mode 100644
rocketmq-a2a/example/python/rocketmq-multiagent-base-langgraph/weather_agent/rocketmq/mq_service.py
create mode 100644
rocketmq-a2a/example/python/rocketmq-multiagent-base-langgraph/weather_agent/weather_agent_start.py
create mode 100644 rocketmq-a2a/pom.xml
create mode 100644
rocketmq-a2a/src/main/java/org/apache/rocketmq/a2a/common/constant/RocketMQA2AConstant.java
create mode 100644
rocketmq-a2a/src/main/java/org/apache/rocketmq/a2a/common/future/A2AResponseFuture.java
create mode 100644
rocketmq-a2a/src/main/java/org/apache/rocketmq/a2a/common/model/RocketMQRequest.java
create mode 100644
rocketmq-a2a/src/main/java/org/apache/rocketmq/a2a/common/model/RocketMQResource.java
create mode 100644
rocketmq-a2a/src/main/java/org/apache/rocketmq/a2a/common/model/RocketMQResponse.java
create mode 100644
rocketmq-a2a/src/main/java/org/apache/rocketmq/a2a/common/model/ServerReceipt.java
create mode 100644
rocketmq-a2a/src/main/java/org/apache/rocketmq/a2a/common/util/RequestIdGenerator.java
create mode 100644
rocketmq-a2a/src/main/java/org/apache/rocketmq/a2a/common/util/RocketMQUtil.java
create mode 100644
rocketmq-a2a/src/main/java/org/apache/rocketmq/a2a/server/RocketMQA2AServerRoutes.java
create mode 100644
rocketmq-a2a/src/main/java/org/apache/rocketmq/a2a/transport/config/RocketMQTransportConfig.java
create mode 100644
rocketmq-a2a/src/main/java/org/apache/rocketmq/a2a/transport/impl/RocketMQTransport.java
create mode 100644
rocketmq-a2a/src/main/java/org/apache/rocketmq/a2a/transport/metadata/RocketMQTransportMetadata.java
create mode 100644
rocketmq-a2a/src/main/java/org/apache/rocketmq/a2a/transport/provider/RocketMQTransportProvider.java
create mode 100644
rocketmq-a2a/src/main/resources/META-INF/services/io.a2a.client.transport.spi.ClientTransportProvider
create mode 100644
rocketmq-a2a/src/main/resources/META-INF/services/io.a2a.server.TransportMetadata
create mode 100644 rocketmq-a2a/style/copyright/Apache.xml
create mode 100644 rocketmq-a2a/style/copyright/profiles_settings.xml
create mode 100644 rocketmq-a2a/style/rmq_checkstyle.xml
create mode 100644 rocketmq-a2a/style/rmq_codeStyle.xml
