Repository: flink Updated Branches: refs/heads/master 90fdae452 -> 5ccd90715
[FLINK-4394] RMQSource: QueueName accessible for subclasses The queueName is needed if the subclasses override `setupQueue`. This closes #2373 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5ccd9071 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5ccd9071 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/5ccd9071 Branch: refs/heads/master Commit: 5ccd9071580e196d150905b2d05eef71e399a24c Parents: 90fdae4 Author: Dominik <domi...@dbruhn.de> Authored: Mon Aug 15 09:41:57 2016 +0200 Committer: Robert Metzger <rmetz...@apache.org> Committed: Mon Aug 15 16:19:49 2016 +0200 ---------------------------------------------------------------------- .../org/apache/flink/streaming/connectors/rabbitmq/RMQSource.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/5ccd9071/flink-streaming-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSource.java ---------------------------------------------------------------------- diff --git a/flink-streaming-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSource.java b/flink-streaming-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSource.java index 33cf52c..ee9c3b9 100644 --- a/flink-streaming-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSource.java +++ b/flink-streaming-connectors/flink-connector-rabbitmq/src/main/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSource.java @@ -74,7 +74,7 @@ public class RMQSource<OUT> extends MultipleIdsMessageAcknowledgingSourceBase<OU private static final Logger LOG = LoggerFactory.getLogger(RMQSource.class); private final RMQConnectionConfig rmqConnectionConfig; - private final String queueName; + protected final String queueName; private final boolean usesCorrelationId; protected DeserializationSchema<OUT> schema;
