From c9dcfa82b6503ece0489bb730b037121694bc57b Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Tam=C3=A1s=20Bunth?= <btomi96@gmail.com>
Date: Tue, 23 Jun 2020 15:43:21 +0200
Subject: [PATCH] Add better exception handling when..

..http server initialization failed.
---
 .../java/org/apache/nifi/processors/standard/ListenHTTP.java   | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ListenHTTP.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ListenHTTP.java
index 3451bad4d3488..8c575c57ba223 100644
--- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ListenHTTP.java
+++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ListenHTTP.java
@@ -385,7 +385,7 @@ private Set<String> findOldFlowFileIds(final ProcessContext ctx) {
     }
 
     @Override
-    public void onTrigger(final ProcessContext context, final ProcessSessionFactory sessionFactory) {
+    public void onTrigger(final ProcessContext context, final ProcessSessionFactory sessionFactory) throws ProcessException {
         try {
             if (!initialized.get()) {
                 createHttpServerFromService(context);
@@ -393,6 +393,7 @@ public void onTrigger(final ProcessContext context, final ProcessSessionFactory
         } catch (Exception e) {
             getLogger().warn("Failed to start http server during initialization: " + e);
             context.yield();
+            throw new ProcessException("Failed to initialize the server", e);
         }
 
         sessionFactoryReference.compareAndSet(null, sessionFactory);