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)
