Revert "[ISSUE #5247] Add A2A Agent Card Registry to EventMesh (#5246)"

This reverts commit 4f94911.

Author: qqeasonchen

docs/plugins/core-engines-configuration.md

@@ -21,7 +21,6 @@ dependencies {
     implementation project(":eventmesh-sdks:eventmesh-sdk-java")
     implementation project(":eventmesh-common")
     implementation project(":eventmesh-storage-plugin:eventmesh-storage-api")
-    implementation project(":eventmesh-protocol-plugin:eventmesh-protocol-a2a")
     implementation project(":eventmesh-connectors:eventmesh-connector-spring")
     implementation('org.springframework.boot:spring-boot-starter-web') {
         exclude group: 'org.springframework.boot', module: 'spring-boot-starter-logging'

eventmesh-examples/build.gradle

@@ -42,26 +42,24 @@ public static void main(String[] args) throws Exception {
         final String eventMeshIp = properties.getProperty(ExampleConstants.EVENTMESH_IP);
         final int eventMeshTcpPort = Integer.parseInt(properties.getProperty(ExampleConstants.EVENTMESH_TCP_PORT));
         try {
-            final UserAgent userAgent = EventMeshTestUtils.generateClient1();
-            try (final EventMeshTCPClient<CloudEvent> client =
-                     EventMeshTCPClientFactory.createEventMeshTCPClient(
-                         EventMeshTCPClientConfig.builder()
-                             .host(eventMeshIp)
-                             .port(eventMeshTcpPort)
-                             .userAgent(userAgent)
-                             .build(),
-                         CloudEvent.class)) {
-                client.init();
+            UserAgent userAgent = EventMeshTestUtils.generateClient1();
+            EventMeshTCPClientConfig eventMeshTcpClientConfig = EventMeshTCPClientConfig.builder()
+                .host(eventMeshIp)
+                .port(eventMeshTcpPort)
+                .userAgent(userAgent)
+                .build();
+            final EventMeshTCPClient<CloudEvent> client =
+                EventMeshTCPClientFactory.createEventMeshTCPClient(eventMeshTcpClientConfig, CloudEvent.class);
+            client.init();
 
-                for (int i = 0; i < 2; i++) {
-                    final CloudEvent event = EventMeshTestUtils.generateCloudEventV1Async();
-                    log.info("begin send async msg[{}]: {}", i, event);
-                    client.publish(event, EventMeshCommon.DEFAULT_TIME_OUT_MILLS);
+            for (int i = 0; i < 2; i++) {
+                CloudEvent event = EventMeshTestUtils.generateCloudEventV1Async();
+                log.info("begin send async msg[{}]: {}", i, event);
+                client.publish(event, EventMeshCommon.DEFAULT_TIME_OUT_MILLS);
 
-                    ThreadUtils.sleep(1, TimeUnit.SECONDS);
-                }
-                ThreadUtils.sleep(2, TimeUnit.SECONDS);
+                ThreadUtils.sleep(1, TimeUnit.SECONDS);
             }
+            ThreadUtils.sleep(2, TimeUnit.SECONDS);
         } catch (Exception e) {
             log.error("AsyncPublish failed", e);
         }