in java/e2e-v4/src/main/java/org/apache/rocketmq/client/rmq/RMQNormalProducer.java [386:401]
public void send(Message message) {
SendResult sendResult = null;
try {
sendResult = producer.send(message);
} catch (MQClientException e) {
e.printStackTrace();
} catch (RemotingException e) {
e.printStackTrace();
} catch (MQBrokerException e) {
e.printStackTrace();
} catch (InterruptedException e) {
e.printStackTrace();
}
logger.info(sendResult.toString());
this.enqueueMessages.addData((MessageExt)message);
}