Add better exception handling when..

..http server initialization failed.
apache · Jun 23, 2020 · c9dcfa8 · c9dcfa8
1 parent 7edef8d
commit c9dcfa8
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...ifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ListenHTTP.java b/...ifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ListenHTTP.java
@@ -385,14 +385,15 @@ 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);
             }
         } 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);