package com.sun.xml.internal.ws.client.dispatch;
import com.sun.istack.internal.Nullable;
import com.sun.xml.internal.ws.api.addressing.WSEndpointReference;
import com.sun.xml.internal.ws.api.client.ThrowableInPacketCompletionFeature;
import com.sun.xml.internal.ws.api.client.WSPortInfo;
import com.sun.xml.internal.ws.api.message.Packet;
import com.sun.xml.internal.ws.api.pipe.Fiber;
import com.sun.xml.internal.ws.api.pipe.Tube;
import com.sun.xml.internal.ws.binding.BindingImpl;
import com.sun.xml.internal.ws.client.WSServiceDelegate;
import javax.xml.namespace.QName;
import javax.xml.ws.Dispatch;
import javax.xml.ws.Service.Mode;
public class PacketDispatch extends DispatchImpl<Packet> {
private final boolean isDeliverThrowableInPacket;
@Deprecated
public PacketDispatch(QName port, WSServiceDelegate owner, Tube pipe, BindingImpl binding, @Nullable WSEndpointReference epr) {
super(port, Mode.MESSAGE, owner, pipe, binding, epr);
isDeliverThrowableInPacket = calculateIsDeliverThrowableInPacket(binding);
}
public PacketDispatch(WSPortInfo portInfo, Tube pipe, BindingImpl binding, WSEndpointReference epr) {
this(portInfo, pipe, binding, epr, true);
}
public PacketDispatch(WSPortInfo portInfo, Tube pipe, BindingImpl binding, WSEndpointReference epr, boolean allowFaultResponseMsg) {
super(portInfo, Mode.MESSAGE, pipe, binding, epr, allowFaultResponseMsg);
isDeliverThrowableInPacket = calculateIsDeliverThrowableInPacket(binding);
}
public PacketDispatch(WSPortInfo portInfo, BindingImpl binding, WSEndpointReference epr) {
super(portInfo, Mode.MESSAGE, binding, epr, true);
isDeliverThrowableInPacket = calculateIsDeliverThrowableInPacket(binding);
}
private boolean calculateIsDeliverThrowableInPacket(BindingImpl binding) {
return binding.isFeatureEnabled(ThrowableInPacketCompletionFeature.class);
}
@Override
protected void configureFiber(Fiber fiber) {
fiber.setDeliverThrowableInPacket(isDeliverThrowableInPacket);
}
@Override
Packet toReturnValue(Packet response) {
return response;
}
@Override
Packet createPacket(Packet request) {
return request;
}
}