[
https://issues.apache.org/jira/browse/BEAM-1127?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15742714#comment-15742714
]
Jean-Baptiste Onofré commented on BEAM-1127:
--------------------------------------------
Yes, but it would require some specific configuration on the broker side.
In ActiveMQ, it can be achieved with a VirtualTopic:
http://activemq.apache.org/virtual-destinations.html
Maybe, we can simply remove the topic support in the {{JmsIO}} in that case
(even if I think it's pretty important to support topic subscription).
> JmsIO should create an unique source in case of topic
> -----------------------------------------------------
>
> Key: BEAM-1127
> URL: https://issues.apache.org/jira/browse/BEAM-1127
> Project: Beam
> Issue Type: Bug
> Components: sdk-java-extensions
> Reporter: Jean-Baptiste Onofré
> Assignee: Jean-Baptiste Onofré
>
> 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).
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
