From 48e0ed41f92bc5664d0c3d2c66f7f6f7e00426ef Mon Sep 17 00:00:00 2001 From: James Kebinger Date: Thu, 16 Oct 2025 11:05:52 -0500 Subject: [PATCH 1/3] Reduce SSE logging verbosity to avoid noise MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Changed SSE event logging from INFO to DEBUG level to reduce log noise: - Comment events now logged at DEBUG instead of INFO - Removed redundant "Unexpected error encountered" INFO log in onError - Changed "Unexpected stream completion" from INFO to DEBUG in onComplete - Changed if/if to if/else if for cleaner event handling These are normal operational events that don't need INFO level logging. 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude --- .../reforge/sdk/internal/SseConfigStreamingSubscriber.java | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/sdk/src/main/java/com/reforge/sdk/internal/SseConfigStreamingSubscriber.java b/sdk/src/main/java/com/reforge/sdk/internal/SseConfigStreamingSubscriber.java index bcbff6b..6f558f3 100644 --- a/sdk/src/main/java/com/reforge/sdk/internal/SseConfigStreamingSubscriber.java +++ b/sdk/src/main/java/com/reforge/sdk/internal/SseConfigStreamingSubscriber.java @@ -109,9 +109,9 @@ public void onSubscribe(Flow.Subscription subscription) { public void onNext(Event item) { if (item instanceof CommentEvent) { CommentEvent commentEvent = (CommentEvent) item; - LOG.info("Received comment event: {}", commentEvent); + LOG.debug("Received comment event: {}", commentEvent); } - if (item instanceof DataEvent) { + else if (item instanceof DataEvent) { DataEvent dataEvent = (DataEvent) item; try { hasReceivedData.set(true); @@ -142,7 +142,6 @@ public void onNext(Event item) { @Override public void onError(Throwable throwable) { - LOG.info("Unexpected error encountered", throwable); if (Optional.ofNullable(throwable.getMessage()).orElse("").contains("GOAWAY")) { LOG.debug("Got GOAWAY on SSE config stream, will restart connection."); } else { @@ -154,7 +153,7 @@ public void onError(Throwable throwable) { @Override public void onComplete() { // this is called even on auth failure - LOG.info("Unexpected stream completion"); + LOG.debug("Unexpected stream completion"); restartHandler.accept(getHasReceivedData()); } From bde2b7080fdb140380c9c15224493dac9e6807b0 Mon Sep 17 00:00:00 2001 From: James Kebinger Date: Thu, 16 Oct 2025 11:05:55 -0500 Subject: [PATCH 2/3] Bump version to 1.0.3 MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Updated version from 1.0.2 to 1.0.3 across all modules. 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude --- micronaut/pom.xml | 2 +- pom.xml | 2 +- sdk/pom.xml | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/micronaut/pom.xml b/micronaut/pom.xml index 3c41e38..1855df7 100644 --- a/micronaut/pom.xml +++ b/micronaut/pom.xml @@ -4,7 +4,7 @@ com.reforge sdk-parent - 1.0.2 + 1.0.3 sdk-micronaut-extension diff --git a/pom.xml b/pom.xml index 7553b46..9f1b014 100644 --- a/pom.xml +++ b/pom.xml @@ -11,7 +11,7 @@ com.reforge sdk-parent - 1.0.2 + 1.0.3 pom Reforge SDK Parent POM Parent POM for Reforge SDK modules providing feature flags, configuration management, and A/B testing capabilities diff --git a/sdk/pom.xml b/sdk/pom.xml index cb3b7df..d3889c4 100644 --- a/sdk/pom.xml +++ b/sdk/pom.xml @@ -4,7 +4,7 @@ com.reforge sdk-parent - 1.0.2 + 1.0.3 sdk From d8d2cacfc4ac0d8d60f1cdcd278bc4a3d6f4d86a Mon Sep 17 00:00:00 2001 From: James Kebinger Date: Thu, 16 Oct 2025 11:24:16 -0500 Subject: [PATCH 3/3] Reformat file --- .../com/reforge/sdk/internal/SseConfigStreamingSubscriber.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/sdk/src/main/java/com/reforge/sdk/internal/SseConfigStreamingSubscriber.java b/sdk/src/main/java/com/reforge/sdk/internal/SseConfigStreamingSubscriber.java index 6f558f3..3f912a1 100644 --- a/sdk/src/main/java/com/reforge/sdk/internal/SseConfigStreamingSubscriber.java +++ b/sdk/src/main/java/com/reforge/sdk/internal/SseConfigStreamingSubscriber.java @@ -110,8 +110,7 @@ public void onNext(Event item) { if (item instanceof CommentEvent) { CommentEvent commentEvent = (CommentEvent) item; LOG.debug("Received comment event: {}", commentEvent); - } - else if (item instanceof DataEvent) { + } else if (item instanceof DataEvent) { DataEvent dataEvent = (DataEvent) item; try { hasReceivedData.set(true);