You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by mc...@apache.org on 2015/02/26 04:54:26 UTC
[23/51] [abbrv] incubator-nifi git commit: NIFI-282: Code cleanup
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/NIFI-353
Commit: 46eebc77abb726ecc56ae7fdc71d575a1f23f39c
Parents: a7405b9
Author: Mark Payne <ma...@hotmail.com>
Authored: Mon Feb 16 16:53:38 2015 -0500
Committer: Mark Payne <ma...@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: