From 6e492b408233f032087d3294111cc646b443db51 Mon Sep 17 00:00:00 2001
From: Mark Latimer <mark.latimer@gmail.com>
Date: Mon, 27 Apr 2015 20:52:54 +0100
Subject: [PATCH] peerStatus to peerDescription in EndpointConnectionPool.java
 fixing incompatible type error

Signed-off-by: Mark Payne <markap14@hotmail.com>
---
 .../nifi/remote/client/socket/EndpointConnectionPool.java       | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/nifi/nifi-commons/nifi-site-to-site-client/src/main/java/org/apache/nifi/remote/client/socket/EndpointConnectionPool.java b/nifi/nifi-commons/nifi-site-to-site-client/src/main/java/org/apache/nifi/remote/client/socket/EndpointConnectionPool.java
index 36d8bac8d4..b162b3fb8d 100644
--- a/nifi/nifi-commons/nifi-site-to-site-client/src/main/java/org/apache/nifi/remote/client/socket/EndpointConnectionPool.java
+++ b/nifi/nifi-commons/nifi-site-to-site-client/src/main/java/org/apache/nifi/remote/client/socket/EndpointConnectionPool.java
@@ -258,7 +258,7 @@ public class EndpointConnectionPool {
         }
 
         final PeerDescription peerDescription = peerStatus.getPeerDescription();
-        BlockingQueue<EndpointConnection> connectionQueue = connectionQueueMap.get(peerStatus);
+        BlockingQueue<EndpointConnection> connectionQueue = connectionQueueMap.get(peerDescription);
         if (connectionQueue == null) {
             connectionQueue = new LinkedBlockingQueue<>();
             BlockingQueue<EndpointConnection> existing = connectionQueueMap.putIfAbsent(peerDescription, connectionQueue);