fea(jmanus): Support publishing custom plans as MCP services.

pom.xml

@@ -273,7 +273,6 @@
         <poi.version>5.4.0</poi.version>
 
         <mcp.version>0.10.0</mcp.version>
-
         <opentelemetry.version>1.38.0</opentelemetry.version>
 
         <!-- CheckStyle Plugin -->

spring-ai-alibaba-jmanus/pom.xml

@@ -37,6 +37,7 @@
         <maven-checkstyle-plugin.failOnViolation>true</maven-checkstyle-plugin.failOnViolation>
         <puppycrawl-tools-checkstyle.version>9.3</puppycrawl-tools-checkstyle.version>
 
+
     </properties>
 
     <dependencyManagement>
@@ -126,6 +127,17 @@
             <artifactId>mcp-spring-webflux</artifactId>
             <version>0.11.0</version>
         </dependency>
+        <!-- Reactor Netty for WebFlux -->
+        <dependency>
+            <groupId>io.projectreactor.netty</groupId>
+            <artifactId>reactor-netty-http</artifactId>
+        </dependency>
+
+        <!-- Spring WebFlux -->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-webflux</artifactId>
+        </dependency>
 
         <!--
         <dependency>

spring-ai-alibaba-jmanus/src/main/java/com/alibaba/cloud/ai/example/manus/OpenManusSpringBootApplication.java

@@ -19,12 +19,18 @@
 import com.microsoft.playwright.Playwright;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.boot.autoconfigure.domain.EntityScan;
+import org.springframework.context.annotation.ComponentScan;
+import org.springframework.data.jpa.repository.config.EnableJpaRepositories;
 import org.springframework.scheduling.annotation.EnableScheduling;
 
 import java.io.IOException;
 
 @SpringBootApplication
 @EnableScheduling
+@EnableJpaRepositories(basePackages = { "com.alibaba.cloud.ai.example.manus" })
+@EntityScan(basePackages = { "com.alibaba.cloud.ai.example.manus" })
+@ComponentScan(basePackages = { "com.alibaba.cloud.ai.example.manus" })
 public class OpenManusSpringBootApplication {
 
 	public static void main(String[] args) throws IOException, InterruptedException {

spring-ai-alibaba-jmanus/src/main/java/com/alibaba/cloud/ai/example/manus/config/CoordinatorProperties.java

@@ -0,0 +1,84 @@
+/*
+ * Copyright 2025 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.alibaba.cloud.ai.example.manus.config;
+
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.stereotype.Component;
+
+/**
+ * Coordinator 配置属性
+ */
+@Component
+@ConfigurationProperties(prefix = "coordinator.tool")
+public class CoordinatorProperties {
+
+	/**
+	 * 是否启用CoordinatorTool功能
+	 */
+	private boolean enabled = true;
+
+	/**
+	 * 轮询配置
+	 */
+	private Polling polling = new Polling();
+
+	public boolean isEnabled() {
+		return enabled;
+	}
+
+	public void setEnabled(boolean enabled) {
+		this.enabled = enabled;
+	}
+
+	public Polling getPolling() {
+		return polling;
+	}
+
+	public void setPolling(Polling polling) {
+		this.polling = polling;
+	}
+
+	/**
+	 * 轮询配置内部类
+	 */
+	public static class Polling {
+		/**
+		 * 最大轮询次数
+		 */
+		private int maxAttempts = 60;
+
+		/**
+		 * 轮询间隔（毫秒）
+		 */
+		private long pollInterval = 10000;
+
+		public int getMaxAttempts() {
+			return maxAttempts;
+		}
+
+		public void setMaxAttempts(int maxAttempts) {
+			this.maxAttempts = maxAttempts;
+		}
+
+		public long getPollInterval() {
+			return pollInterval;
+		}
+
+		public void setPollInterval(long pollInterval) {
+			this.pollInterval = pollInterval;
+		}
+	}
+}