in java/e2e-v4/src/main/java/org/apache/rocketmq/client/rmq/RMQTransactionProducer.java [50:74]
public void send(String topic, String tag, int messageNum) {
logger.info("Producer start to send messages");
for (int i = 0; i < messageNum; i++) {
//Message message = MessageFactory.buildOneMessageWithTagAndBody(topic, tag, String.valueOf(i));
Message message = MessageFactory.buildOneMessageWithTag(topic, tag);
SendResult sendResult = null;
MessageExt messageExt = null;
try {
sendResult = producer.send(message);
messageExt = new MessageExt();
messageExt.setMsgId(sendResult.getMsgId());
logger.info("{}, index: {}, tag: {}", sendResult, i, tag);
this.enqueueMessages.addData(messageExt);
} catch (MQClientException e) {
e.printStackTrace();
} catch (RemotingException e) {
e.printStackTrace();
} catch (MQBrokerException e) {
e.printStackTrace();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
logger.info("Producer send messages finished");
}