<BUG>messageConsumer = session.createDurableSubscriber((Topic) destination, subscriberName, messageSelector, isNoLocal);} else {messageConsumer = session.createConsumer(destination, messageSelector, isNoLocal);}</BUG><CONTEXT>final String messageSelector = jmsConfig.getMessageSelector();final String subscriberName = jmsConfig.getSubscriberName();final boolean isDurable = jmsConfig.isDurable(); // TRUE if not set, special case for Durable topicfinal boolean isNoLocal = jmsConfig.isNoLocal();if (destination instanceof Topic && isDurable) {<extra_id_0>messageListener.setSession(session);</CONTEXT>
LOG.info("Created durable subscriber for {}", jmsConfig.getDestination());LOG.info("Created non-durable subscriber for {}", jmsConfig.getDestination());}