public JMSQueueSession()

in src/main/java/org/apache/sling/jms/impl/JMSQueueManager.java [229:240]

• 12 lines of code
• 1 McCabe index (conditional complexity)

        public JMSQueueSession(Connection connection, QueueReader queueReader, String name,  MessageFilter messageFilter, boolean retryByRequeue, int maxRetries) throws JMSException {
            this.queueReader = queueReader;
            this.name = name;
            this.messageFilter = messageFilter;
            this.retryByRequeue = retryByRequeue;
            this.maxRetries = maxRetries;
            session = connection.createSession(true, Session.AUTO_ACKNOWLEDGE);
            Queue queue = session.createQueue(name);
            queueConsumer = session.createConsumer(queue);
            queueProducer = session.createProducer(queue);
            queueConsumer.setMessageListener(this);
        }