You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "ASF GitHub Bot (JIRA)" <ji...@apache.org> on 2016/07/21 20:45:21 UTC
[jira] [Commented] (FLINK-4251) Add possiblity for the RMQ
Streaming Sink to customize the queue
[ 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 <ph...@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)