summaryrefslogtreecommitdiffstats
path: root/ydb/services/sqs_topic/create_queue.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'ydb/services/sqs_topic/create_queue.cpp')
-rw-r--r--ydb/services/sqs_topic/create_queue.cpp6
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());