Repository: nifi
Updated Branches:
  refs/heads/master e0e6f0bac -> e113511fe


NIFI-3393 - replicates cluster/nodes/{id} to cluster coordinator. This closes 
#1443


Project: http://git-wip-us.apache.org/repos/asf/nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/e113511f
Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/e113511f
Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/e113511f

Branch: refs/heads/master
Commit: e113511fef2f408f24b05da28046d8a3de3b228a
Parents: e0e6f0b
Author: Pierre Villard <[email protected]>
Authored: Wed Jan 25 15:31:39 2017 +0100
Committer: Matt Gilman <[email protected]>
Committed: Wed Jan 25 10:25:36 2017 -0500

----------------------------------------------------------------------
 .../main/java/org/apache/nifi/web/api/ControllerResource.java    | 4 ++++
 1 file changed, 4 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/nifi/blob/e113511f/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/api/ControllerResource.java
----------------------------------------------------------------------
diff --git 
a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/api/ControllerResource.java
 
b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/api/ControllerResource.java
index 86ca792..1e56dbb 100644
--- 
a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/api/ControllerResource.java
+++ 
b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/api/ControllerResource.java
@@ -512,6 +512,10 @@ public class ControllerResource extends 
ApplicationResource {
             throw new IllegalClusterResourceRequestException("Only a node 
connected to a cluster can process the request.");
         }
 
+        if (isReplicateRequest()) {
+            return replicate(HttpMethod.GET, getClusterCoordinatorNode());
+        }
+
         // get the specified relationship
         final NodeDTO dto = serviceFacade.getNode(id);
 

Reply via email to