Apache/nifi
1
0
Fork 0
mirror of https://github.com/apache/nifi.git synced 2025-02-16 23:15:36 +00:00
Code Issues Packages Projects Releases Wiki Activity

peerStatus to peerDescription in EndpointConnectionPool.java fixing incompatible type error

Browse Source 
Signed-off-by: Mark Payne <markap14@hotmail.com>
This commit is contained in:
Mark Latimer 2015-04-27 20:52:54 +01:00 committed by Mark Payne
parent 6c3256e00a
commit 6e492b4082
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
nifi/nifi-commons/nifi-site-to-site-client/src/main/java/org/apache/nifi/remote/client/socket/EndpointConnectionPool.java
View File

@ -258,7 +258,7 @@ public class EndpointConnectionPool {
} }
final PeerDescription peerDescription = peerStatus.getPeerDescription(); final PeerDescription peerDescription = peerStatus.getPeerDescription();
BlockingQueue<EndpointConnection> connectionQueue = connectionQueueMap.get(peerStatus); BlockingQueue<EndpointConnection> connectionQueue = connectionQueueMap.get(peerDescription);
if (connectionQueue == null) { if (connectionQueue == null) {
connectionQueue = new LinkedBlockingQueue<>(); connectionQueue = new LinkedBlockingQueue<>();
BlockingQueue<EndpointConnection> existing = connectionQueueMap.putIfAbsent(peerDescription, connectionQueue); BlockingQueue<EndpointConnection> existing = connectionQueueMap.putIfAbsent(peerDescription, connectionQueue);