Skip to content

Commit 9acf2a6

Browse files
committed
Fix ExtensibleLoadManagerTest
1 parent f982fe5 commit 9acf2a6

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

lib/ConsumerImpl.cc

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -334,8 +334,8 @@ Result ConsumerImpl::handleCreateConsumer(const ClientConnectionPtr& cnx, Result
334334
return ResultAlreadyClosed;
335335
}
336336

337+
mutexLock.unlock();
337338
LOG_INFO(getName() << "Created consumer on broker " << cnx->cnxString());
338-
setCnx(cnx);
339339
incomingMessages_.clear();
340340
possibleSendToDeadLetterTopicMessages_.clear();
341341
backoff_.reset();

0 commit comments

Comments
 (0)