[JAX-WS] The client out interceptor chain is not called in case of on…

…eway operation (fix exchange and interceptor chain issues)
apache · Oct 28, 2023 · 4845f08 · 4845f08
1 parent 437f688
commit 4845f08
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/core/src/main/java/org/apache/cxf/endpoint/ClientImpl.java b/core/src/main/java/org/apache/cxf/endpoint/ClientImpl.java
@@ -707,7 +707,6 @@ protected void onewayOnly(Exchange exhange) {
         }
 
         final Message message = endpoint.getBinding().createMessage(original);
-        message.getExchange().setInMessage(message);
         message.put(Message.REQUESTOR_ROLE, Boolean.TRUE);
         message.put(Message.INBOUND_MESSAGE, Boolean.TRUE);
         PhaseManager pm = bus.getExtension(PhaseManager.class);
@@ -758,7 +757,7 @@ protected void onewayOnly(Exchange exhange) {
         }
     }
 
-    private List<Interceptor<? extends Message>> filterOneway(List<Interceptor<? extends Message>> interceptors) {
+    private List<Interceptor<? extends Message>> filterOneway(Collection<Interceptor<? extends Message>> interceptors) {
         return interceptors
             .stream()
             .filter(OneWayInterceptor.class::isInstance)
@@ -1122,7 +1121,7 @@ protected void modifyOnewayChain(InterceptorChain chain, Message ctx) {
         Collection<Interceptor<? extends Message>> is
             = CastUtils.cast((Collection<?>)ctx.get(Message.IN_INTERCEPTORS));
         if (is != null) {
-            chain.add(is);
+            chain.add(filterOneway(is));
         }
     }