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.");
}
}
