public void add()

in src/main/java/org/apache/sling/jms/impl/JMSQueueManager.java [104:123]

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

    public void add(@NotNull Types.QueueName name, @NotNull Map<String, Object> message) {
        Session session = null;
        try {
            session = connection.createSession(true, Session.AUTO_ACKNOWLEDGE);
            //TODO Instead of copy do addition at JSON writer level
            Map<String, Object> msgCopy = new HashMap<>(message);
            msgCopy.put(NRETRIES, 0L); // set the number of retries to 0.
            TextMessage textMessage = session.createTextMessage(Json.toJson(msgCopy));
            textMessage.setJMSType(JMSMessageTypes.JSON.toString());
            LOGGER.info("Sending to {} message {} ", name, textMessage);
            session.createProducer(session.createQueue(name.toString())).send(textMessage);
            session.commit();
            session.close();
        } catch (JMSException e) {
            LOGGER.error("Unable to send message to queue "+name, e);
            close(session);

        }

    }