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 <[email protected]>
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 [email protected] or file a JIRA ticket
with INFRA.
---
