Repository: nifi Updated Branches: refs/heads/0.x c4ddb5212 -> 86c96d930
NIFI-1982: Use Compressed check box value. - The Compressed check box UI input was not used - This commit enables Site-to-Site compression configuration from UI This closes #509. Signed-off-by: Bryan Bende <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/86c96d93 Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/86c96d93 Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/86c96d93 Branch: refs/heads/0.x Commit: 86c96d9304fea850a0f0947ec40254a3054704bd Parents: c4ddb52 Author: Koji Kawamura <[email protected]> Authored: Wed Jun 8 20:54:40 2016 +0900 Committer: Bryan Bende <[email protected]> Committed: Thu Jun 9 09:37:24 2016 -0400 ---------------------------------------------------------------------- .../main/java/org/apache/nifi/remote/StandardRemoteGroupPort.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/86c96d93/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-site-to-site/src/main/java/org/apache/nifi/remote/StandardRemoteGroupPort.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-site-to-site/src/main/java/org/apache/nifi/remote/StandardRemoteGroupPort.java b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-site-to-site/src/main/java/org/apache/nifi/remote/StandardRemoteGroupPort.java index 552c0c6..9f6f783 100644 --- a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-site-to-site/src/main/java/org/apache/nifi/remote/StandardRemoteGroupPort.java +++ b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-site-to-site/src/main/java/org/apache/nifi/remote/StandardRemoteGroupPort.java @@ -131,6 +131,7 @@ public class StandardRemoteGroupPort extends RemoteGroupPort { .url(remoteGroup.getTargetUri().toString()) .portIdentifier(getIdentifier()) .sslContext(sslContext) + .useCompression(isUseCompression()) .eventReporter(remoteGroup.getEventReporter()) .peerPersistenceFile(getPeerPersistenceFile(getIdentifier())) .nodePenalizationPeriod(penalizationMillis, TimeUnit.MILLISECONDS)
