Dominik Bruhn created FLINK-4394:
------------------------------------
Summary: RMQSource: The QueueName is not accessible to subclasses
Key: FLINK-4394
URL: https://issues.apache.org/jira/browse/FLINK-4394
Project: Flink
Issue Type: Bug
Components: Streaming Connectors
Affects Versions: 1.1.1
Reporter: Dominik Bruhn
In version 1.1.0 we made the RMQSource extensible so that subclasses can
configure how they want their queue for RabbitMQ/AMQP create. The subclasses
can override
{code}
protected void setupQueue() throws IOException {
channel.queueDeclare(queueName, true, false, false, null);
}
{code}
The problem is, that the queueName property is private. So when override the
setupQueue parameter, you don't know what actual queueName was provided. A
simple change of the queueName property to protected fixes this.
PR will follow
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
