public void sendOnewayWithTagAndBody()

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

• 17 lines of code
• 5 McCabe index (conditional complexity)

    public void sendOnewayWithTagAndBody(String topic, String tag, String messageBody, int messageNum) {
        logger.info("Producer start to OneWay send message");
        for (int i = 0; i < messageNum; i++) {
            Message message = MessageFactory.buildOneMessageWithTagAndBody(topic, tag, messageBody);
            try {
                producer.sendOneway(message);
            } catch (MQClientException e) {
                e.printStackTrace();
            } catch (RemotingException e) {
                e.printStackTrace();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            //logger.info("topic: {}, msgId: {}, index: {}, tag: {}, body:{}", topic, message.getMsgID(), i, tag, messageBody);
            this.enqueueMessages.addData((MessageExt)message);
        }
        logger.info("Producer send messages finished");
    }