ohair@286: /*
ohair@286:  * Copyright (c) 1997, 2011, Oracle and/or its affiliates. All rights reserved.
ohair@286:  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
ohair@286:  *
ohair@286:  * This code is free software; you can redistribute it and/or modify it
ohair@286:  * under the terms of the GNU General Public License version 2 only, as
ohair@286:  * published by the Free Software Foundation.  Oracle designates this
ohair@286:  * particular file as subject to the "Classpath" exception as provided
ohair@286:  * by Oracle in the LICENSE file that accompanied this code.
ohair@286:  *
ohair@286:  * This code is distributed in the hope that it will be useful, but WITHOUT
ohair@286:  * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
ohair@286:  * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
ohair@286:  * version 2 for more details (a copy is included in the LICENSE file that
ohair@286:  * accompanied this code).
ohair@286:  *
ohair@286:  * You should have received a copy of the GNU General Public License version
ohair@286:  * 2 along with this work; if not, write to the Free Software Foundation,
ohair@286:  * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
ohair@286:  *
ohair@286:  * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
ohair@286:  * or visit www.oracle.com if you need additional information or have any
ohair@286:  * questions.
ohair@286:  */
ohair@286: 
ohair@286: package com.sun.xml.internal.ws.server.sei;
ohair@286: 
ohair@286: import com.sun.istack.internal.NotNull;
ohair@286: import com.sun.xml.internal.ws.api.SOAPVersion;
ohair@286: import com.sun.xml.internal.ws.api.WSBinding;
ohair@286: import com.sun.xml.internal.ws.api.databinding.EndpointCallBridge;
ohair@286: import com.sun.xml.internal.ws.api.message.Message;
ohair@286: import com.sun.xml.internal.ws.api.message.Packet;
ohair@286: import com.sun.xml.internal.ws.api.pipe.NextAction;
ohair@286: import com.sun.xml.internal.ws.api.server.Invoker;
ohair@286: import com.sun.xml.internal.ws.client.sei.MethodHandler;
ohair@286: import com.sun.xml.internal.ws.model.AbstractSEIModelImpl;
ohair@286: import com.sun.xml.internal.ws.server.InvokerTube;
ohair@286: import com.sun.xml.internal.ws.resources.ServerMessages;
ohair@286: import com.sun.xml.internal.ws.fault.SOAPFaultBuilder;
ohair@286: import com.sun.xml.internal.ws.wsdl.DispatchException;
ohair@286: import com.sun.xml.internal.org.jvnet.ws.databinding.JavaCallInfo;
ohair@286: import java.util.List;
ohair@286: import java.lang.reflect.InvocationTargetException;
ohair@286: import java.text.MessageFormat;
ohair@286: 
ohair@286: /**
ohair@286:  * This pipe is used to invoke SEI based endpoints.
ohair@286:  *
ohair@286:  * @author Jitendra Kotamraju
ohair@286:  */
ohair@286: public class SEIInvokerTube extends InvokerTube {
ohair@286: 
ohair@286:     /**
ohair@286:      * For each method on the port interface we have
ohair@286:      * a {@link MethodHandler} that processes it.
ohair@286:      */
ohair@286:     private final WSBinding binding;
ohair@286:     private final AbstractSEIModelImpl model;
ohair@286: 
ohair@286:     public SEIInvokerTube(AbstractSEIModelImpl model,Invoker invoker, WSBinding binding) {
ohair@286:         super(invoker);
ohair@286:         this.binding = binding;
ohair@286:         this.model = model;
ohair@286:     }
ohair@286: 
ohair@286:     /**
ohair@286:      * This binds the parameters for SEI endpoints and invokes the endpoint method. The
ohair@286:      * return value, and response Holder arguments are used to create a new {@link Message}
ohair@286:      * that traverses through the Pipeline to transport.
ohair@286:      */
ohair@286:     public @NotNull NextAction processRequest(@NotNull Packet req) {
ohair@286:                 JavaCallInfo call = model.getDatabinding().deserializeRequest(req);
ohair@286:                 if (call.getException() == null) {
ohair@286:                         try {
ohair@286:                                 if (req.getMessage().isOneWay(model.getPort()) && req.transportBackChannel != null) {
ohair@286:                                         req.transportBackChannel.close();
ohair@286:                                 }
ohair@286:                                 Object ret = getInvoker(req).invoke(req, call.getMethod(), call.getParameters());
ohair@286:                                 call.setReturnValue(ret);
ohair@286:                                 } catch (InvocationTargetException e) {
ohair@286:                                         call.setException(e);
ohair@286:                                 } catch (Exception e) {
ohair@286:                                         call.setException(e);
ohair@286:                                 }
ohair@286:                         } else if (call.getException() instanceof DispatchException) {
ohair@286:                             DispatchException e = (DispatchException)call.getException();
ohair@286:                             return doReturnWith(req.createServerResponse(e.fault, model.getPort(), null, binding));
ohair@286:                         }
ohair@286:                 Packet res = (Packet) model.getDatabinding().serializeResponse(call);
ohair@286:                         res = req.relateServerResponse(res, req.endpoint.getPort(), model, req.endpoint.getBinding());
ohair@286:             assert res != null;
ohair@286:             return doReturnWith(res);
ohair@286:     }
ohair@286: 
ohair@286:     public @NotNull NextAction processResponse(@NotNull Packet response) {
ohair@286:         throw new IllegalStateException("InovkerPipe's processResponse shouldn't be called.");
ohair@286:     }
ohair@286: 
ohair@286:     public @NotNull NextAction processException(@NotNull Throwable t) {
ohair@286:         throw new IllegalStateException("InovkerPipe's processException shouldn't be called.");
ohair@286:     }
ohair@286: 
ohair@286: }