diff options
| author | alexbogo <alexbogo@ydb.tech> | 2022-10-13 12:35:07 +0300 |
|---|---|---|
| committer | alexbogo <alexbogo@ydb.tech> | 2022-10-13 12:35:07 +0300 |
| commit | 9cc5d1d5dbe564b03d97a801aa7ad883628ee531 (patch) | |
| tree | 81cbb5e168a5f96118c9465e7ddc0ed43eacd0ac | |
| parent | 32a0e5cc7383b8a0bb3e4737026762339954aeb2 (diff) | |
| download | ydb-9cc5d1d5dbe564b03d97a801aa7ad883628ee531.tar.gz | |
[ymq] correct process of double CreateQueueRequest in cloud mode
init
| -rw-r--r-- | ydb/core/ymq/actor/queue_schema.cpp | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/ydb/core/ymq/actor/queue_schema.cpp b/ydb/core/ymq/actor/queue_schema.cpp index 90bcb11c45c..616843185e3 100644 --- a/ydb/core/ymq/actor/queue_schema.cpp +++ b/ydb/core/ymq/actor/queue_schema.cpp @@ -1065,10 +1065,11 @@ void TCreateQueueSchemaActorV2::MatchQueueAttributes( ) { Become(&TCreateQueueSchemaActorV2::MatchAttributes); + const TString existingQueueName = IsCloudMode_ ? ExistingQueueResourceId_ : QueuePath_.QueueName; TDbQueriesMaker queryMaker( Cfg().GetRoot(), QueuePath_.UserName, - QueuePath_.QueueName, + existingQueueName, currentVersion, IsFifo_, 0, @@ -1085,7 +1086,7 @@ void TCreateQueueSchemaActorV2::MatchQueueAttributes( TParameters(trans->MutableParams()->MutableProto()) .Uint64("QUEUE_ID_NUMBER", currentVersion) .Uint64("QUEUE_ID_NUMBER_HASH", GetKeysHash(currentVersion)) - .Utf8("NAME", IsCloudMode_ ? ExistingQueueResourceId_ : QueuePath_.QueueName) + .Utf8("NAME", existingQueueName) .Bool("FIFO", IsFifo_) .Uint64("SHARDS", RequiredShardsCount_) .Uint64("PARTITIONS", Request_.GetPartitions()) |