Skip to content

Commit 8ecb359

Browse files
committed
fixup: more log tweaks
Signed-off-by: Todd Baert <[email protected]>
1 parent 7bf97ff commit 8ecb359

File tree

1 file changed

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

1 file changed

+4
-2
lines changed

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

+4-2
Original file line numberDiff line numberDiff line change
@@ -158,8 +158,10 @@ private void observeSyncStream() throws InterruptedException {
158158
Throwable streamException = taken.getError();
159159
if (streamException != null) {
160160
log.debug("Exception in stream RPC, streamException {}, will restart", streamException);
161-
if (!outgoingQueue.offer(
162-
new QueuePayload(QueuePayloadType.ERROR, "Error from stream: ", metadataResponse))) {
161+
if (!outgoingQueue.offer(new QueuePayload(
162+
QueuePayloadType.ERROR,
163+
String.format("Error from stream: %s", streamException.getMessage()),
164+
metadataResponse))) {
163165
log.error("Failed to convey ERROR status, queue is full");
164166
}
165167
break;

0 commit comments

Comments
 (0)