diff options
| author | alexbogo <alexbogo@ydb.tech> | 2022-12-01 16:42:29 +0300 |
|---|---|---|
| committer | alexbogo <alexbogo@ydb.tech> | 2022-12-01 16:42:29 +0300 |
| commit | f8d315d838d9d5f3fda70e2f30e29ac6f38315c6 (patch) | |
| tree | e955bb233bb8ca51dac3dbc9140bd25b1e788e30 | |
| parent | 8d2a5a58b600a3afa793ad2fef0d2a6befa1bd20 (diff) | |
| download | ydb-f8d315d838d9d5f3fda70e2f30e29ac6f38315c6.tar.gz | |
[ymq] fix dlq queries for different tables format
init
| -rw-r--r-- | ydb/core/ymq/queues/common/db_queries_maker.cpp | 2 | ||||
| -rw-r--r-- | ydb/core/ymq/queues/common/db_queries_maker.h | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/ydb/core/ymq/queues/common/db_queries_maker.cpp b/ydb/core/ymq/queues/common/db_queries_maker.cpp index abaedf50398..87964e7ce38 100644 --- a/ydb/core/ymq/queues/common/db_queries_maker.cpp +++ b/ydb/core/ymq/queues/common/db_queries_maker.cpp @@ -27,7 +27,7 @@ namespace NKikimr::NSQS { }
const char* TDbQueriesMaker::GetDlqStateKeys() const {
- if (TablesFormat_ == 0) {
+ if (DlqTablesFormat_ == 0) {
return IsFifo_ ? "'('State (Uint64 '0))" : "'('State dlqShard)";
}
return IsFifo_ ? GetDlqIdKeys() : DLQ_STD_STATE_KEYS;
diff --git a/ydb/core/ymq/queues/common/db_queries_maker.h b/ydb/core/ymq/queues/common/db_queries_maker.h index 8597ad058d7..06dc79604b5 100644 --- a/ydb/core/ymq/queues/common/db_queries_maker.h +++ b/ydb/core/ymq/queues/common/db_queries_maker.h @@ -104,7 +104,7 @@ private: return TablesFormat_ == 1 ? QUEUE_ID_AND_SHARD_KEYS : "";
}
const char* GetDlqIdAndShardKeys() const {
- return TablesFormat_ == 1 ? DLQ_ID_AND_SHARD_KEYS : "";
+ return DlqTablesFormat_ == 1 ? DLQ_ID_AND_SHARD_KEYS : "";
}
const char* GetShardColumnName() const {
return TablesFormat_ == 1 ? "Shard" : "State";
|