[NIFI-7015] ConsumeJMS should handle any message type

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.11.0
• Component/s: Extensions
• Assignee: Tamas Palfy
• Reporter: Pierre Villard
• Created: 14/Jan/20 14:35
• Updated: 23/Jun/20 12:07
• Resolved: 14/Jan/20 22:08

Description

At the moment ConsumeJMS only handles TextMessage and ByteMessage. Support for StreamMessage, ObjectMessage and MapMessage should be added. Besides, there could be additional message types implementing the interface like ActiveMQBlobMessage.

Supporting this would require extra work as this depends of the JMS providers. A property ERROR_QUEUE should be added to re-route the messages into another queue when there is no way to process the messages in the processor so that unsupported and/or malformed messages are still acknowledged and moved somewhere else without further blocking message processing.

Issue Links

• links to: GitHub Pull Request #3987