javawsdlcxfcxf-client

How to get WSDL operation name from SoapMessage in CXF Request Interceptor


Im trying to get wsdl operation name (SOAPAction) but it gives me null. i have written a request interceptor in camel blueprint.
TASK TO DO: Aim is to intercept the webservice request retrieve username & password from headers & check whether the user have have rights to consume the requested SOAPAction/OperationName. How can i achieve this.? Is there any other approach to do this.

public class Interceptor extends AbstractSoapInterceptor {

    Logger _log = Logger.getLogger(Interceptor.class);

    public Interceptor() {
        super(Phase.PRE_LOGICAL);
    }

    @Override
    public void handleMessage(SoapMessage message) {
        _log.info(".... IM HERE INTERCEPTOR");

        Map<String, List<String>> headers = CastUtils.cast((Map) message.get(Message.PROTOCOL_HEADERS));
        _log.info(".... IM HERE INTERCEPTOR:::: " + headers.size());

        for (Entry<String, List<String>> entry : headers.entrySet()) {
            _log.info(entry.getKey() + " /// " + entry.getValue().get(0));
        }
    }
}

Logs of my code are here:

.... IM HERE INTERCEPTOR
.... IM HERE INTERCEPTOR:::: 9
accept-encoding /// gzip,deflate
connection /// keep-alive
Content-Length /// 351
content-type /// text/xml;charset=UTF-8
Host /// localhost:8181
password /// herman
SOAPAction /// ""
User-Agent /// Apache-HttpClient/4.1.1 (java 1.5)
username /// herman

Below is Blueprint

<?xml version="1.0" encoding="UTF-8"?>
<blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0"
    xmlns:camel="http://camel.apache.org/schema/blueprint"
    xmlns:cm="http://aries.apache.org/blueprint/xmlns/blueprint-cm/v1.1.0"
    xmlns:cxf="http://camel.apache.org/schema/blueprint/cxf"
    xmlns:cxfcore="http://cxf.apache.org/blueprint/core"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="              http://www.osgi.org/xmlns/blueprint/v1.0.0 http://www.osgi.org/xmlns/blueprint/v1.0.0/blueprint.xsd              http://camel.apache.org/schema/blueprint/cxf http://camel.apache.org/schema/blueprint/cxf/camel-cxf.xsd              http://camel.apache.org/schema/blueprint http://camel.apache.org/schema/blueprint/camel-blueprint.xsd              http://cxf.apache.org/schemas/blueprint/core http://cxf.apache.org/schemas/blueprint/core.xsd              http://cxf.apache.org/blueprint/jaxws http://cxf.apache.org/blueprint/jaxws.xsd">
    <bean class="pk.com.herman.log.query.QueryProcessor" id="QueryProcessor"/>
    <bean class="pk.com.herman.get.query.QueryGetProcessor" id="QueryGetProcessor"/>
    <bean class="pk.com.herman.interceptors.Interceptor" id="requestInterceptor"/>
    <cxfcore:bus bus="cxf">
        <cxfcore:inInterceptors>
            <ref component-id="requestInterceptor"/>
        </cxfcore:inInterceptors>
    </cxfcore:bus>
    <cxf:cxfEndpoint address="/query/" id="queryEndpoint" serviceClass="pk.com.herman.log.query.QueryService"/>
    <camelContext id="camelContext-282c3eaf-a6ba-4f22-bee7-9ad3fd7ae3ca" xmlns="http://camel.apache.org/schema/blueprint">
        <route id="cxf">
            <!-- route starts from the cxf webservice in POJO mode -->
            <from id="_from1" uri="cxf:bean:queryEndpoint"/>
            <recipientList id="_recipientList1">
                <simple>direct:${header.operationName}</simple>
            </recipientList>
        </route>
        <route id="query">
            <from id="_from2" uri="direct:reportQuery"/>
            <log id="_log1" message="Query Call"/>
            <process id="_process1" ref="QueryProcessor"/>
            <to id="_to1" uri="log:output"/>
        </route>
    </camelContext>
</blueprint>

Solution

  • here is the solution :)

    @Override
    public void handleMessage(SoapMessage message) {
        _log.info(".... IM HERE INTERCEPTOR");
    
        HttpServletRequest httpRequest = (HttpServletRequest) message.get(AbstractHTTPDestination.HTTP_REQUEST);
    
        Message inMessage = message.getExchange().getInMessage();
        MessageInfo mi = (MessageInfo) inMessage.get(MessageInfo.class);
        OperationInfo operationInfo = mi.getOperation();
    
        _log.info("username:: " + httpRequest.getHeader("username"));
        _log.info("password:: " + httpRequest.getHeader("password"));
    
        if (operationInfo != null) {
            _log.info("operationInfo:: " + operationInfo.getInputName());
        }
    }
    

    logs:

    username:: herman
    password:: herman
    operationInfo:: getQuery