public void send()

in java/e2e-v4/src/main/java/org/apache/rocketmq/client/rmq/RMQNormalProducer.java [66:81]

• 16 lines of code
• 3 McCabe index (conditional complexity)

    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.buildOneMessageWithTag(topic, tag);
            try {
                SendResult sendResult = producer.send(message);
                MessageExt messageExt = new MessageExt();
                messageExt.setMsgId(sendResult.getMsgId());
                logger.info("{}, index: {}, tag: {}", sendResult, i, tag);
                this.enqueueMessages.addData(messageExt);
            } catch (Exception e) {
                logger.error("DefaultMQProducer send message failed");
            }
        }
        logger.info("Producer send messages finished");
    }