updates per code review, simplification.

Author: robotdan

src/main/java/io/fusionauth/http/server/Configurable.java

@@ -333,8 +333,12 @@ default T withShutdownDuration(Duration duration) {
 
   /**
    *
-   * Sets the unexpected exception handler that may occur while processing an HTTP request. This can be set to null which means the HTTP
-   * worker will use the default behavior.
+   * Sets the unexpected exception handler. This handler will be called when an unexpected exception is taken while processing the HTTP
+   * request by the HTTP worker.
+   * <p>
+   * This allows you to customize the status code and logging behavior.
+   * <p>
+   * Must not be null.
    *
    * @param unexpectedExceptionHandler The unexpected exception handler.
    * @return This.

src/main/java/io/fusionauth/http/server/DefaultHTTPUnexpectedExceptionHandler.java

@@ -0,0 +1,33 @@
+/*
+ * Copyright (c) 2025, FusionAuth, All Rights Reserved
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,
+ * either express or implied. See the License for the specific
+ * language governing permissions and limitations under the License.
+ */
+package io.fusionauth.http.server;
+
+import io.fusionauth.http.log.Logger;
+
+/**
+ * THe default HTTP unexpected exception handler.
+ *
+ * @author Daniel DeGroff
+ */
+public class DefaultHTTPUnexpectedExceptionHandler implements HTTPUnexpectedExceptionHandler {
+
+  @Override
+  public int handle(Logger logger, Throwable t) {
+    int internalServerError = 500;
+    logger.error(String.format("[%s] Closing socket with status [%d]. An HTTP worker threw an exception while processing a request.", Thread.currentThread().threadId(), internalServerError), t);
+    return internalServerError;
+  }
+}

src/main/java/io/fusionauth/http/server/HTTPServerConfiguration.java

@@ -79,7 +79,7 @@ public class HTTPServerConfiguration implements Configurable<HTTPServerConfigura
 
   private Duration shutdownDuration = Duration.ofSeconds(10);
 
-  private HTTPUnexpectedExceptionHandler unexpectedExceptionHandler;
+  private HTTPUnexpectedExceptionHandler unexpectedExceptionHandler = new DefaultHTTPUnexpectedExceptionHandler();
 
   private Duration writeThroughputCalculationDelayDuration = Duration.ofSeconds(5);
 
@@ -112,14 +112,6 @@ public String getContextPath() {
     return contextPath;
   }
 
-  /**
-   * @return The HTTP unexpected exception handler for this server or null if a default was not set.
-   */
-  public HTTPUnexpectedExceptionHandler getDefaultExceptionHandler() {
-    return unexpectedExceptionHandler;
-  }
-
-
   /**
    * @return The expect validator. Cannot be null and is required.
    */
@@ -285,6 +277,13 @@ public Duration getShutdownDuration() {
     return shutdownDuration;
   }
 
+  /**
+   * @return The HTTP unexpected exception handler for this server or null if a default was not set.
+   */
+  public HTTPUnexpectedExceptionHandler getUnexpectedExceptionHandler() {
+    return unexpectedExceptionHandler;
+  }
+
   /**
    * @return the duration that will be used to delay the calculation and enforcement of the minimum write throughput.
    */

src/main/java/io/fusionauth/http/server/HTTPUnexpectedExceptionHandler.java

@@ -15,11 +15,24 @@
  */
 package io.fusionauth.http.server;
 
+import io.fusionauth.http.log.Logger;
+
+/**
+ * An interface defining the HTTP unexpected exception handler contract.
+ *
+ * @author Daniel DeGroff
+ */
 public interface HTTPUnexpectedExceptionHandler {
   /**
    *
-   * @param response the HTTP response, may be null.
-   * @param t        the unexpected exception to handle.
+   * This handler will be called when an unexpected exception is taken while processing an HTTP request by the HTTP worker.
+   * <p>
+   * The intent is that this provides additional flexibility on the status code and the logging behavior when an unexpected exception
+   * caught.
+   *
+   * @param logger the HTTP worker logger.
+   * @param t      the unexpected exception to handle.
+   * @return the desired HTTP status code. Note that if the response has already been committed this will be ignored.
    */
-  void handle(HTTPResponse response, Throwable t);
+  int handle(Logger logger, Throwable t);
 }

src/main/java/io/fusionauth/http/server/internal/HTTPWorker.java

@@ -36,7 +36,6 @@
 import io.fusionauth.http.server.HTTPRequest;
 import io.fusionauth.http.server.HTTPResponse;
 import io.fusionauth.http.server.HTTPServerConfiguration;
-import io.fusionauth.http.server.HTTPUnexpectedExceptionHandler;
 import io.fusionauth.http.server.Instrumenter;
 import io.fusionauth.http.server.io.ConnectionClosedException;
 import io.fusionauth.http.server.io.HTTPInputStream;
@@ -268,24 +267,10 @@ public void run() {
       logger.debug(String.format("[%s] Closing socket with status [%d]. An IO exception was thrown during processing. These are pretty common.", Thread.currentThread().threadId(), Status.InternalServerError), e);
       closeSocketOnError(response, Status.InternalServerError);
     } catch (Throwable e) {
-      HTTPUnexpectedExceptionHandler unexpectedExceptionHandler = configuration.getDefaultExceptionHandler();
       var status = Status.InternalServerError;
-      if (unexpectedExceptionHandler != null) {
-        if (response != null) {
-          // Set the initial status, allowing the handler to attempt to modify the status code.
-          response.setHeader(Headers.Connection, Connections.Close);
-          response.setStatus(status);
-        }
-
-        try {
-          unexpectedExceptionHandler.handle(response, e);
-        } catch (Throwable ignore) {
-        }
-
-        status = response != null ? response.getStatus() : status;
-      } else {
-        // Log the error
-        logger.error(String.format("[%s] Closing socket with status [%d]. An HTTP worker threw an exception while processing a request.", Thread.currentThread().threadId(), status), e);
+      try {
+        status = configuration.getUnexpectedExceptionHandler().handle(logger, e);
+      } catch (Throwable ignore) {
       }
 
       // Signal an error