Apache CXF: - Как извлечь данные полезной нагрузки с помощью cxf-перехватчиков

Question

Какие шаги следует выполнить для извлечения полезной нагрузки с использованием перехватчиков Apache CXF?

Answer 1

Ваш перехватчик должен простираться от AbstractPhaseInterceptor или подкласса

public class MyInterceptor extends AbstractPhaseInterceptor<Message> { 
    public MyInterceptor() { 
     super(Phase.RECEIVE); 
    } 

    public void handleMessage(Message message) { 
     //Get the message body into payload[] and set a new non-consumed inputStream into Message 
     InputStream in = message.getContent(InputStream.class); 
     byte payload[] = IOUtils.readBytesFromStream(in); 
     ByteArrayInputStream bin = new ByteArrayInputStream(payload); 
     message.setContent(InputStream.class, bin); 
    } 

    public void handleFault(Message messageParam) { 
     //Invoked when interceptor fails 
    } 
} 

Добавить перехватчик программно

MyInterceptor myInterceptor = new MyInterceptor(); 

Server server = serverFactoryBean.create(); 
server.getEndpoint().getInInterceptor().add(myInterceptor); 

Или с использованием конфигурации

<beans xmlns="http://www.springframework.org/schema/beans" 
     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
     xmlns:cxf="http://cxf.apache.org/core" 
     xsi:schemaLocation=" 
http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd 
http://cxf.apache.org/core http://cxf.apache.org/schemas/core.xsd"> 

    <bean id="MyInterceptor" class="demo.interceptor.MyInterceptor"/> 

    <!-- We are adding the interceptors to the bus as we will have only one endpoint/service/bus. --> 

    <cxf:bus> 
     <cxf:inInterceptors> 
      <ref bean="MyInterceptor"/> 
     </cxf:inInterceptors> 
     <cxf:outInterceptors> 
      <ref bean="MyInterceptor"/> 
     </cxf:outInterceptors> 
    </cxf:bus> 
</beans> 

Проверка документации here

Answer 2

Вы можете использовать LoggingInInterceptor для извлечения полезной нагрузки в виде строки

public class CustomInInterceptor extends LoggingInInterceptor { 

    /** 
    * SLF4J Log Instance 
    */ 
    private final static Logger LOG = LoggerFactory.getLogger(CustomInInterceptor.class); 

    /** 
    * formats logging message and also attaches input xml to thread context 
    * 
    * @see org.apache.cxf.interceptor.LoggingInInterceptor#formatLoggingMessage(org.apache.cxf.interceptor.LoggingMessage) 
    */ 
    @Override 
    protected String formatLoggingMessage(final LoggingMessage loggingMessage) { 
    //The below line reads payload and puts into threads context, which I use later to save in db 
    KpContextHolder.setInputXml(loggingMessage.getPayload().toString()); 
     return super.formatLoggingMessage(loggingMessage); 
    } 

}