当前位置：源码 > Java源码 >

Java源码示例：com.oracle.webservices.internal.api.databinding.JavaCallInfo

示例1

@Override
public Packet serializeResponse(JavaCallInfo call) {
    Method method = call.getMethod();
    Message message = null;
    if (method != null) {
        TieHandler th = tieHandlers.get(method);
        if (th != null) {
            return th.serializeResponse(call);
        }
    }
    if (call.getException() instanceof DispatchException) {
        message = ((DispatchException) call.getException()).fault;
    }
    Packet p = (Packet) packetFactory.createContext(message);
    p.setState(Packet.State.ServerResponse);
    return p;
}

示例2

@Override
public Packet serializeResponse(JavaCallInfo call) {
    Method method = call.getMethod();
    Message message = null;
    if (method != null) {
        TieHandler th = tieHandlers.get(method);
        if (th != null) {
            return th.serializeResponse(call);
        }
    }
    if (call.getException() instanceof DispatchException) {
        message = ((DispatchException) call.getException()).fault;
    }
    Packet p = (Packet) packetFactory.createContext(message);
    p.setState(Packet.State.ServerResponse);
    return p;
}

示例3

@Override
public Packet serializeResponse(JavaCallInfo call) {
    Method method = call.getMethod();
    Message message = null;
    if (method != null) {
        TieHandler th = tieHandlers.get(method);
        if (th != null) {
            return th.serializeResponse(call);
        }
    }
    if (call.getException() instanceof DispatchException) {
        message = ((DispatchException) call.getException()).fault;
    }
    Packet p = (Packet) packetFactory.createContext(message);
    p.setState(Packet.State.ServerResponse);
    return p;
}

示例4

@Override
public Packet serializeResponse(JavaCallInfo call) {
    Method method = call.getMethod();
    Message message = null;
    if (method != null) {
        TieHandler th = tieHandlers.get(method);
        if (th != null) {
            return th.serializeResponse(call);
        }
    }
    if (call.getException() instanceof DispatchException) {
        message = ((DispatchException) call.getException()).fault;
    }
    Packet p = (Packet) packetFactory.createContext(message);
    p.setState(Packet.State.ServerResponse);
    return p;
}

示例5

@Override
public Packet serializeResponse(JavaCallInfo call) {
    Method method = call.getMethod();
    Message message = null;
    if (method != null) {
        TieHandler th = tieHandlers.get(method);
        if (th != null) {
            return th.serializeResponse(call);
        }
    }
    if (call.getException() instanceof DispatchException) {
        message = ((DispatchException) call.getException()).fault;
    }
    Packet p = (Packet) packetFactory.createContext(message);
    p.setState(Packet.State.ServerResponse);
    return p;
}

示例6

@Override
public Packet serializeResponse(JavaCallInfo call) {
    Method method = call.getMethod();
    Message message = null;
    if (method != null) {
        TieHandler th = tieHandlers.get(method);
        if (th != null) {
            return th.serializeResponse(call);
        }
    }
    if (call.getException() instanceof DispatchException) {
        message = ((DispatchException) call.getException()).fault;
    }
    Packet p = (Packet) packetFactory.createContext(message);
    p.setState(Packet.State.ServerResponse);
    return p;
}

示例7

/**
 * Creates a request {@link com.sun.xml.internal.ws.message.jaxb.JAXBMessage} from method arguments.
 * @param args proxy invocation arguments
 * @return Message for the arguments
 */
public Packet createRequestPacket(JavaCallInfo args) {
    Message msg = bodyBuilder.createMessage(args.getParameters());

    for (MessageFiller filler : inFillers) filler.fillIn(args.getParameters(),msg);

    Packet req = (Packet)packetFactory.createContext(msg);
    req.setState(Packet.State.ClientRequest);
    req.soapAction = soapAction;
    req.expectReply = !isOneWay;
    req.getMessage().assertOneWay(isOneWay);
    req.setWSDLOperation(getOperationName());
    return req;
}

示例8

public Message createResponse(JavaCallInfo call) {
        Message responseMessage;
        if (call.getException() == null) {
            responseMessage = isOneWay ? null : createResponseMessage(call.getParameters(), call.getReturnValue());
        } else {
            Throwable e = call.getException();
            Throwable serviceException = getServiceException(e);
            if (e instanceof InvocationTargetException || serviceException != null) {
//              Throwable cause = e.getCause();
              //if (!(cause instanceof RuntimeException) && cause instanceof Exception) {
                if (serviceException != null) {
                    // Service specific exception
                    LOGGER.log(Level.FINE, serviceException.getMessage(), serviceException);
                    responseMessage = SOAPFaultBuilder.createSOAPFaultMessage(soapVersion,
                            javaMethodModel.getCheckedException(serviceException.getClass()), serviceException);
                } else {
                    Throwable cause = e.getCause();
                    if (cause instanceof ProtocolException) {
                        // Application code may be throwing it intentionally
                        LOGGER.log(Level.FINE, cause.getMessage(), cause);
                    } else {
                        // Probably some bug in application code
                        LOGGER.log(Level.SEVERE, cause.getMessage(), cause);
                    }
                    responseMessage = SOAPFaultBuilder.createSOAPFaultMessage(soapVersion, null, cause);
                }
            } else if (e instanceof DispatchException) {
                responseMessage = ((DispatchException)e).fault;
            } else {
                LOGGER.log(Level.SEVERE, e.getMessage(), e);
                responseMessage = SOAPFaultBuilder.createSOAPFaultMessage(soapVersion, null, e);
            }
        }
//        return req.createServerResponse(responseMessage, req.endpoint.getPort(), javaMethodModel.getOwner(), req.endpoint.getBinding());

        return responseMessage;
    }

示例9

@Override
public JavaCallInfo deserializeRequest(Packet req) {
com.sun.xml.internal.ws.api.databinding.JavaCallInfo call = new com.sun.xml.internal.ws.api.databinding.JavaCallInfo();
        call.setMethod(this.getMethod());
Object[] args = this.readRequest(req.getMessage());
        call.setParameters(args);
        return call;
}

示例10

@Override
public Packet serializeResponse(JavaCallInfo call) {
    Message msg = this.createResponse(call);
    Packet p = (msg == null) ? (Packet)packetFactory.createContext() : (Packet)packetFactory.createContext(msg);
    p.setState(Packet.State.ServerResponse);
    return p;
}

示例11

public JavaCallInfo deserializeResponse(Packet res, JavaCallInfo call) {
    StubHandler stubHandler = stubHandlers.get(call.getMethod());
    try {
        return stubHandler.readResponse(res, call);
    } catch (Throwable e) {
        call.setException(e);
        return call;
    }
}

示例12

@Override
public Packet serializeRequest(JavaCallInfo call) {
    StubHandler stubHandler = stubHandlers.get(call.getMethod());
    Packet p = stubHandler.createRequestPacket(call);
    p.setState(Packet.State.ClientRequest);
    return p;
}

示例13

public JavaCallInfo deserializeRequest(Packet req) {
    com.sun.xml.internal.ws.api.databinding.JavaCallInfo call = new com.sun.xml.internal.ws.api.databinding.JavaCallInfo();
    try {
        JavaMethodImpl wsdlOp = resolveJavaMethod(req);
        TieHandler tie = wsdlOpMap.get(wsdlOp);
        call.setMethod(tie.getMethod());
        Object[] args = tie.readRequest(req.getMessage());
        call.setParameters(args);
    } catch (DispatchException e) {
        call.setException(e);
    }
    return call;
}

示例14

/**
 * Creates a request {@link com.sun.xml.internal.ws.message.jaxb.JAXBMessage} from method arguments.
 * @param args proxy invocation arguments
 * @return Message for the arguments
 */
public Packet createRequestPacket(JavaCallInfo args) {
    Message msg = bodyBuilder.createMessage(args.getParameters());

    for (MessageFiller filler : inFillers) filler.fillIn(args.getParameters(),msg);

    Packet req = (Packet)packetFactory.createContext(msg);
    req.setState(Packet.State.ClientRequest);
    req.soapAction = soapAction;
    req.expectReply = !isOneWay;
    req.getMessage().assertOneWay(isOneWay);
    req.setWSDLOperation(getOperationName());
    return req;
}

示例15

public JavaCallInfo readResponse(Packet p, JavaCallInfo call) throws Throwable {
        Message msg = p.getMessage();
if(msg.isFault()) {
    SOAPFaultBuilder faultBuilder = SOAPFaultBuilder.create(msg);
    Throwable t = faultBuilder.createException(checkedExceptions);
    call.setException(t);
    throw t;
} else {
        initArgs(call.getParameters());
    Object ret = responseBuilder.readResponse(msg, call.getParameters());
    call.setReturnValue(ret);
    return call;
}
}

示例16

@Override
public Packet serializeRequest(JavaCallInfo call) {
    StubHandler stubHandler = stubHandlers.get(call.getMethod());
    Packet p = stubHandler.createRequestPacket(call);
    p.setState(Packet.State.ClientRequest);
    return p;
}

示例17

/**
 * Creates a request {@link com.sun.xml.internal.ws.message.jaxb.JAXBMessage} from method arguments.
 * @param args proxy invocation arguments
 * @return Message for the arguments
 */
public Packet createRequestPacket(JavaCallInfo args) {
    Message msg = bodyBuilder.createMessage(args.getParameters());

    for (MessageFiller filler : inFillers) filler.fillIn(args.getParameters(),msg);

    Packet req = (Packet)packetFactory.createContext(msg);
    req.setState(Packet.State.ClientRequest);
    req.soapAction = soapAction;
    req.expectReply = !isOneWay;
    req.getMessage().assertOneWay(isOneWay);
    req.setWSDLOperation(getOperationName());
    return req;
}

示例18

public JavaCallInfo deserializeRequest(Packet req) {
    com.sun.xml.internal.ws.api.databinding.JavaCallInfo call = new com.sun.xml.internal.ws.api.databinding.JavaCallInfo();
    try {
        JavaMethodImpl wsdlOp = resolveJavaMethod(req);
        TieHandler tie = wsdlOpMap.get(wsdlOp);
        call.setMethod(tie.getMethod());
        Object[] args = tie.readRequest(req.getMessage());
        call.setParameters(args);
    } catch (DispatchException e) {
        call.setException(e);
    }
    return call;
}

示例19

public JavaCallInfo deserializeResponse(Packet res, JavaCallInfo call) {
    StubHandler stubHandler = stubHandlers.get(call.getMethod());
    try {
        return stubHandler.readResponse(res, call);
    } catch (Throwable e) {
        call.setException(e);
        return call;
    }
}

示例20

@Override
public Packet serializeRequest(JavaCallInfo call) {
    StubHandler stubHandler = stubHandlers.get(call.getMethod());
    Packet p = stubHandler.createRequestPacket(call);
    p.setState(Packet.State.ClientRequest);
    return p;
}

示例21

public JavaCallInfo deserializeResponse(Packet res, JavaCallInfo call) {
    StubHandler stubHandler = stubHandlers.get(call.getMethod());
    try {
        return stubHandler.readResponse(res, call);
    } catch (Throwable e) {
        call.setException(e);
        return call;
    }
}

示例22

@Override
public JavaCallInfo deserializeRequest(Packet req) {
com.sun.xml.internal.ws.api.databinding.JavaCallInfo call = new com.sun.xml.internal.ws.api.databinding.JavaCallInfo();
        call.setMethod(this.getMethod());
Object[] args = this.readRequest(req.getMessage());
        call.setParameters(args);
        return call;
}

示例23

/**
 * Creates a request {@link com.sun.xml.internal.ws.message.jaxb.JAXBMessage} from method arguments.
 * @param args proxy invocation arguments
 * @return Message for the arguments
 */
public Packet createRequestPacket(JavaCallInfo args) {
    Message msg = bodyBuilder.createMessage(args.getParameters());

    for (MessageFiller filler : inFillers) filler.fillIn(args.getParameters(),msg);

    Packet req = (Packet)packetFactory.createContext(msg);
    req.setState(Packet.State.ClientRequest);
    req.soapAction = soapAction;
    req.expectReply = !isOneWay;
    req.getMessage().assertOneWay(isOneWay);
    req.setWSDLOperation(getOperationName());
    return req;
}

示例24

public JavaCallInfo readResponse(Packet p, JavaCallInfo call) throws Throwable {
        Message msg = p.getMessage();
if(msg.isFault()) {
    SOAPFaultBuilder faultBuilder = SOAPFaultBuilder.create(msg);
    Throwable t = faultBuilder.createException(checkedExceptions);
    call.setException(t);
    throw t;
} else {
        initArgs(call.getParameters());
    Object ret = responseBuilder.readResponse(msg, call.getParameters());
    call.setReturnValue(ret);
    return call;
}
}

示例25

public Message createResponse(JavaCallInfo call) {
        Message responseMessage;
        if (call.getException() == null) {
            responseMessage = isOneWay ? null : createResponseMessage(call.getParameters(), call.getReturnValue());
        } else {
            Throwable e = call.getException();
            Throwable serviceException = getServiceException(e);
            if (e instanceof InvocationTargetException || serviceException != null) {
//              Throwable cause = e.getCause();
              //if (!(cause instanceof RuntimeException) && cause instanceof Exception) {
                if (serviceException != null) {
                    // Service specific exception
                    LOGGER.log(Level.FINE, serviceException.getMessage(), serviceException);
                    responseMessage = SOAPFaultBuilder.createSOAPFaultMessage(soapVersion,
                            javaMethodModel.getCheckedException(serviceException.getClass()), serviceException);
                } else {
                    Throwable cause = e.getCause();
                    if (cause instanceof ProtocolException) {
                        // Application code may be throwing it intentionally
                        LOGGER.log(Level.FINE, cause.getMessage(), cause);
                    } else {
                        // Probably some bug in application code
                        LOGGER.log(Level.SEVERE, cause.getMessage(), cause);
                    }
                    responseMessage = SOAPFaultBuilder.createSOAPFaultMessage(soapVersion, null, cause);
                }
            } else if (e instanceof DispatchException) {
                responseMessage = ((DispatchException)e).fault;
            } else {
                LOGGER.log(Level.SEVERE, e.getMessage(), e);
                responseMessage = SOAPFaultBuilder.createSOAPFaultMessage(soapVersion, null, e);
            }
        }
//        return req.createServerResponse(responseMessage, req.endpoint.getPort(), javaMethodModel.getOwner(), req.endpoint.getBinding());

        return responseMessage;
    }

示例26

@Override
public JavaCallInfo deserializeRequest(Packet req) {
com.sun.xml.internal.ws.api.databinding.JavaCallInfo call = new com.sun.xml.internal.ws.api.databinding.JavaCallInfo();
        call.setMethod(this.getMethod());
Object[] args = this.readRequest(req.getMessage());
        call.setParameters(args);
        return call;
}

示例27

public JavaCallInfo deserializeRequest(Packet req) {
    com.sun.xml.internal.ws.api.databinding.JavaCallInfo call = new com.sun.xml.internal.ws.api.databinding.JavaCallInfo();
    try {
        JavaMethodImpl wsdlOp = resolveJavaMethod(req);
        TieHandler tie = wsdlOpMap.get(wsdlOp);
        call.setMethod(tie.getMethod());
        Object[] args = tie.readRequest(req.getMessage());
        call.setParameters(args);
    } catch (DispatchException e) {
        call.setException(e);
    }
    return call;
}

示例28

@Override
public Packet serializeRequest(JavaCallInfo call) {
    StubHandler stubHandler = stubHandlers.get(call.getMethod());
    Packet p = stubHandler.createRequestPacket(call);
    p.setState(Packet.State.ClientRequest);
    return p;
}

示例29

public JavaCallInfo readResponse(Packet p, JavaCallInfo call) throws Throwable {
        Message msg = p.getMessage();
if(msg.isFault()) {
    SOAPFaultBuilder faultBuilder = SOAPFaultBuilder.create(msg);
    Throwable t = faultBuilder.createException(checkedExceptions);
    call.setException(t);
    throw t;
} else {
        initArgs(call.getParameters());
    Object ret = responseBuilder.readResponse(msg, call.getParameters());
    call.setReturnValue(ret);
    return call;
}
}

示例30

/**
 * Creates a request {@link com.sun.xml.internal.ws.message.jaxb.JAXBMessage} from method arguments.
 * @param args proxy invocation arguments
 * @return Message for the arguments
 */
public Packet createRequestPacket(JavaCallInfo args) {
    Message msg = bodyBuilder.createMessage(args.getParameters());

    for (MessageFiller filler : inFillers) filler.fillIn(args.getParameters(),msg);

    Packet req = (Packet)packetFactory.createContext(msg);
    req.setState(Packet.State.ClientRequest);
    req.soapAction = soapAction;
    req.expectReply = !isOneWay;
    req.getMessage().assertOneWay(isOneWay);
    req.setWSDLOperation(getOperationName());
    return req;
}

Java源码示例：com.oracle.webservices.internal.api.databinding.JavaCallInfo

微信关注