public class PromptProvider { @McpPrompt(name = "personalized-message", description = "Generates a personalized message based on user information") public GetPromptResult personalizedMessage(McpSyncServerExchange exchange, @McpArg(name = "name", description = "The user's name", required = true) String name, @McpArg(name = "age", description = "The user's age", required = false) Integer age, @McpArg(name = "interests", description = "The user's interests", required = false) String interests) { exchange.loggingNotification(LoggingMessageNotification.builder() .level(LoggingLevel.INFO) .data("personalized-message event").build()); StringBuilder message = new StringBuilder(); message.append("Hello, ").append(name).append("!\n\n"); if (age != null) { message.append("At ").append(age).append(" years old, you have "); if (age < 30) { message.append("so much ahead of you.\n\n"); } else if (age < 60) { message.append("gained valuable life experience.\n\n"); } else { message.append("accumulated wisdom to share with others.\n\n"); } } if (interests != null && !interests.isEmpty()) { message.append("Your interest in ") .append(interests) .append(" shows your curiosity and passion for learning.\n\n"); } message .append("I'm here to assist you with any questions you might have about the Model Context Protocol."); return new GetPromptResult("Personalized Message", List.of(new PromptMessage(Role.ASSISTANT, new TextContent(message.toString())))); } }

public class AutocompleteProvider { private final Map<String, List<String>> usernameDatabase = new HashMap<>(); private final Map<String, List<String>> cityDatabase = new HashMap<>(); public AutocompleteProvider() { // Initialize with sample data cityDatabase.put("l", List.of("Lagos", "Lima", "Lisbon", "London", "Los Angeles")); // .... usernameDatabase.put("a", List.of("alex123", "admin", "alice_wonder", "andrew99")); // Add more data... } @McpComplete(prompt = "personalized-message") public List<String> completeName(String name) { String prefix = name.toLowerCase(); String firstLetter = prefix.substring(0, 1); List<String> usernames = usernameDatabase.getOrDefault(firstLetter, List.of()); return usernames.stream().filter(username -> username.toLowerCase().startsWith(prefix)).toList();	} @McpComplete(prompt = "travel-planner") public List<String> completeCityName(CompleteRequest.CompleteArgument argument) { String prefix = argument.value().toLowerCase(); String firstLetter = prefix.substring(0, 1); List<String> cities = cityDatabase.getOrDefault(firstLetter, List.of()); return cities.stream() .filter(city -> city.toLowerCase().startsWith(prefix)) .toList(); } }

// Create the autocomplete provider AutocompleteProvider provider = new AutocompleteProvider(); // Register a method with SyncMcpCompleteMethodCallback Method method = AutocompleteProvider.class.getMethod("completeCityName", CompleteRequest.CompleteArgument.class); McpComplete annotation = method.getAnnotation(McpComplete.class); BiFunction<McpSyncServerExchange, CompleteRequest, CompleteResult> callback = SyncMcpCompleteMethodCallback.builder() .method(method) .bean(provider) .complete(annotation) .build(); // Use the callback with your MCP server

public class AsyncAutocompleteProvider { // ... @McpComplete(prompt = "travel-planner") public Mono<List<String>> completeCityNameAsync(CompleteRequest.CompleteArgument argument) { return Mono.fromCallable(() -> { // Implementation similar to sync version // ... }); } }

public class MyResourceProvider { private String getUserStatus(String username) { // Simple logic to generate a status if (username.equals("john")) { return "🟢 Online";	} else if (username.equals("jane")) { return "🟠 Away";	} else if (username.equals("bob")) { return "⚪ Offline";	} else if (username.equals("alice")) { return "🔴 Busy";	} else { return "⚪ Offline";	}	} @McpResource(uri = "user-status://{username}", name = "User Status", description = "Provides the current status for a specific user") public String getUserStatus(String username) { return this.getUserStatus(username);	} @McpResource(uri = "user-profile-exchange://{username}", name = "User Profile with Exchange", description = "Provides user profile information with server exchange context") public ReadResourceResult getProfileWithExchange(McpSyncServerExchange exchange, String username) { exchange.loggingNotification(LoggingMessageNotification.builder()	.level(LoggingLevel.INFO)	.data("user-profile-exchange") .build()); String profileInfo = formatProfileInfo(userProfiles.getOrDefault(username.toLowerCase(), new HashMap<>())); return new ReadResourceResult(List.of(new TextResourceContents("user-profile-exchange://" + username, "text/plain", "Profile with exchange for " + username + ": " + profileInfo)));	} }

public class McpServerFactory { public McpSyncServer createMcpServer( MyResourceProvider myResourceProvider, AutocompleteProvider autocompleteProvider, LoggingHandler loggingHandler) { List<SyncResourceSpecification> resourceSpecifications = new SyncMcpResourceProvider(List.of(myResourceProvider)).getResourceSpecifications(); List<SyncCompletionSpecification> completionSpecifications = new SyncMcpCompletionProvider(List.of(autocompleteProvider)).getCompleteSpecifications(); List<SyncPromptSpecification> promptSpecifications = new SyncMcpPromptProvider(List.of(autocompleteProvider)).getPromptSpecifications(); List<Consumer<LoggingMessageNotification>> loggingConsumers = new SyncMcpLoggingConsumerProvider(List.of(loggingHandler)).getLoggingConsumers(); // Create a server with custom configuration McpSyncServer syncServer = McpServer.sync(transportProvider) .serverInfo("my-server", "1.0.0") .capabilities(ServerCapabilities.builder() .resources(true) // Enable resource support .prompts(true) // Enable prompt support .logging() // Enable logging support .completions() // Enable completions support .build()) .resources(resourceSpecifications) .completions(completionSpecifications) .prompts(promptSpecifications) .build(); return syncServer; } }

public class LoggingHandler { /**  * Handle logging message notifications with a single parameter.  * @param notification The logging message notification  */ @McpLoggingConsumer public void handleLoggingMessage(LoggingMessageNotification notification) { System.out.println("Received logging message: " + notification.level() + " - " + notification.logger() + " - " + notification.data()); } /**  * Handle logging message notifications with individual parameters.  * @param level The logging level  * @param logger The logger name  * @param data The log message data  */ @McpLoggingConsumer public void handleLoggingMessageWithParams(LoggingLevel level, String logger, String data) { System.out.println("Received logging message with params: " + level + " - " + logger + " - " + data); } } public class MyMcpClient { public static McpSyncClient createClient(LoggingHandler loggingHandler) { List<Consumer<LoggingMessageNotification>> loggingCOnsummers = new SyncMcpLoggingConsumerProvider(List.of(loggingHandler)).getLoggingConsumers(); McpSyncClient client = McpClient.sync(transport) .capabilities(ClientCapabilities.builder() // Enable capabilities .. .build()) .loggingConsumers(loggingCOnsummers) .build(); return client; } }

@Configuration public class McpConfig { @Bean public List<SyncCompletionSpecification> syncCompletionSpecifications( List<AutocompleteProvider> completeProviders) { return SpringAiMcpAnnotationProvider.createSyncCompleteSpecifications(completeProviders); } @Bean public List<SyncPromptSpecification> syncPromptSpecifications( List<PromptProvider> promptProviders) { return SpringAiMcpAnnotationProvider.createSyncPromptSpecifications(promptProviders); } @Bean public List<SyncResourceSpecification> syncResourceSpecifications( List<ResourceProvider> resourceProviders) { return SpringAiMcpAnnotationProvider.createSyncResourceSpecifications(resourceProviders); } @Bean public List<Consumer<LoggingMessageNotification>> syncLoggingConsumers( List<LoggingHandler> loggingHandlers) { return SpringAiMcpAnnotationProvider.createSyncLoggingConsumers(loggingHandlers); } }