add async support to all non-deprecated filters

Enables async servlet support across all active MoSKito filters so they
do not block async dispatch chains (e.g. SSE/MCP endpoints). Three
deployment paths are covered: web-fragment.xml (<async-supported>true),
@webfilter(asyncSupported=true) on each filter class, and
FilterRegistrationBean.setAsyncSupported(true) in the Spring Boot 1/2
auto-configurations. Deprecated filters are intentionally excluded.

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

Author: dvayanu

moskito-integration/moskito-springboot/src/main/java/net/anotheria/moskito/integration/springboot/MoskitoAutoConfiguration.java

@@ -50,6 +50,7 @@ public FilterRegistrationBean journeyStarterFilter() {
         FilterRegistrationBean registrationBean = new FilterRegistrationBean();
         registrationBean.setFilter(new JourneyStarterFilter());
         registrationBean.addUrlPatterns("/*");
+        registrationBean.setAsyncSupported(true);
         return registrationBean;
     }
 
@@ -59,6 +60,7 @@ public FilterRegistrationBean asyncSourceTldFilter() {
         FilterRegistrationBean registrationBean = new FilterRegistrationBean();
         registrationBean.setFilter(new AsyncSourceTldFilter());
         registrationBean.addUrlPatterns("/*");
+        registrationBean.setAsyncSupported(true);
         return registrationBean;
     }
 
@@ -68,6 +70,7 @@ public FilterRegistrationBean debugRequestFilter() {
         FilterRegistrationBean registrationBean = new FilterRegistrationBean();
         registrationBean.setFilter(new DebugRequestFilter());
         registrationBean.addUrlPatterns("/*");
+        registrationBean.setAsyncSupported(true);
         return registrationBean;
     }
 
@@ -77,6 +80,7 @@ public FilterRegistrationBean genericMonitoringFilter() {
         FilterRegistrationBean registrationBean = new FilterRegistrationBean();
         registrationBean.setFilter(new GenericMonitoringFilter());
         registrationBean.addUrlPatterns("/*");
+        registrationBean.setAsyncSupported(true);
         return registrationBean;
     }
 
@@ -86,6 +90,7 @@ public FilterRegistrationBean journeyFilter() {
         FilterRegistrationBean registrationBean = new FilterRegistrationBean();
         registrationBean.setFilter(new JourneyFilter());
         registrationBean.addUrlPatterns("/*");
+        registrationBean.setAsyncSupported(true);
         return registrationBean;
     }
 
@@ -95,6 +100,7 @@ public FilterRegistrationBean jSTalkBackFilter() {
         FilterRegistrationBean registrationBean = new FilterRegistrationBean();
         registrationBean.setFilter(new JSTalkBackFilter());
         registrationBean.addUrlPatterns("/*");
+        registrationBean.setAsyncSupported(true);
         return registrationBean;
     }
 
@@ -104,6 +110,7 @@ public FilterRegistrationBean moskitoCommandFilter() {
         FilterRegistrationBean registrationBean = new FilterRegistrationBean();
         registrationBean.setFilter(new MoskitoCommandFilter());
         registrationBean.addUrlPatterns("/*");
+        registrationBean.setAsyncSupported(true);
         return registrationBean;
     }
 
@@ -113,6 +120,7 @@ public FilterRegistrationBean sourceIpSegmentFilter() {
         FilterRegistrationBean registrationBean = new FilterRegistrationBean();
         registrationBean.setFilter(new SourceIpSegmentFilter());
         registrationBean.addUrlPatterns("/*");
+        registrationBean.setAsyncSupported(true);
         return registrationBean;
     }
 
@@ -122,6 +130,7 @@ public FilterRegistrationBean sourceTldFilter() {
         FilterRegistrationBean registrationBean = new FilterRegistrationBean();
         registrationBean.setFilter(new SourceTldFilter());
         registrationBean.addUrlPatterns("/*");
+        registrationBean.setAsyncSupported(true);
         return registrationBean;
     }
 

moskito-integration/moskito-springboot2/src/main/java/net/anotheria/moskito/integration/springboot/MoskitoAutoConfiguration.java

@@ -69,6 +69,7 @@ public FilterRegistrationBean journeyStarterFilter() {
     FilterRegistrationBean registrationBean = new FilterRegistrationBean();
     registrationBean.setFilter(new JourneyStarterFilter());
     registrationBean.addUrlPatterns("/*");
+    registrationBean.setAsyncSupported(true);
     return registrationBean;
   }
 
@@ -78,6 +79,7 @@ public FilterRegistrationBean asyncSourceTldFilter() {
     FilterRegistrationBean registrationBean = new FilterRegistrationBean();
     registrationBean.setFilter(new AsyncSourceTldFilter());
     registrationBean.addUrlPatterns("/*");
+    registrationBean.setAsyncSupported(true);
     return registrationBean;
   }
 
@@ -87,6 +89,7 @@ public FilterRegistrationBean debugRequestFilter() {
     FilterRegistrationBean registrationBean = new FilterRegistrationBean();
     registrationBean.setFilter(new DebugRequestFilter());
     registrationBean.addUrlPatterns("/*");
+    registrationBean.setAsyncSupported(true);
     return registrationBean;
   }
 
@@ -96,6 +99,7 @@ public FilterRegistrationBean genericMonitoringFilter() {
     FilterRegistrationBean registrationBean = new FilterRegistrationBean();
     registrationBean.setFilter(new GenericMonitoringFilter());
     registrationBean.addUrlPatterns("/*");
+    registrationBean.setAsyncSupported(true);
     return registrationBean;
   }
 
@@ -105,6 +109,7 @@ public FilterRegistrationBean journeyFilter() {
     FilterRegistrationBean registrationBean = new FilterRegistrationBean();
     registrationBean.setFilter(new JourneyFilter());
     registrationBean.addUrlPatterns("/*");
+    registrationBean.setAsyncSupported(true);
     return registrationBean;
   }
 
@@ -114,6 +119,7 @@ public FilterRegistrationBean journeyFilter() {
 //        FilterRegistrationBean registrationBean = new FilterRegistrationBean();
 //        registrationBean.setFilter(new JSTalkBackFilter());
 //        registrationBean.addUrlPatterns("/*");
+//        registrationBean.setAsyncSupported(true);
 //        return registrationBean;
 //    }
 
@@ -123,6 +129,7 @@ public FilterRegistrationBean moskitoCommandFilter() {
     FilterRegistrationBean registrationBean = new FilterRegistrationBean();
     registrationBean.setFilter(new MoskitoCommandFilter());
     registrationBean.addUrlPatterns("/*");
+    registrationBean.setAsyncSupported(true);
     return registrationBean;
   }
 
@@ -132,6 +139,7 @@ public FilterRegistrationBean sourceIpSegmentFilter() {
     FilterRegistrationBean registrationBean = new FilterRegistrationBean();
     registrationBean.setFilter(new SourceIpSegmentFilter());
     registrationBean.addUrlPatterns("/*");
+    registrationBean.setAsyncSupported(true);
     return registrationBean;
   }
 
@@ -141,6 +149,7 @@ public FilterRegistrationBean sourceTldFilter() {
     FilterRegistrationBean registrationBean = new FilterRegistrationBean();
     registrationBean.setFilter(new SourceTldFilter());
     registrationBean.addUrlPatterns("/*");
+    registrationBean.setAsyncSupported(true);
     return registrationBean;
   }
 

moskito-web/src/main/java/net/anotheria/moskito/web/filters/AsyncSourceTldFilter.java

@@ -13,6 +13,7 @@
 import jakarta.servlet.ServletException;
 import jakarta.servlet.ServletRequest;
 import jakarta.servlet.ServletResponse;
+import jakarta.servlet.annotation.WebFilter;
 import java.io.IOException;
 import java.net.InetAddress;
 
@@ -23,6 +24,7 @@
  * @author lrosenberg
  * @since 25.04.13 18:48
  */
+@WebFilter(asyncSupported = true)
 public class AsyncSourceTldFilter extends MoskitoFilter{
 	/**
 	 * Limit for the ip length. This limit is simple precaution in case someone is sending constructed source ip header

moskito-web/src/main/java/net/anotheria/moskito/web/filters/DebugRequestFilter.java

@@ -9,6 +9,7 @@
 import jakarta.servlet.ServletException;
 import jakarta.servlet.ServletRequest;
 import jakarta.servlet.ServletResponse;
+import jakarta.servlet.annotation.WebFilter;
 import jakarta.servlet.http.HttpServletRequest;
 import jakarta.servlet.http.HttpSession;
 import java.io.IOException;
@@ -21,6 +22,7 @@
  *
  * @author asamoilich.
  */
+@WebFilter(asyncSupported = true)
 public class DebugRequestFilter implements Filter {
 
     /**

moskito-web/src/main/java/net/anotheria/moskito/web/filters/GenericMonitoringFilter.java

@@ -23,6 +23,7 @@
 import jakarta.servlet.ServletException;
 import jakarta.servlet.ServletRequest;
 import jakarta.servlet.ServletResponse;
+import jakarta.servlet.annotation.WebFilter;
 import jakarta.servlet.http.HttpServletRequest;
 import jakarta.servlet.http.HttpServletResponse;
 import java.io.IOException;
@@ -38,6 +39,7 @@
  * @author lrosenberg
  * @since 26.04.16 19:04
  */
+@WebFilter(asyncSupported = true)
 public class GenericMonitoringFilter implements Filter, IStatsProducer {
 	/**
 	 * Logger instance.

moskito-web/src/main/java/net/anotheria/moskito/web/filters/JSTalkBackFilter.java

@@ -17,6 +17,7 @@
 import jakarta.servlet.ServletException;
 import jakarta.servlet.ServletRequest;
 import jakarta.servlet.ServletResponse;
+import jakarta.servlet.annotation.WebFilter;
 import jakarta.servlet.http.HttpServletRequest;
 import jakarta.servlet.http.HttpServletResponse;
 import java.io.IOException;
@@ -28,6 +29,7 @@
  * @author lrosenberg
  * @since 15.09.13 22:44
  */
+@WebFilter(asyncSupported = true)
 public class JSTalkBackFilter implements Filter {
 	/**
 	 * Parameter name for the init parameter for the limit of dynamic case names (number of names) in the filter config. If the number of cases will exceed this limit,

moskito-web/src/main/java/net/anotheria/moskito/web/filters/JourneyFilter.java

@@ -26,13 +26,15 @@
 import jakarta.servlet.ServletRequest;
 import jakarta.servlet.ServletResponse;
 import jakarta.servlet.http.HttpServletRequest;
+import jakarta.servlet.annotation.WebFilter;
 import jakarta.servlet.http.HttpSession;
 import java.io.IOException;
 
 
 /**
  * This filter checks if the journey tracing is active for current http session and if so switches the call tracing on.
  */
+@WebFilter(asyncSupported = true)
 public class JourneyFilter implements Filter {
 
 	/**

moskito-web/src/main/java/net/anotheria/moskito/web/filters/JourneyStarterFilter.java

@@ -15,6 +15,7 @@
 import jakarta.servlet.ServletRequest;
 import jakarta.servlet.ServletResponse;
 import jakarta.servlet.http.HttpServletRequest;
+import jakarta.servlet.annotation.WebFilter;
 import jakarta.servlet.http.HttpSession;
 import java.io.IOException;
 
@@ -26,6 +27,7 @@
  * @author lrosenberg
  * @since 15.10.14 22:41
  */
+@WebFilter(asyncSupported = true)
 public class JourneyStarterFilter implements Filter{
 
 	/**

moskito-web/src/main/java/net/anotheria/moskito/web/filters/MoskitoCommandFilter.java

@@ -8,13 +8,15 @@
 import jakarta.servlet.ServletException;
 import jakarta.servlet.ServletRequest;
 import jakarta.servlet.ServletResponse;
+import jakarta.servlet.annotation.WebFilter;
 import java.io.IOException;
 import java.util.Map;
 
 
 /**
  * This filter checks for commands that can be executed by MoSKito and forwards them to the responsbile components.
  */
+@WebFilter(asyncSupported = true)
 public class MoskitoCommandFilter implements Filter{
 	/**
 	 * Name of the command parameter (default).

moskito-web/src/main/java/net/anotheria/moskito/web/filters/SourceIpSegmentFilter.java

@@ -4,6 +4,7 @@
 
 import jakarta.servlet.ServletRequest;
 import jakarta.servlet.ServletResponse;
+import jakarta.servlet.annotation.WebFilter;
 import jakarta.servlet.http.HttpServletRequest;
 
 /**
@@ -12,6 +13,7 @@
  * @author lrosenberg
  * @since 25.04.13 18:21
  */
+@WebFilter(asyncSupported = true)
 public class SourceIpSegmentFilter extends MoskitoFilter {
 	/**
 	 * Limit for the ip length. This limit is simple precaution in case someone is sending constructed source ip header