Skip to content

Commit

Permalink
Fix after rebase
Browse files Browse the repository at this point in the history
  • Loading branch information
pnv1 committed Jan 23, 2025
1 parent 22ad5a4 commit b169df1
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -426,7 +426,7 @@ private void onInitResponse(YdbTopic.StreamWriteMessage.InitResponse response) {
// TODO: remember supported codecs for further validation
if (!sentMessages.isEmpty()) {
// resending messages that haven't received acks yet
logger.info("[{}] Resending {} messages that haven't received ack's yet into new session...", fullId,
logger.info("[{}] Resending {} messages that haven't received ack's yet into new session...", streamId,
sentMessages.size());
messageSender.sendMessages(sentMessages);
}
Expand Down

0 comments on commit b169df1

Please sign in to comment.