Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5410#discussion_r190654087
--- Diff:
flink-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSource.java
---
@@ -151,7 +151,9 @@ public void open(Configuration config) throws Exception
{
if (channel == null) {
throw new RuntimeException("None of RabbitMQ
channels are available");
}
- setupQueue();
+ if (rmqConnectionConfig.hasToCreateQueueOnSetup()) {
--- End diff --
There was a PR that did something similar and got rejected. See:
https://github.com/apache/flink/pull/4979 and
https://issues.apache.org/jira/browse/FLINK-8018
---
