fix(sync): downgrade noisy SSE transmission logs to DEBUG
Some checks failed
Deploy to OCIWP / deploy (push) Has been cancelled
Some checks failed
Deploy to OCIWP / deploy (push) Has been cancelled
This commit is contained in:
@@ -210,13 +210,13 @@ public class CustomWebMvcSseServerTransportProvider implements McpServerTranspor
|
|||||||
@Override
|
@Override
|
||||||
public Mono<Void> sendMessage(McpSchema.JSONRPCMessage message) {
|
public Mono<Void> sendMessage(McpSchema.JSONRPCMessage message) {
|
||||||
return Mono.fromRunnable(() -> {
|
return Mono.fromRunnable(() -> {
|
||||||
log.info("Sending message to SSE stream: " + message.getClass().getName());
|
log.debug("Sending message to SSE stream: {}", message.getClass().getName());
|
||||||
try {
|
try {
|
||||||
String json = objectMapper.writeValueAsString(message);
|
String json = objectMapper.writeValueAsString(message);
|
||||||
log.info("Serialized message: " + json);
|
log.debug("Serialized message: {}", json);
|
||||||
if (this.emitter != null) {
|
if (this.emitter != null) {
|
||||||
this.emitter.send(org.springframework.web.servlet.mvc.method.annotation.SseEmitter.event().name("message").data(json));
|
this.emitter.send(org.springframework.web.servlet.mvc.method.annotation.SseEmitter.event().name("message").data(json));
|
||||||
log.info("Message successfully sent to SSE emitter");
|
log.debug("Message successfully sent to SSE emitter");
|
||||||
|
|
||||||
// Custom 프로토콜: 1회 요청당 1응답 후 종료 (스트림을 닫아버림)
|
// Custom 프로토콜: 1회 요청당 1응답 후 종료 (스트림을 닫아버림)
|
||||||
// 클라이언트가 한 번의 POST 후 응답을 받고 연결을 끊기 때문
|
// 클라이언트가 한 번의 POST 후 응답을 받고 연결을 끊기 때문
|
||||||
|
|||||||
Reference in New Issue
Block a user