You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by rm...@apache.org on 2016/08/15 14:20:21 UTC
flink git commit: [FLINK-4394] RMQSource: QueueName accessible for
subclasses
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 <do...@dbruhn.de>
Authored: Mon Aug 15 09:41:57 2016 +0200
Committer: Robert Metzger <rm...@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;