private static void sendMessages()

in amazon-mq-client/src/main/java/com/aws/sample/amazonmq/AmazonMqClient.java [96:115]

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

    private static void sendMessages(Session session, MessageProducer queueMessageProducer, long ttl, String name, int interval, int deliveryMode, WrapInt count) throws JMSException {
        String destination = queueMessageProducer.getDestination().toString();

        while (true) {
            count.v++;
            String id = UUID.randomUUID().toString();
            TextMessage message = session.createTextMessage(String.format("[%s] [%s] Message number %s", destination, name, count.v));
            message.setJMSMessageID(id);
            message.setJMSCorrelationID(id);
            queueMessageProducer.send(message, deliveryMode, 0, ttl);
            if (interval > 0) {
                System.out.println(String.format("%s - Sender: sent '%s'", df.format(new Date()), message.getText()));
                try {
                    Thread.sleep(interval);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
    }