if (dataChunk.HasCodec() && dataChunk.GetCodec() != NPersQueueCommon::RAW) {
const NYdb::NTopic::ICodec* codec = GetCodec(static_cast<NPersQueueCommon::ECodec>(dataChunk.GetCodec()));
if (codec == nullptr) {
return ReplyAndPassAway(GetHTTPINTERNALERROR("text/plain", "Message decompression failed"));
}
setData(*messageProto, std::move(codec->Decompress(dataChunk.GetData())));
} else {
setData(*messageProto, std::move(*dataChunk.MutableData()));
}