diff options
Diffstat (limited to 'ydb/services/sqs_topic/create_queue.cpp')
| -rw-r--r-- | ydb/services/sqs_topic/create_queue.cpp | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/ydb/services/sqs_topic/create_queue.cpp b/ydb/services/sqs_topic/create_queue.cpp index 91a92178771..8d88c8e777d 100644 --- a/ydb/services/sqs_topic/create_queue.cpp +++ b/ydb/services/sqs_topic/create_queue.cpp @@ -169,9 +169,9 @@ namespace NKikimr::NSqsTopic::V1 { topicRequest.mutable_supported_codecs()->add_codecs(Ydb::Topic::CODEC_RAW); topicRequest.set_content_based_deduplication(QueueAttributes.ContentBasedDeduplication.GetOrElse(false)); - if (QueueAttributes.ContentBasedDeduplication.GetOrElse(false)) { - topicRequest.set_partition_write_speed_messages_per_second(NPQ::CONTENT_BASED_DEDUPLICATION_MESSAGE_LIMIT); - topicRequest.set_partition_write_burst_messages(NPQ::CONTENT_BASED_DEDUPLICATION_MESSAGE_BURST); + if (QueueAttributes.FifoQueue) { + topicRequest.set_partition_write_speed_messages_per_second(NPQ::FIFO_PARTITION_WRITE_SPEED_MESSAGES_PER_SECOND); + topicRequest.set_partition_write_burst_messages(NPQ::FIFO_PARTITION_WRITE_BURST_MESSAGES); } AddConsumerToRequest(topicRequest.add_consumers()); |
