JAX-WS send custom SOAP headers and Set endpoint

String endPointURL=”<ws_service_endpoint_url>”;

String userName=”uname”; //custom header for ws security

String password=”password”; //custom header for ws security

String systemId=”system_id”; //custom header to call WS

String correlationId=”corr_id”; //custom header to call ws

                 

//adding handler to add custom soap header

RetailAccountService serviceLocator=new RetailAccountService();

HeaderHandlerResolver handlerResolver = new HeaderHandlerResolver(userName,password,systemId,correlationId);

serviceLocator.setHandlerResolver(handlerResolver);

                 

//setting webservice endpoint

PncEnterpriseOffersV1RetailInterfacesPortType oppService=serviceLocator.getPncEnterpriseOffersV1RetailInterfacesPort();

BindingProvider bp = (BindingProvider)oppService;          bp.getRequestContext().put(BindingProvider.ENDPOINT_ADDRESS_PROPERTY, endPointURL);

GetOpportunitiesByUserType oppUser=new GetOpportunitiesByUserType();

oppUser.setUser(userId);

GetOpportunitiesByUserResponseType oppRes=oppService.getOpportunitiesByUser(oppUser);

import java.util.ArrayList;

import java.util.List;

import javax.xml.ws.handler.Handler;

import javax.xml.ws.handler.HandlerResolver;

import javax.xml.ws.handler.PortInfo;

public class HeaderHandlerResolver implements HandlerResolver {

      private String userName;

      private String password;

      private String systemId;

      private String correlationId;

      public HeaderHandlerResolver(String userName, String password,

                  String systemId, String correlationId) {

            super();

            this.userName = userName;

            this.password = password;

            this.systemId = systemId;

            this.correlationId = correlationId;

      }

      public List<Handler> getHandlerChain(PortInfo portInfo) {

            List<Handler> handlerChain = new ArrayList<Handler>();

            HeaderHandler hh = new HeaderHandler(userName, password, systemId,

                        correlationId);

            handlerChain.add(hh);

            return handlerChain;

      }

}

import java.io.ByteArrayOutputStream;

import java.util.Set;

import javax.xml.soap.SOAPElement;

import javax.xml.soap.SOAPEnvelope;

import javax.xml.soap.SOAPHeader;

import javax.xml.soap.SOAPMessage;

import javax.xml.ws.handler.MessageContext;

import javax.xml.ws.handler.soap.SOAPHandler;

import javax.xml.ws.handler.soap.SOAPMessageContext;

import org.apache.log4j.Logger;

public class HeaderHandler implements SOAPHandler<SOAPMessageContext> {

      private static Logger log = Logger.getLogger(HeaderHandler.class);

      private String userName;

      private String password;

      private String systemId;

      private String correlationId;

      public HeaderHandler(String userName, String password, String systemId, String correlationId) {

            super();

            this.userName = userName;

            this.password = password;

            this.systemId = systemId;

            this.correlationId = correlationId;

      }

      public boolean handleMessage(SOAPMessageContext smc) {

            // constructing custom soap header

            Boolean outboundProperty = (Boolean) smc.get(MessageContext.MESSAGE_OUTBOUND_PROPERTY);

            if (outboundProperty.booleanValue()) {

                  SOAPMessage message = smc.getMessage();

                  try {

                        SOAPEnvelope envelope = smc.getMessage().getSOAPPart().getEnvelope();

                        SOAPHeader header = envelope.addHeader();

                        SOAPElement securityEle = header.addChildElement("Security", "wsse", "http://docs.oasis-open.org/wss/2004/01/oasis-200401-wss-wssecurity-secext-1.0.xsd");

                        SOAPElement usernameTokenEle = securityEle.addChildElement("UsernameToken", "wsse");

                        SOAPElement usernameEle = usernameTokenEle.addChildElement("Username", "wsse");

                        usernameEle.addTextNode(userName);

                        SOAPElement passwordEle = usernameTokenEle.addChildElement("Password", "wsse");

                        passwordEle.setAttribute("Type", "http://docs.oasis-open.org/wss/2004/01/oasis-200401-wss-username-token-profile-1.0#PasswordText");

                        passwordEle.addTextNode(password);

                        SOAPElement systemContextEle = header.addChildElement("systemContext", "urn", "urn:pnc.common.utils.v1.context");

                        SOAPElement systemIdEle = systemContextEle.addChildElement("systemId");

                        systemIdEle.addTextNode(systemId);

                        SOAPElement correlationIdEle = systemContextEle.addChildElement("correlationId");

                        correlationIdEle.addTextNode(correlationId);

                        // Print out the outbound SOAP message to log

                        ByteArrayOutputStream soapReq = new ByteArrayOutputStream();

                        message.writeTo(soapReq);

                        log.debug("SOAP Request for Operation getOpportunitiesByUser " + new String(soapReq.toByteArray()));

                        soapReq.close();

                  } catch (Exception e) {

                        log.error(e.getMessage(), e);

                  }

            } else {

                  try {

                        // This handler does nothing with the response from the Web

                        // Service so we just log the SOAP message.

                        SOAPMessage message = smc.getMessage();

                        ByteArrayOutputStream soapRes = new ByteArrayOutputStream();

                        message.writeTo(soapRes);

                        log.debug("SOAP Response for Operation getOpportunitiesByUser " + new String(soapRes.toByteArray()));

                        soapRes.close();

                  } catch (Exception e) {

                        log.error(e.getMessage(), e);

                  }

            }

            return outboundProperty;

      }

      public Set getHeaders() {

            // throw new UnsupportedOperationException("Not supported yet.");

            return null;

      }

      public boolean handleFault(SOAPMessageContext context) {

            // throw new UnsupportedOperationException("Not supported yet.");

            return true;

      }

      public void close(MessageContext context) {

            // throw new UnsupportedOperationException("Not supported yet.");

      }

}