Skip to content

Commit d0639c9

Browse files
committed
no log
1 parent e7562cb commit d0639c9

1 file changed

Lines changed: 0 additions & 7 deletions

File tree

lib/ConsumerImpl.cc

Lines changed: 0 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -196,13 +196,6 @@ ConsumerImpl::~ConsumerImpl() {
196196
cnx->sendRequestWithId(Commands::newCloseConsumer(consumerId_, requestId), requestId,
197197
"CLOSE_CONSUMER");
198198
cnx->removeConsumer(consumerId_);
199-
if (client) {
200-
LOG_DEBUG(consumerStr_ << "Closed consumer for race condition: " << consumerId_);
201-
}
202-
} else {
203-
if (client) {
204-
LOG_WARN(consumerStr_ << "Client is destroyed and cannot send the CloseConsumer command");
205-
}
206199
}
207200
}
208201
internalShutdown();

0 commit comments

Comments
 (0)