Skip to content

Commit 271d004

Browse files
committed
Remove unused code
1 parent 160f421 commit 271d004

File tree

1 file changed

+0
-2
lines changed

1 file changed

+0
-2
lines changed

lib/ConsumerImpl.cc

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -296,8 +296,6 @@ Result ConsumerImpl::handleCreateConsumer(const ClientConnectionPtr& cnx, Result
296296
{
297297
Lock mutexLock(mutex_);
298298
if (!changeToReadyState()) {
299-
resetCnx();
300-
// The consumer has been
301299
auto client = client_.lock();
302300
if (client) {
303301
LOG_INFO(getName() << "Closing subscribed consumer since it was already closed");

0 commit comments

Comments
 (0)