flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Dominik Bruhn (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-4025) Add possiblity for the RMQ Streaming Source to customize the queue
Date Mon, 06 Jun 2016 14:42:21 GMT

    [ 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

View raw message