public QueueReaderHolder()

in src/main/java/org/apache/sling/jms/impl/JMSQueueManager.java [171:192]

19 lines of code
3 McCabe index (conditional complexity)


        public QueueReaderHolder(Connection connection, QueueReader queueReader, Map<String, Object> properties) {
            try {
                LOGGER.info("Creating Queue holder for {} ", queueReader.getClass());
                String name = (String) properties.get(QueueReader.QUEUE_NAME_PROP);
                checkNotNull(name, "A valid queue name as property " + QueueReader.QUEUE_NAME_PROP + " is required for QueueReader registration");
                if (queueReader instanceof MessageFilter) {
                    session = new JMSQueueSession(connection, queueReader, name, (MessageFilter) queueReader, true, 5);
                } else {
                    session = new JMSQueueSession(connection, queueReader, name, new MessageFilter() {
                        @Override
                        public boolean accept(Types.Name name, Map<String, Object> mapMessage) {
                            return true;
                        }

                    }, true, 5);

                }
            } catch (JMSException e) {
                throw new IllegalArgumentException("Unable to register QueueReader with JMS ",e);
            }

        }