From 3259b01f8ec2c1492c7acf3c9b9b29b8402dda6a Mon Sep 17 00:00:00 2001 From: Mike Moser Date: Tue, 20 Dec 2016 17:26:39 +0000 Subject: [PATCH] NIFI-3230 fix ActiveMQ SSL support for simple connect URIs in Get/Put JMS processors This closes #1344. --- .../org/apache/nifi/processors/standard/util/JmsFactory.java | 3 +++ 1 file changed, 3 insertions(+) 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 19e8ac07ae..a844288bca 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 @@ -382,6 +382,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;