in java/e2e-v4/src/main/java/org/apache/rocketmq/client/rmq/RMQNormalProducer.java [47:64]
public void send(String topic, int messageNum) {
logger.info("Producer start to send messages");
for (int i = 0; i < messageNum; i++) {
Message message = MessageFactory.buildOneMessage(topic);
try {
SendResult sendResult = producer.send(message);
logger.info(sendResult.toString());
MessageExt messageExt = new MessageExt();
messageExt.setMsgId(sendResult.getMsgId());
logger.info("{}, index: {}", sendResult, i);
this.enqueueMessages.addData(messageExt);
} catch (Exception e) {
logger.error("DefaultMQProducer send message failed");
}
}
logger.info("Producer send messages finished");
}