NIFI-3230 fix ActiveMQ SSL support for simple connect URIs in Get/Put JMS processors
This closes #1344. Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/954201a4 Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/954201a4 Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/954201a4 Branch: refs/heads/support/nifi-0.7.x Commit: 954201a4d74b33964dd361732255d086032901ad Parents: 0952685 Author: Mike Moser <mose...@apache.org> Authored: Tue Dec 20 17:26:39 2016 +0000 Committer: Pierre Villard <pierre.villard...@gmail.com> Committed: Thu Jan 5 22:20:18 2017 +0100 ---------------------------------------------------------------------- .../java/org/apache/nifi/processors/standard/util/JmsFactory.java | 3 +++ 1 file changed, 3 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/954201a4/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/util/JmsFactory.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/util/JmsFactory.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/util/JmsFactory.java index 45758a4..26d0399 100644 --- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/util/JmsFactory.java +++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/util/JmsFactory.java @@ -378,6 +378,9 @@ public class JmsFactory { private static boolean isSSL(URI uri) { try { CompositeData compositeData = URISupport.parseComposite(uri); + if ("ssl".equals(compositeData.getScheme())) { + return true; + } for(URI component : compositeData.getComponents()){ if ("ssl".equals(component.getScheme())) { return true;
