NIFI-282: Code cleanup
Project: http://git-wip-us.apache.org/repos/asf/incubator-nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-nifi/commit/46eebc77 Tree: http://git-wip-us.apache.org/repos/asf/incubator-nifi/tree/46eebc77 Diff: http://git-wip-us.apache.org/repos/asf/incubator-nifi/diff/46eebc77 Branch: refs/heads/develop Commit: 46eebc77abb726ecc56ae7fdc71d575a1f23f39c Parents: a7405b9 Author: Mark Payne <marka...@hotmail.com> Authored: Mon Feb 16 16:53:38 2015 -0500 Committer: Mark Payne <marka...@hotmail.com> Committed: Mon Feb 16 16:53:38 2015 -0500 ---------------------------------------------------------------------- .../nifi/remote/client/socket/EndpointConnectionPool.java | 5 ++++- .../nifi/remote/protocol/socket/SocketClientTransaction.java | 2 +- 2 files changed, 5 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/46eebc77/nifi/nifi-commons/nifi-site-to-site-client/src/main/java/org/apache/nifi/remote/client/socket/EndpointConnectionPool.java ---------------------------------------------------------------------- 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 450daec..42428f6 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 @@ -904,7 +904,10 @@ public class EndpointConnectionPool { return listeningPort; } - + @Override + public String toString() { + return "EndpointConnectionPool[Cluster URL=" + clusterUrl + "]"; + } /** http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/46eebc77/nifi/nifi-commons/nifi-site-to-site-client/src/main/java/org/apache/nifi/remote/protocol/socket/SocketClientTransaction.java ---------------------------------------------------------------------- diff --git a/nifi/nifi-commons/nifi-site-to-site-client/src/main/java/org/apache/nifi/remote/protocol/socket/SocketClientTransaction.java b/nifi/nifi-commons/nifi-site-to-site-client/src/main/java/org/apache/nifi/remote/protocol/socket/SocketClientTransaction.java index 2fbcfc4..a1ce07e 100644 --- a/nifi/nifi-commons/nifi-site-to-site-client/src/main/java/org/apache/nifi/remote/protocol/socket/SocketClientTransaction.java +++ b/nifi/nifi-commons/nifi-site-to-site-client/src/main/java/org/apache/nifi/remote/protocol/socket/SocketClientTransaction.java @@ -138,7 +138,7 @@ public class SocketClientTransaction implements Transaction { this.dataAvailable = true; break; case FINISH_TRANSACTION: - logger.debug("{} {} Indicates Transaction should finish", peer); + logger.debug("{} {} Indicates Transaction should finish", this, peer); this.dataAvailable = false; break; default: