如何覆蓋cxf MessageSenderEndingInterceptor並控制handleMessage方法

Question

我使用jaxws：client標記和spring來消費webservices。 在上述過程中，我想在調用webservice之前和之後使用cxf攔截器。

亞姆能夠與CXF攔截器的工作與web服務返回正確的SOAP錯誤和成功響應，但inFaultInterceptor不 Http狀態代碼的情況下得到調用：404 也當服務已關閉...連接異常..

分析錯誤後..我發現異常正在從 https://cxf.apache.org/javadoc/latest/org/apache/cxf/interceptor/MessageSenderInterceptor.MessageSenderEndingInterceptor.html

/** 
* Licensed to the Apache Software Foundation (ASF) under one 
* or more contributor license agreements. See the NOTICE file 
* distributed with this work for additional information 
    * regarding copyright ownership. The ASF licenses this file 
    * to you 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 org.apache.cxf.interceptor; 

import java.io.IOException; 
import java.util.ResourceBundle; 

import org.apache.cxf.common.i18n.BundleUtils; 
import org.apache.cxf.message.Exchange; 
import org.apache.cxf.message.Message; 
import org.apache.cxf.phase.AbstractPhaseInterceptor; 
import org.apache.cxf.phase.Phase; 
import org.apache.cxf.transport.Conduit; 

/** 
    * Takes the Conduit from the exchange and sends the message through it. 
    */ 
    public class MessageSenderInterceptor extends AbstractPhaseInterceptor<Message> { 
    private static final ResourceBundle BUNDLE = BundleUtils.getBundle(MessageSenderInterceptor.class); 
    private MessageSenderEndingInterceptor ending = new MessageSenderEndingInterceptor(); 


    public MessageSenderInterceptor() { 
     super(Phase.PREPARE_SEND); 
    } 

    public void handleMessage(Message message) { 
     try { 
      getConduit(message).prepare(message); 
     } catch (IOException ex) { 
     throw new Fault(new org.apache.cxf.common.i18n.Message("COULD_NOT_SEND", BUNDLE), ex); 
     }  

      // Add a final interceptor to close the conduit 
      message.getInterceptorChain().add(ending); 
    } 

     public class MessageSenderEndingInterceptor extends AbstractPhaseInterceptor<Message> { 
     public MessageSenderEndingInterceptor() { 
       super(Phase.PREPARE_SEND_ENDING); 
      } 

    public void handleMessage(Message message) throws Fault { 
      try { 
       getConduit(message).close(message); 
      } catch (IOException e) { 
       throw new Fault(new org.apache.cxf.common.i18n.Message("COULD_NOT_SEND", BUNDLE), e); 
       } 
     } 
     } 

    private Conduit getConduit(Message message) { 
     Exchange exchange = message.getExchange(); 
     Conduit conduit = exchange.getConduit(message); 
     if (conduit == null 
      && (exchange.getOutMessage() != null 
       || exchange.getOutFaultMessage() != null)) { 
      conduit = OutgoingChainInterceptor.getBackChannelConduit(message); 
     } 
     return conduit; 
    } 

} 

我的問題拋出：如何在我們的項目覆蓋這個類，以便內部C類的handleMessage一個定製？ 我得在故障攔截控制之前CXF與無法將消息發送故障被拋出...

Answer 1

可以使用FaultListener加入CXF總線。偵聽器還將捕獲http異常（例如404），允許您在引發調用方法之前執行代碼。

例如

public class CxfFaultListenerImpl implements FaultListener{ 
    public boolean faultOccurred(final Exception exception,final String description,final Message message) { 

     //return false to avoid standard CXF logging of exception 
     return false; 
    } 
} 

春CXF配置

<cxf:bus> 
<cxf:properties> 
    <entry key="org.apache.cxf.logging.FaultListener"> 
     <bean id="cxfFaultListener" class="CxfFaultListenerImpl" /> 
    </entry> 
</cxf:properties> 
</cxf:bus>