Skip to content

Commit a10ccbf

Browse files
committed
fix(flagd): Fix checkstzle issues
Signed-off-by: Guido Breitenhuber <[email protected]>
1 parent 77c04a9 commit a10ccbf

File tree

1 file changed

+4
-3
lines changed
  • providers/flagd/src/main/java/dev/openfeature/contrib/providers/flagd/resolver/process/storage/connector/sync

1 file changed

+4
-3
lines changed

providers/flagd/src/main/java/dev/openfeature/contrib/providers/flagd/resolver/process/storage/connector/sync/SyncStreamQueueSource.java

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -15,13 +15,13 @@
1515
import dev.openfeature.flagd.grpc.sync.Sync.SyncFlagsRequest;
1616
import dev.openfeature.flagd.grpc.sync.Sync.SyncFlagsResponse;
1717
import edu.umd.cs.findbugs.annotations.SuppressFBWarnings;
18+
import io.grpc.Context;
19+
import io.grpc.stub.StreamObserver;
1820
import java.util.concurrent.BlockingQueue;
1921
import java.util.concurrent.LinkedBlockingQueue;
2022
import java.util.concurrent.TimeUnit;
2123
import java.util.concurrent.atomic.AtomicBoolean;
2224
import java.util.function.Consumer;
23-
import io.grpc.Context;
24-
import io.grpc.stub.StreamObserver;
2525
import lombok.extern.slf4j.Slf4j;
2626

2727
/**
@@ -214,7 +214,8 @@ public void onError(Throwable throwable) {
214214
try {
215215
String message = throwable != null ? throwable.getMessage() : "unknown";
216216
log.debug("Stream error: {}, will restart", message, throwable);
217-
if (!outgoingQueue.offer(new QueuePayload(QueuePayloadType.ERROR, String.format("Error from stream: %s", message), null))) {
217+
if (!outgoingQueue.offer(new QueuePayload(QueuePayloadType.ERROR,
218+
String.format("Error from stream: %s", message), null))) {
218219
log.error("Failed to convey ERROR status, queue is full");
219220
}
220221
} finally {

0 commit comments

Comments
 (0)