mirror of https://github.com/apache/nifi.git
NIFI-282: Code cleanup
This commit is contained in:
parent
a7405b915d
commit
46eebc77ab
|
@ -904,7 +904,10 @@ public class EndpointConnectionPool {
|
||||||
return listeningPort;
|
return listeningPort;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public String toString() {
|
||||||
|
return "EndpointConnectionPool[Cluster URL=" + clusterUrl + "]";
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|
|
@ -138,7 +138,7 @@ public class SocketClientTransaction implements Transaction {
|
||||||
this.dataAvailable = true;
|
this.dataAvailable = true;
|
||||||
break;
|
break;
|
||||||
case FINISH_TRANSACTION:
|
case FINISH_TRANSACTION:
|
||||||
logger.debug("{} {} Indicates Transaction should finish", peer);
|
logger.debug("{} {} Indicates Transaction should finish", this, peer);
|
||||||
this.dataAvailable = false;
|
this.dataAvailable = false;
|
||||||
break;
|
break;
|
||||||
default:
|
default:
|
||||||
|
|
Loading…
Reference in New Issue