[ https://issues.apache.org/jira/browse/FLINK-4251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15388395#comment-15388395 ]
ASF GitHub Bot commented on FLINK-4251: --------------------------------------- GitHub user PhilippGrulich opened a pull request: https://github.com/apache/flink/pull/2281 RMQ Sink: Possibility to customize queue config [FLINK-4251] This patch adds the possibilty for the user of the RabbitMQ Streaming Sink to customize the queue which is used. This adopts the behavior of [FLINK-4025] for the sink. The commit doesn't change the actual behaviour but makes it possible for users to override the `setupQueue` method and customize their implementation. This was only possible for the RMQSource before. The Sink and the Source offer now both the same functionality, so this should increase usability. [FLINK-4025] = https://issues.apache.org/jira/browse/FLINK-4251 Best, Philipp You can merge this pull request into a Git repository by running: $ git pull https://github.com/PhilippGrulich/flink RMQSink_setupQueue Alternatively you can review and apply these changes as the patch at: https://github.com/apache/flink/pull/2281.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #2281 ---- commit 3b5ec690c6320840cc0b9f5eafb64e11761e543b Author: philippgrulich <philippgrul...@hotmail.de> Date: 2016-07-21T20:31:24Z RMQ Sink: Possibility to customize queue config [FLINK-4251] ---- > Add possiblity for the RMQ Streaming Sink to customize the queue > ---------------------------------------------------------------- > > Key: FLINK-4251 > URL: https://issues.apache.org/jira/browse/FLINK-4251 > Project: Flink > Issue Type: Improvement > Components: Streaming Connectors > Reporter: Philipp Grulich > Priority: Minor > > This patch adds the possibilty for the user of the RabbitMQ > Streaming Sink to customize the queue which is used. > This adopts the behavior of [FLINK-4025] for the sink. > The commit doesn't change the actual behaviour but makes it > possible for users to override the `setupQueue` > method and customize their implementation. This was only possible for the > RMQSource before. The Sink and the Source offer now both the same > functionality, so this should increase usability. > [FLINK-4025] = https://issues.apache.org/jira/browse/FLINK-4025 -- This message was sent by Atlassian JIRA (v6.3.4#6332)