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;