[NIFI-6959] JMS Durable subscription does not support filters

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.6.0, 1.7.0, 1.8.0, 1.9.0, 1.10.0, 1.9.1, 1.9.2
• Component/s: Extensions
• Environment: All
• Assignee: Unassigned
• Reporter: john uiterwyk
• Created: 19/Dec/19 06:34
• Updated: 23/Feb/24 20:26
• Resolved: 23/Feb/24 20:26

Description

The ConsumeJMS processor does not support passing filters when creating a topic subscription.

This can be seen in line 72 of JMSConsumer.java, where null is passed for the filter when calling :

return session.createDurableConsumer((Topic) destination, subscriberName, null, JMSConsumer.this.jmsTemplate.isPubSubDomain());

Some JMS implementations require a filter when creating a durable subscription for performance reasons. 

This can be resolved by adding a property 'filter' of type string to the ConsumeJMS processor, and then passing that filter string to the JMSConsumer  method createMessageConsumer and then passing it to the createDurableConsumer method.

Issue Links

• is fixed by: NIFI-7671 Support Message Selector in ConsumeJMS processor