private static void receiveMessages()

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

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

    private static void receiveMessages(Session session, MessageConsumer consumer) throws JMSException {
        consumer.setMessageListener(new MessageListener() {
            public void onMessage(Message message) {
                try {
                    if (message instanceof TextMessage) {
                        TextMessage msg = (TextMessage) message;
                        System.out.println(String.format("%s - Receiver: received '%s'", df.format(new Date()), msg.getText()));
                    } else if (message instanceof BytesMessage) {
                        BytesMessage msg = (BytesMessage) message;
                        byte[] content = new byte[(int)msg.getBodyLength()];
                        msg.readBytes(content);
                        System.out.println(String.format("%s - Receiver: received '%s'", df.format(new Date()), new String(content)));
                    } else {
                        System.out.println(String.format("%s - Receiver: received '%s'", df.format(new Date()), message));
                    }
                    message.acknowledge();
                } catch (JMSException e) {
                    throw new RuntimeException(e);
                }
            }});
    }