[
https://issues.apache.org/jira/browse/FLINK-4025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15316571#comment-15316571
]
Dominik Bruhn commented on FLINK-4025:
--------------------------------------
No, actually they address different problems although one needs to modify the
other PR if the other one was merged:
FLINK-3763 makes the currently existing configuration parameters easier
accessible using an own class
My PR adds the possiblity to customize what happens when the RMQSource creates
the queue. That is still not possible on the mentioned FLINK-3763.
> Add possiblity for the RMQ Streaming Source to customize the queue
> ------------------------------------------------------------------
>
> Key: FLINK-4025
> URL: https://issues.apache.org/jira/browse/FLINK-4025
> Project: Flink
> Issue Type: Improvement
> Components: Streaming Connectors
> Affects Versions: 1.0.2
> Reporter: Dominik Bruhn
>
> This patch adds the possibilty for the user of the RabbitMQ
> Streaming Connector to customize the queue which is used. There
> are use-cases in which you want to set custom parameters for the
> queue (i.e. TTL of the messages if Flink reboots) or the
> possibility to bind the queue to an exchange afterwards.
> The commit doesn't change the actual behaviour but makes it
> possible for users to override the newly create `setupQueue`
> method and cutomize their implementation. This was not possible
> before.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
