You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@eventmesh.apache.org by gi...@apache.org on 2026/04/02 08:36:41 UTC
(eventmesh) branch dependabot/gradle/grpcVersion-1.71.0 updated (698f6a9eb -> 83f925ec5)
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch dependabot/gradle/grpcVersion-1.71.0
in repository https://gitbox.apache.org/repos/asf/eventmesh.git
discard 698f6a9eb Bump grpcVersion from 1.68.0 to 1.71.0
add 635f038ad [ISSUE #4642] unit test for FileSinkConnectorTest.java (#5197)
add 0c0f30eb5 Update README.md (#5198)
add bebce5311 update EventMesh architecture (#5199)
add 436ce7870 update eventmesh architecture (#5200)
add 74aee768d [ISSUE #5208] develop mcp protocol (#5203)
add 68ed2835d [ISSUE #5202,#5204]Implement A2A (Agent-to-Agent) protocol (#5206)
add 46a67a989 [ISSUE #5214]Fix operator logic (#5215)
add 7943df26e Add files via upload (#5216)
add 233ea4816 Update EventMesh architecture image (#5217)
add 193343caf update architecture (#5219)
add 59b1e0a49 update architecture image (#5220)
add c3d6548eb 1.12.0-prepare (#5222)
add 83f925ec5 Bump grpcVersion from 1.68.0 to 1.71.0
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (698f6a9eb)
\
N -- N -- N refs/heads/dependabot/gradle/grpcVersion-1.71.0 (83f925ec5)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
NOTICE | 2 +-
README.md | 140 +-
README.zh-CN.md | 5 +-
build.gradle | 4 +-
docs/a2a-protocol/ARCHITECTURE.md | 155 ++
docs/a2a-protocol/IMPLEMENTATION_SUMMARY.md | 37 +
docs/a2a-protocol/IMPLEMENTATION_SUMMARY_EN.md | 38 +
docs/a2a-protocol/README.md | 209 +++
docs/a2a-protocol/README_EN.md | 150 ++
docs/a2a-protocol/TEST_RESULTS.md | 56 +
docs/a2a-protocol/eventmesh-a2a-design.md | 269 ++++
eventmesh-common/build.gradle | 2 +-
.../McpRetryConfig.java} | 4 +-
.../HttpSinkConfig.java => mcp/McpSinkConfig.java} | 5 +-
.../McpSourceConfig.java} | 5 +-
.../{http => mcp}/SinkConnectorConfig.java | 11 +-
.../{http => mcp}/SourceConnectorConfig.java | 8 +-
.../config/convert/converter/ObjectConverter.java | 14 +-
.../apache/eventmesh/common/utils/JsonUtils.java | 11 +
.../convert/converter/ObjectConverterTest.java | 92 ++
.../file/sink/connector/FileSinkConnectorTest.java | 89 ++
.../connector}/FileSourceConnectorTest.java | 3 +-
.../src/main/resources/server-config.yml | 2 +-
.../build.gradle | 74 +-
.../gradle.properties | 2 +-
.../connector/mcp/config/McpServerConfig.java} | 7 +-
.../connector/mcp/server/McpConnectServer.java} | 20 +-
.../connector/mcp/sink/McpSinkConnector.java | 189 +++
.../connector/mcp/sink/data/McpAttemptEvent.java} | 10 +-
.../connector/mcp/sink/data/McpConnectRecord.java} | 66 +-
.../mcp/sink/data/McpExportMetadata.java} | 6 +-
.../connector/mcp/sink/data/McpExportRecord.java} | 8 +-
.../mcp/sink/data/McpExportRecordPage.java} | 8 +-
.../mcp/sink/data/MultiMcpRequestContext.java} | 14 +-
.../mcp/sink/handler/AbstractMcpSinkHandler.java} | 43 +-
.../mcp/sink/handler/McpDeliveryStrategy.java} | 4 +-
.../mcp/sink/handler/McpSinkHandler.java} | 26 +-
.../sink/handler/impl/CommonMcpSinkHandler.java} | 69 +-
.../handler/impl/McpSinkHandlerRetryWrapper.java} | 53 +-
.../connector/mcp/source/McpSourceConnector.java | 659 ++++++++
.../connector/mcp/source/McpSourceConstants.java | 433 ++++++
.../connector/mcp/source/McpToolRegistry.java | 138 ++
.../connector/mcp/source/data/McpRequest.java} | 58 +-
.../connector/mcp/source/data/McpResponse.java | 136 ++
.../connector/mcp}/source/protocol/Protocol.java | 6 +-
.../mcp}/source/protocol/ProtocolFactory.java | 17 +-
.../source/protocol/impl/McpStandardProtocol.java | 339 ++++
...entmesh.openconnect.api.ConnectorCreateService} | 5 +-
.../src/main/resources/server-config.yml | 2 +-
.../src/main/resources/sink-config.yml | 33 +-
.../src/main/resources/source-config.yml | 18 +-
.../src/test}/resources/server-config.yml | 0
eventmesh-examples/build.gradle | 2 +-
.../demo/A2AAbstractDemo.java} | 43 +-
.../eventmesh/a2a/demo/ce/CloudEventsCaller.java | 116 ++
.../eventmesh/a2a/demo/ce/CloudEventsProvider.java | 99 ++
.../apache/eventmesh/a2a/demo/mcp/McpCaller.java | 154 ++
.../apache/eventmesh/a2a/demo/mcp/McpProvider.java | 117 ++
.../http/demo/sub/RemoteSubscribeInstance.java | 47 +-
eventmesh-meta/eventmesh-meta-raft/build.gradle | 2 +-
.../eventmesh_connectors/connectors_controller.go | 191 ++-
.../eventmesh_runtime/runtime_controller.go | 247 +--
eventmesh-operator/share/share.go | 5 -
.../build.gradle | 23 +-
.../protocol/a2a/A2AProtocolConstants.java | 57 +
.../protocol/a2a/EnhancedA2AProtocolAdaptor.java | 421 +++++
.../eventmesh/protocol/a2a/mcp/JsonRpcError.java | 71 +
.../eventmesh/protocol/a2a/mcp/JsonRpcRequest.java | 73 +
.../protocol/a2a/mcp/JsonRpcResponse.java | 60 +-
.../eventmesh/protocol/a2a/mcp/McpMethods.java | 57 +
...g.apache.eventmesh.protocol.api.ProtocolAdaptor | 2 +-
.../a2a/CloudEventsComprehensiveDemoTest.java | 165 ++
.../a2a/EnhancedA2AProtocolAdaptorTest.java | 210 +++
.../protocol/a2a/McpComprehensiveDemoTest.java | 190 +++
.../protocol/a2a/McpIntegrationDemoTest.java | 153 ++
.../protocol/a2a/McpPatternsIntegrationTest.java | 147 ++
.../api/EnhancedProtocolPluginFactory.java | 351 +++++
.../eventmesh/protocol/api/ProtocolAdaptor.java | 67 +-
.../eventmesh/protocol/api/ProtocolMetrics.java | 310 ++++
.../eventmesh/protocol/api/ProtocolRouter.java | 295 ++++
.../protocol/api/ProtocolPluginFactoryTest.java | 8 +-
.../eventmesh-protocol-cloudevents/build.gradle | 2 +-
.../eventmesh-protocol-grpc/build.gradle | 2 +-
.../eventmesh-protocol-http/build.gradle | 2 +-
.../eventmesh-protocol-meshmessage/build.gradle | 2 +-
.../retry/api/timer/HashedWheelTimer.java | 8 +-
eventmesh-runtime/build.gradle | 1 +
.../conf/a2a-protocol-config.yaml | 42 +-
.../runtime/core/consumer/SubscriptionManager.java | 33 +-
.../core/protocol/http/processor/inf/Client.java | 26 +
.../core/protocol/tcp/client/session/Session.java | 27 +-
eventmesh-sdks/eventmesh-sdk-java/build.gradle | 2 +-
gradle.properties | 2 +-
resources/eventmesh-architecture-5.png | Bin 169892 -> 309136 bytes
resources/eventmesh-architecture-6.png | Bin 0 -> 1185617 bytes
settings.gradle | 2 +
tools/dist-license/NOTICE | 1614 ++++++++++----------
97 files changed, 7680 insertions(+), 1522 deletions(-)
create mode 100644 docs/a2a-protocol/ARCHITECTURE.md
create mode 100644 docs/a2a-protocol/IMPLEMENTATION_SUMMARY.md
create mode 100644 docs/a2a-protocol/IMPLEMENTATION_SUMMARY_EN.md
create mode 100644 docs/a2a-protocol/README.md
create mode 100644 docs/a2a-protocol/README_EN.md
create mode 100644 docs/a2a-protocol/TEST_RESULTS.md
create mode 100644 docs/a2a-protocol/eventmesh-a2a-design.md
copy eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/{http/HttpRetryConfig.java => mcp/McpRetryConfig.java} (93%)
copy eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/{http/HttpSinkConfig.java => mcp/McpSinkConfig.java} (90%)
copy eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/{http/HttpSourceConfig.java => mcp/McpSourceConfig.java} (90%)
copy eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/{http => mcp}/SinkConnectorConfig.java (83%)
copy eventmesh-common/src/main/java/org/apache/eventmesh/common/config/connector/{http => mcp}/SourceConnectorConfig.java (91%)
create mode 100644 eventmesh-common/src/test/java/org/apache/eventmesh/common/config/convert/converter/ObjectConverterTest.java
create mode 100644 eventmesh-connectors/eventmesh-connector-file/src/test/java/org/apache/eventmesh/connector/file/sink/connector/FileSinkConnectorTest.java
rename eventmesh-connectors/eventmesh-connector-file/src/test/java/org/apache/eventmesh/connector/file/{ => source/connector}/FileSourceConnectorTest.java (95%)
copy eventmesh-connectors/{eventmesh-connector-http => eventmesh-connector-mcp}/build.gradle (74%)
copy eventmesh-connectors/{eventmesh-connector-s3 => eventmesh-connector-mcp}/gradle.properties (98%)
copy eventmesh-connectors/{eventmesh-connector-s3/src/main/java/org/apache/eventmesh/connector/s3/config/S3ServerConfig.java => eventmesh-connector-mcp/src/main/java/org/apache/eventmesh/connector/mcp/config/McpServerConfig.java} (91%)
copy eventmesh-connectors/{eventmesh-connector-chatgpt/src/main/java/org/apache/eventmesh/connector/chatgpt/server/ChatGPTConnectServer.java => eventmesh-connector-mcp/src/main/java/org/apache/eventmesh/connector/mcp/server/McpConnectServer.java} (64%)
create mode 100644 eventmesh-connectors/eventmesh-connector-mcp/src/main/java/org/apache/eventmesh/connector/mcp/sink/McpSinkConnector.java
copy eventmesh-connectors/{eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/sink/data/HttpAttemptEvent.java => eventmesh-connector-mcp/src/main/java/org/apache/eventmesh/connector/mcp/sink/data/McpAttemptEvent.java} (93%)
copy eventmesh-connectors/{eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/sink/data/HttpConnectRecord.java => eventmesh-connector-mcp/src/main/java/org/apache/eventmesh/connector/mcp/sink/data/McpConnectRecord.java} (61%)
copy eventmesh-connectors/{eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/sink/data/HttpExportMetadata.java => eventmesh-connector-mcp/src/main/java/org/apache/eventmesh/connector/mcp/sink/data/McpExportMetadata.java} (88%)
copy eventmesh-connectors/{eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/sink/data/HttpExportRecord.java => eventmesh-connector-mcp/src/main/java/org/apache/eventmesh/connector/mcp/sink/data/McpExportRecord.java} (81%)
copy eventmesh-connectors/{eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/sink/data/HttpExportRecordPage.java => eventmesh-connector-mcp/src/main/java/org/apache/eventmesh/connector/mcp/sink/data/McpExportRecordPage.java} (83%)
copy eventmesh-connectors/{eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/sink/data/MultiHttpRequestContext.java => eventmesh-connector-mcp/src/main/java/org/apache/eventmesh/connector/mcp/sink/data/MultiMcpRequestContext.java} (84%)
copy eventmesh-connectors/{eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/sink/handler/AbstractHttpSinkHandler.java => eventmesh-connector-mcp/src/main/java/org/apache/eventmesh/connector/mcp/sink/handler/AbstractMcpSinkHandler.java} (62%)
copy eventmesh-connectors/{eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/sink/handler/HttpDeliveryStrategy.java => eventmesh-connector-mcp/src/main/java/org/apache/eventmesh/connector/mcp/sink/handler/McpDeliveryStrategy.java} (90%)
copy eventmesh-connectors/{eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/sink/handler/HttpSinkHandler.java => eventmesh-connector-mcp/src/main/java/org/apache/eventmesh/connector/mcp/sink/handler/McpSinkHandler.java} (70%)
copy eventmesh-connectors/{eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/sink/handler/impl/CommonHttpSinkHandler.java => eventmesh-connector-mcp/src/main/java/org/apache/eventmesh/connector/mcp/sink/handler/impl/CommonMcpSinkHandler.java} (76%)
copy eventmesh-connectors/{eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/sink/handler/impl/HttpSinkHandlerRetryWrapper.java => eventmesh-connector-mcp/src/main/java/org/apache/eventmesh/connector/mcp/sink/handler/impl/McpSinkHandlerRetryWrapper.java} (56%)
create mode 100644 eventmesh-connectors/eventmesh-connector-mcp/src/main/java/org/apache/eventmesh/connector/mcp/source/McpSourceConnector.java
create mode 100644 eventmesh-connectors/eventmesh-connector-mcp/src/main/java/org/apache/eventmesh/connector/mcp/source/McpSourceConstants.java
create mode 100644 eventmesh-connectors/eventmesh-connector-mcp/src/main/java/org/apache/eventmesh/connector/mcp/source/McpToolRegistry.java
copy eventmesh-connectors/{eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http/source/data/WebhookRequest.java => eventmesh-connector-mcp/src/main/java/org/apache/eventmesh/connector/mcp/source/data/McpRequest.java} (51%)
create mode 100644 eventmesh-connectors/eventmesh-connector-mcp/src/main/java/org/apache/eventmesh/connector/mcp/source/data/McpResponse.java
copy eventmesh-connectors/{eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http => eventmesh-connector-mcp/src/main/java/org/apache/eventmesh/connector/mcp}/source/protocol/Protocol.java (91%)
copy eventmesh-connectors/{eventmesh-connector-http/src/main/java/org/apache/eventmesh/connector/http => eventmesh-connector-mcp/src/main/java/org/apache/eventmesh/connector/mcp}/source/protocol/ProtocolFactory.java (77%)
create mode 100644 eventmesh-connectors/eventmesh-connector-mcp/src/main/java/org/apache/eventmesh/connector/mcp/source/protocol/impl/McpStandardProtocol.java
copy eventmesh-connectors/{eventmesh-connector-spring/src/main/resources/META-INF/spring.factories => eventmesh-connector-mcp/src/main/resources/META-INF.eventmesh/org.apache.eventmesh.openconnect.api.ConnectorCreateService} (85%)
copy eventmesh-connectors/{eventmesh-connector-knative => eventmesh-connector-mcp}/src/main/resources/server-config.yml (97%)
copy eventmesh-connectors/{eventmesh-connector-http => eventmesh-connector-mcp}/src/main/resources/sink-config.yml (57%)
copy eventmesh-connectors/{eventmesh-connector-http => eventmesh-connector-mcp}/src/main/resources/source-config.yml (77%)
copy eventmesh-connectors/{eventmesh-connector-chatgpt/src/main => eventmesh-connector-mcp/src/test}/resources/server-config.yml (100%)
copy eventmesh-examples/src/main/java/org/apache/eventmesh/{http/demo/HttpAbstractDemo.java => a2a/demo/A2AAbstractDemo.java} (54%)
create mode 100644 eventmesh-examples/src/main/java/org/apache/eventmesh/a2a/demo/ce/CloudEventsCaller.java
create mode 100644 eventmesh-examples/src/main/java/org/apache/eventmesh/a2a/demo/ce/CloudEventsProvider.java
create mode 100644 eventmesh-examples/src/main/java/org/apache/eventmesh/a2a/demo/mcp/McpCaller.java
create mode 100644 eventmesh-examples/src/main/java/org/apache/eventmesh/a2a/demo/mcp/McpProvider.java
copy eventmesh-protocol-plugin/{eventmesh-protocol-cloudevents => eventmesh-protocol-a2a}/build.gradle (68%)
create mode 100644 eventmesh-protocol-plugin/eventmesh-protocol-a2a/src/main/java/org/apache/eventmesh/protocol/a2a/A2AProtocolConstants.java
create mode 100644 eventmesh-protocol-plugin/eventmesh-protocol-a2a/src/main/java/org/apache/eventmesh/protocol/a2a/EnhancedA2AProtocolAdaptor.java
create mode 100644 eventmesh-protocol-plugin/eventmesh-protocol-a2a/src/main/java/org/apache/eventmesh/protocol/a2a/mcp/JsonRpcError.java
create mode 100644 eventmesh-protocol-plugin/eventmesh-protocol-a2a/src/main/java/org/apache/eventmesh/protocol/a2a/mcp/JsonRpcRequest.java
copy eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/consumer/ClientInfo.java => eventmesh-protocol-plugin/eventmesh-protocol-a2a/src/main/java/org/apache/eventmesh/protocol/a2a/mcp/JsonRpcResponse.java (51%)
create mode 100644 eventmesh-protocol-plugin/eventmesh-protocol-a2a/src/main/java/org/apache/eventmesh/protocol/a2a/mcp/McpMethods.java
copy eventmesh-protocol-plugin/{eventmesh-protocol-http => eventmesh-protocol-a2a}/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.protocol.api.ProtocolAdaptor (92%)
create mode 100644 eventmesh-protocol-plugin/eventmesh-protocol-a2a/src/test/java/org/apache/eventmesh/protocol/a2a/CloudEventsComprehensiveDemoTest.java
create mode 100644 eventmesh-protocol-plugin/eventmesh-protocol-a2a/src/test/java/org/apache/eventmesh/protocol/a2a/EnhancedA2AProtocolAdaptorTest.java
create mode 100644 eventmesh-protocol-plugin/eventmesh-protocol-a2a/src/test/java/org/apache/eventmesh/protocol/a2a/McpComprehensiveDemoTest.java
create mode 100644 eventmesh-protocol-plugin/eventmesh-protocol-a2a/src/test/java/org/apache/eventmesh/protocol/a2a/McpIntegrationDemoTest.java
create mode 100644 eventmesh-protocol-plugin/eventmesh-protocol-a2a/src/test/java/org/apache/eventmesh/protocol/a2a/McpPatternsIntegrationTest.java
create mode 100644 eventmesh-protocol-plugin/eventmesh-protocol-api/src/main/java/org/apache/eventmesh/protocol/api/EnhancedProtocolPluginFactory.java
create mode 100644 eventmesh-protocol-plugin/eventmesh-protocol-api/src/main/java/org/apache/eventmesh/protocol/api/ProtocolMetrics.java
create mode 100644 eventmesh-protocol-plugin/eventmesh-protocol-api/src/main/java/org/apache/eventmesh/protocol/api/ProtocolRouter.java
copy docker/Dockerfile_jdk11 => eventmesh-runtime/conf/a2a-protocol-config.yaml (58%)
create mode 100644 resources/eventmesh-architecture-6.png
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org