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] ---- --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabled but not working, please contact infrastructure at infrastruct...@apache.org or file a JIRA ticket with INFRA. ---