Skip to content

Commit

Permalink
commented out maxDeliveryAttempts range check
Browse files Browse the repository at this point in the history
Signed-off-by: Emelia Lei <wlei29@bloomberg.net>
  • Loading branch information
emelialei88 committed Nov 1, 2024
1 parent 198843c commit 687408a
Showing 1 changed file with 19 additions and 18 deletions.
37 changes: 19 additions & 18 deletions src/groups/mqb/mqbblp/mqbblp_domain.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -204,23 +204,24 @@ int normalizeConfig(mqbconfm::Domain* defn,
const unsigned int minValue = highThresh + 1;

// 'maxDeliveryAttempts' can be zero, which indicates unlimited attempts.
if (maxDeliveryAttempts && maxDeliveryAttempts < minValue) {
errorDescription << domain.cluster()->name() << ", " << domain.name()
<< ": maxDeliveryAttempts is less than message "
"throttling high threshold value. "
"maxDeliveryAttempts: "
<< maxDeliveryAttempts
<< ", highThreshold: " << highThresh
<< ". Updated "
"maxDeliveryAttempts to have a value of "
<< minValue
<< ". Please update the value of "
"maxDeliveryAttempts in this domain's config to "
"have a value of at least "
<< minValue << ".\n";
defn->maxDeliveryAttempts() = minValue;
++updatedValues;
}
// if (maxDeliveryAttempts && maxDeliveryAttempts < minValue) {
// errorDescription << domain.cluster()->name() << ", " <<
// domain.name()
// << ": maxDeliveryAttempts is less than message "
// "throttling high threshold value. "
// "maxDeliveryAttempts: "
// << maxDeliveryAttempts
// << ", highThreshold: " << highThresh
// << ". Updated "
// "maxDeliveryAttempts to have a value of "
// << minValue
// << ". Please update the value of "
// "maxDeliveryAttempts in this domain's config to
// " "have a value of at least "
// << minValue << ".\n";
// defn->maxDeliveryAttempts() = minValue;
// ++updatedValues;
// }

if (defn->mode().isBroadcastValue() &&
defn->consistency().selectionId() ==
Expand Down Expand Up @@ -515,7 +516,7 @@ int Domain::configure(bsl::ostream& errorDescription,
// Invoke callbacks for each added and removed ID on each queue.
bsl::unordered_set<bsl::string>::const_iterator it =
addedIds.cbegin();
QueueMap::const_iterator qIt;
QueueMap::const_iterator qIt;
for (; it != addedIds.cend(); it++) {
for (qIt = d_queues.cbegin(); qIt != d_queues.cend(); ++qIt) {
d_dispatcher_p->execute(
Expand Down

0 comments on commit 687408a

Please sign in to comment.