Skip to content

Commit 57ad480

Browse files
authored
Merge 7d16d80 into b654981
2 parents b654981 + 7d16d80 commit 57ad480

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

ydb/core/http_proxy/http_req.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -488,7 +488,7 @@ namespace NKikimr::NHttpProxy {
488488
}
489489
CloudId = cloudIdAndResourceId.first;
490490
HttpContext.ResourceId = ResourceId = cloudIdAndResourceId.second;
491-
HttpContext.ResponseData.YmqIsFifo = queueUrl.EndsWith(".fifo");
491+
HttpContext.ResponseData.YmqIsFifo = AsciiHasSuffixIgnoreCase(queueUrl, ".fifo");
492492
}
493493
} catch (const NKikimr::NSQS::TSQSException& e) {
494494
NYds::EErrorCodes issueCode = NYds::EErrorCodes::OK;

ydb/core/ymq/base/queue_attributes.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -66,7 +66,7 @@ TQueueAttributes TQueueAttributes::FromAttributesAndConfig(const THashMap<TStrin
6666
} else if (config.GetEnableDeadLetterQueues() && name == "RedrivePolicy") {
6767
result.RedrivePolicy = TRedrivePolicy::FromJson(value, config);
6868
if (result.RedrivePolicy.IsValid()) {
69-
if (*result.RedrivePolicy.TargetQueueName && isFifoQueue != result.RedrivePolicy.TargetQueueName->EndsWith(".fifo")) {
69+
if (*result.RedrivePolicy.TargetQueueName && isFifoQueue != AsciiHasSuffixIgnoreCase(result.RedrivePolicy.TargetQueueName, ".fifo")) {
7070
result.ErrorText = "Target dead letter queue should have the same type as source queue.";
7171
} else {
7272
continue;

0 commit comments

Comments
 (0)