[Java Client] Remove invalid call to Thread.currentThread().interrupt();
Thread.currentThread().interrupt() shouldn't be called here.
- it must only be called when handling an InterruptedException.
- this looks like a copy-paste bug introduced in
@@ -1799,7 +1799,6 @@ public class ProducerImpl<T> extends ProducerBase<T> implements TimerTask, Conne
processOpSendMsg(opSendMsg);
}
} catch (PulsarClientException e) {
- Thread.currentThread().interrupt();
semaphoreRelease(batchMessageContainer.getNumMessagesInBatch());
} catch (Throwable t) {
semaphoreRelease(batchMessageContainer.getNumMessagesInBatch());
