Skip to content

Commit ba0e34e

Browse files
authored
Merge 5b18ded into 1237379
2 parents 1237379 + 5b18ded commit ba0e34e

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-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: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,7 @@
22
#include "queue_attributes.h"
33

44
#include <util/generic/utility.h>
5+
#include <util/string/ascii.h>
56
#include <util/string/cast.h>
67
#include <util/string/printf.h>
78

@@ -66,7 +67,7 @@ TQueueAttributes TQueueAttributes::FromAttributesAndConfig(const THashMap<TStrin
6667
} else if (config.GetEnableDeadLetterQueues() && name == "RedrivePolicy") {
6768
result.RedrivePolicy = TRedrivePolicy::FromJson(value, config);
6869
if (result.RedrivePolicy.IsValid()) {
69-
if (*result.RedrivePolicy.TargetQueueName && isFifoQueue != result.RedrivePolicy.TargetQueueName->EndsWith(".fifo")) {
70+
if (*result.RedrivePolicy.TargetQueueName && isFifoQueue != AsciiHasSuffixIgnoreCase(*result.RedrivePolicy.TargetQueueName, ".fifo")) {
7071
result.ErrorText = "Target dead letter queue should have the same type as source queue.";
7172
} else {
7273
continue;

0 commit comments

Comments
 (0)