talen0702 opened a new issue #3370:
URL: https://github.com/apache/rocketmq/issues/3370
在DefaultMQProducerImpl的sendDefaultImpl这个方法中，如果出现RemotingException或MQClientException异常，会打印信息，但异常信息是一样的，也没有特别的逻辑，是否可以合成一个或打印信息加以区分，会更容易理解，谢谢
` } catch (RemotingException | MQClientException e) {
endTimestamp = System.currentTimeMillis();
this.updateFaultItem(mq.getBrokerName(),
endTimestamp - beginTimestampPrev, true);
log.warn(String.format("sendKernelImpl exception,
resend at once, InvokeID: %s, RT: %sms, Broker: %s", invokeID, endTimestamp -
beginTimestampPrev, mq), e);
log.warn(msg.toString());
exception = e;
continue;
// } catch (MQClientException e) {
// endTimestamp = System.currentTimeMillis();
// this.updateFaultItem(mq.getBrokerName(),
endTimestamp - beginTimestampPrev, true);
// log.warn(String.format("sendKernelImpl exception,
resend at once, InvokeID: %s, RT: %sms, Broker: %s", invokeID, endTimestamp -
beginTimestampPrev, mq), e);
// log.warn(msg.toString());
// exception = e;
// continue;
} catch (MQBrokerException e) {`
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
