Skip to content

Commit 924ba24

Browse files
committed
Remove unused parameter from RelayQueueEngine
During the fixes relating to monolithic storage, we left an unused parameter in `RelayQueueEngine::storePush` originally denoting whether the push was out-of-order or not. This is no longer needed, so this patch removes the parameter. Signed-off-by: Patrick M. Niedzielski <[email protected]>
1 parent 1415eb9 commit 924ba24

File tree

2 files changed

+4
-6
lines changed

2 files changed

+4
-6
lines changed

Diff for: src/groups/mqb/mqbblp/mqbblp_relayqueueengine.cpp

+3-4
Original file line numberDiff line numberDiff line change
@@ -1802,7 +1802,7 @@ RelayQueueEngine::push(mqbi::StorageMessageAttributes* attributes,
18021802
ordinalPlusOne = 1 + app->ordinal();
18031803
subscriptions.begin()->setId(ordinalPlusOne);
18041804

1805-
storePush(attributes, msgGUID, appData, subscriptions, true);
1805+
storePush(attributes, msgGUID, appData, subscriptions);
18061806

18071807
// Attempt to deliver
18081808
processAppRedelivery(subQueueId, app);
@@ -1886,7 +1886,7 @@ RelayQueueEngine::push(mqbi::StorageMessageAttributes* attributes,
18861886
if (count) {
18871887
// Pass correct ref count
18881888
attributes->setRefCount(count);
1889-
storePush(attributes, msgGUID, appData, subscriptions, false);
1889+
storePush(attributes, msgGUID, appData, subscriptions);
18901890
}
18911891
return count;
18921892
}
@@ -1927,8 +1927,7 @@ void RelayQueueEngine::storePush(
19271927
mqbi::StorageMessageAttributes* attributes,
19281928
const bmqt::MessageGUID& msgGUID,
19291929
const bsl::shared_ptr<bdlbb::Blob>& appData,
1930-
const bmqp::Protocol::SubQueueInfosArray& subscriptions,
1931-
bool isOutOfOrder)
1930+
const bmqp::Protocol::SubQueueInfosArray& subscriptions)
19321931
{
19331932
if (d_queueState_p->domain()->cluster()->isRemote()) {
19341933
// Save the message along with the subIds in the storage. Note that

Diff for: src/groups/mqb/mqbblp/mqbblp_relayqueueengine.h

+1-2
Original file line numberDiff line numberDiff line change
@@ -350,8 +350,7 @@ class RelayQueueEngine BSLS_KEYWORD_FINAL : public mqbi::QueueEngine {
350350
void storePush(mqbi::StorageMessageAttributes* attributes,
351351
const bmqt::MessageGUID& msgGUID,
352352
const bsl::shared_ptr<bdlbb::Blob>& appData,
353-
const bmqp::Protocol::SubQueueInfosArray& subscriptions,
354-
bool isOutOfOrder);
353+
const bmqp::Protocol::SubQueueInfosArray& subscriptions);
355354

356355
void beforeOneAppRemoved(unsigned int upstreamSubQueueId);
357356

0 commit comments

Comments
 (0)