Skip to content

Commit a56ab71

Browse files
committed
Moved commit "Move unacknowledged messages back to OriginalMessagesToPassDown queue" from ydb repo
1 parent db347eb commit a56ab71

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

src/client/federated_topic/impl/federated_write_session.cpp

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -174,6 +174,14 @@ std::shared_ptr<NTopic::IWriteSession> TFederatedWriteSessionImpl::OpenSubsessio
174174
}
175175
});
176176

177+
{
178+
// Unacknowledged messages should be resent.
179+
for (auto& msg : OriginalMessagesToPassDown) {
180+
OriginalMessagesToGetAck.emplace_back(std::move(msg));
181+
}
182+
OriginalMessagesToPassDown = std::move(OriginalMessagesToGetAck);
183+
}
184+
177185
NTopic::TWriteSessionSettings wsSettings = Settings;
178186
wsSettings
179187
// .MaxMemoryUsage(Settings.MaxMemoryUsage_) // to fix if split not by half on creation

0 commit comments

Comments
 (0)