public FilteredTopicSubscriber()

in src/main/java/org/apache/sling/jms/impl/JMSTopicManager.java [208:219]

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

        public FilteredTopicSubscriber(@NotNull Session session,
                                       @NotNull Subscriber subscriber,
                                       @NotNull String[] topicNames,
                                       @NotNull MessageFilter filter) throws JMSException {
            this.subscriber = subscriber;
            this.filter = filter;
            for (String t : topicNames) {
                MessageConsumer c = session.createConsumer(session.createTopic(t));
                c.setMessageListener(this);
                consumers.add(c);
            }
        }