From 04d6bf46e8d8684494522cd0c92ad462922d0af4 Mon Sep 17 00:00:00 2001
From: Dominik <dominik@dbruhn.de>
Date: Mon, 15 Aug 2016 09:41:57 +0200
Subject: [PATCH] RMQSource: QueueName accessible for subclasses

The queueName is needed if the subclasses override `setupQueue`.
---
 .../apache/flink/streaming/connectors/rabbitmq/RMQSource.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 33cf52ca2bb64..ee9c3b94a570b 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;