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 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..3f912a1 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,8 @@ 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); - } - if (item instanceof DataEvent) { + LOG.debug("Received comment event: {}", commentEvent); + } else if (item instanceof DataEvent) { DataEvent dataEvent = (DataEvent) item; try { hasReceivedData.set(true); @@ -142,7 +141,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 +152,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()); }