Skip to content

Commit e3d3ce7

Browse files
committed
Log message offset in case of decoding error
1 parent 9b61b44 commit e3d3ce7

File tree

1 file changed

+8
-3
lines changed

1 file changed

+8
-3
lines changed

src/main/java/com/rabbitmq/stream/impl/ServerFrameHandler.java

+8-3
Original file line numberDiff line numberDiff line change
@@ -332,9 +332,14 @@ static int handleMessage(
332332
if (ignore && Long.compareUnsigned(offset, offsetLimit) < 0) {
333333
messageIgnored.set(true);
334334
} else {
335-
Message message = codec.decode(data);
336-
messageListener.handle(
337-
subscriptionId, offset, chunkTimestamp, committedChunkId, chunkContext, message);
335+
try {
336+
Message message = codec.decode(data);
337+
messageListener.handle(
338+
subscriptionId, offset, chunkTimestamp, committedChunkId, chunkContext, message);
339+
} catch (RuntimeException e) {
340+
LOGGER.warn("Error while decoding message at offset {}", offset, e);
341+
throw e;
342+
}
338343
}
339344
return read;
340345
}

0 commit comments

Comments
 (0)