public void sendDelay()

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

• 24 lines of code
• 6 McCabe index (conditional complexity)

    public void sendDelay(String topic, int delayLevel, int messageNum) {
        logger.info("Producer start to send delay messages");
        for (int i = 0; i < messageNum; i++) {
            Message message = MessageFactory.buildOneMessageWithDelayTimeLevel(topic, delayLevel);
            SendResult sendResult = null;
            MessageExt messageExt = null;
            try {
                sendResult = producer.send(message);
                logger.info(sendResult.toString());

                messageExt = new MessageExt();
                messageExt.setMsgId(sendResult.getMsgId());
                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 delay messages finished");
    }