You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Philipp Grulich (JIRA)" <ji...@apache.org> on 2016/07/21 20:35:20 UTC

[jira] [Created] (FLINK-4251) Add possiblity for the RMQ Streaming Sink to customize the queue

Philipp Grulich created FLINK-4251:
--------------------------------------

             Summary: 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)