private static void sendMessages()

in amqp-client/src/main/java/com/aws/sample/amazonmq/AMQPClient.java [94:113]

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

    private static void sendMessages(Session session, MessageProducer messageProducer, String name, int interval, int deliveryMode, WrapInt count) throws JMSException {
        String destination = messageProducer.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);
            messageProducer.send(message, deliveryMode, 0, -1);
            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();
                }
            }
        }
    }