JAX-WSプロバイダーベースのプロキシ/ゲートウェイの擬似コードは次のとおりです。
@WebServiceProvider
public class ServiceGateway implements Provider<SOAPMessage> {
private static final QName SERVICE_NAME = new QName("http://ws.com",
"Service");
private static final QName PORT_NAME = new QName("http://ws.com", "Port");
private static final String FAULT_MESSAGE = "fault.message";
private static final Service service = Service.create(SERVICE_NAME);
@Override
public SOAPMessage invoke(SOAPMessage inboundMessage) {
Dispatch<SOAPMessage> dispatch = service.createDispatch(PORT_NAME,
SOAPMessage.class, Mode.MESSAGE);
dispatch.getRequestContext().put(
BindingProvider.ENDPOINT_ADDRESS_PROPERTY,
"http://real.destination.address");
// Handler is required to pass SOAPFault messages
@SuppressWarnings("rawtypes")
List<Handler> handlers = new ArrayList<Handler>(dispatch.getBinding()
.getHandlerChain());
handlers.add(new SOAPHandler<SOAPMessageContext>() {
@Override
public void close(MessageContext context) {
}
@Override
public boolean handleFault(SOAPMessageContext context) {
context.put(FAULT_MESSAGE, context.getMessage());
context.setScope(FAULT_MESSAGE, Scope.APPLICATION);
return true;
}
@Override
public boolean handleMessage(SOAPMessageContext context) {
return true;
}
@Override
public Set<QName> getHeaders() {
return null;
}
});
dispatch.getBinding().setHandlerChain(handlers);
try {
return dispatch.invoke(inboundMessage);
} catch (SOAPFaultException exception) {
return (SOAPMessage) dispatch.getResponseContext().get(
FAULT_MESSAGE);
}
}
}