[BEAM-1127] JmsIO should create an unique source in case of topic

• Type: Bug
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Fix Version/s: 0.6.0
• Component/s: io-java-jms
• Assignee: Jean-Baptiste Onofré
• Reporter: Jean-Baptiste Onofré
• Created: 10/Dec/16 16:12
• Updated: 16/May/20 13:56
• Resolved: 03/Feb/17 11:39

Description

The JmsIO deals with both queue and topic.

Currently, we create multiple sources depending of the desired number of splits.
If this behavior is correct when using a queue (we have concurrent consumers of the queue), it's basically wrong when using a topic (we have multiple subscribers, so potentially duplicated message).

When using a topic, the JmsIO should use an unique source (to avoid messages duplication).

Issue Links

• links to: GitHub Pull Request #1573
• links to: GitHub Pull Request #1573