Skip to content

Commit 2c213cf

Browse files
jonnxuShannonDing
authored andcommitted
Wrong lock flag for pull request in orderly consume when unlock bug (#175)
1 parent f8e2faf commit 2c213cf

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/consumer/Rebalance.cpp

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -277,7 +277,7 @@ void Rebalance::unlockAll(bool oneway) {
277277
PullRequest* pullreq = getPullRequest(mqs[i]);
278278
if (pullreq) {
279279
LOG_INFO("unlockBatchMQ success of mq:%s", mqs[i].toString().c_str());
280-
pullreq->setLocked(true);
280+
pullreq->setLocked(false);
281281
} else {
282282
LOG_ERROR("unlockBatchMQ fails of mq:%s", mqs[i].toString().c_str());
283283
}
@@ -311,7 +311,7 @@ void Rebalance::unlock(MQMessageQueue mq) {
311311
PullRequest* pullreq = getPullRequest(mqs[i]);
312312
if (pullreq) {
313313
LOG_INFO("unlock success of mq:%s", mqs[i].toString().c_str());
314-
pullreq->setLocked(true);
314+
pullreq->setLocked(false);
315315
} else {
316316
LOG_ERROR("unlock fails of mq:%s", mqs[i].toString().c_str());
317317
}

0 commit comments

Comments
 (0)