public void sendWithQueue()

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

• 20 lines of code
• 4 McCabe index (conditional complexity)

    public void sendWithQueue(List<MessageQueue> mqs, int messageNum) {
        String tag = NameUtils.getTagName();
        logger.info("Producer start to send messages");
        for (MessageQueue mq : mqs) {
            for (int i = 0; i < messageNum; i++) {
                Message message = MessageFactory.buildOneMessageWithTagAndBody(mq.getTopic(), tag, String.valueOf(i));
                try {
                    SendResult sendResult = producer.send(message, mq);
                    MessageExt messageExt = new MessageExt();
                    messageExt.setMsgId(sendResult.getMsgId());
                    messageExt.setBody(message.getBody());
                    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");
    }