diff --git a/java/dev/enola/ai/mcp/McpLoader.java b/java/dev/enola/ai/mcp/McpLoader.java index bb9433b75..7eff60fff 100644 --- a/java/dev/enola/ai/mcp/McpLoader.java +++ b/java/dev/enola/ai/mcp/McpLoader.java @@ -124,7 +124,7 @@ private static McpSyncClient createSyncClient(McpClientTransport transport, Stri // TODO Make this configurable - but how & from where? // .initializationTimeout(Duration.ofSeconds(7)) // .requestTimeout(Duration.ofSeconds(7)) - .loggingConsumer(new McpServer(origin)) + .loggingConsumer(new Slf4jLoggingConsumer(origin)) .build(); client.initialize(); client.ping(); diff --git a/java/dev/enola/ai/mcp/McpServer.java b/java/dev/enola/ai/mcp/Slf4jLoggingConsumer.java similarity index 77% rename from java/dev/enola/ai/mcp/McpServer.java rename to java/dev/enola/ai/mcp/Slf4jLoggingConsumer.java index f453a2e0e..a6e46d70c 100644 --- a/java/dev/enola/ai/mcp/McpServer.java +++ b/java/dev/enola/ai/mcp/Slf4jLoggingConsumer.java @@ -26,19 +26,22 @@ import java.util.function.Consumer; -class McpServer implements Consumer { +class Slf4jLoggingConsumer implements Consumer { - private static final Logger LOG = LoggerFactory.getLogger(McpServer.class); + // TODO: If https://github.com/modelcontextprotocol/java-sdk/pull/503 + // is accepted and merged, the eventually replace this by that? + // But that doesn't have the origin... hm. Add it? private final String origin; - public McpServer(String origin) { + public Slf4jLoggingConsumer(String origin) { this.origin = origin; } @Override public void accept(LoggingMessageNotification notif) { - LOG.atLevel(convert(notif.level())) + Logger log = LoggerFactory.getLogger(notif.logger()); + log.atLevel(convert(notif.level())) .log("{} : {} : {}", origin, notif.logger(), notif.data()); }