import com.sun.xml.internal.ws.api.pipe.TransportTubeFactory; //导入依赖的package包/类
/**
* Send a response to a non-anonymous address. Also closes the transport back channel
* of {@link Packet} if it's not closed already.
*
* @param packet
*      The response from our server, which will be delivered to the destination.
* @return The response packet that should be used to complete the tubeline response processing
*/
   public Packet process(Packet packet) {
   Fiber.CompletionCallback fiberCallback = null;
   Fiber currentFiber = Fiber.getCurrentIfSet();
   if (currentFiber != null) {
       // Link completion of the current fiber to the new fiber that will
       // deliver the async response. This allows access to the response
       // packet that may be generated by sending a new message for the
       // current async response.

           final Fiber.CompletionCallback currentFiberCallback =
               currentFiber.getCompletionCallback();

                   if (currentFiberCallback != null) {
                     fiberCallback = new Fiber.CompletionCallback() {
                     public void onCompletion(@NotNull Packet response) {
                       currentFiberCallback.onCompletion(response);
                     }

                     public void onCompletion(@NotNull Throwable error) {
                       currentFiberCallback.onCompletion(error);
                     }
                   };
                   currentFiber.setCompletionCallback(null);
           }
   }

   // we need to assemble a pipeline to talk to this endpoint.
           WSEndpoint<?> endpoint = packet.endpoint;
           WSBinding binding = endpoint.getBinding();
   Tube transport = TransportTubeFactory.create(Thread.currentThread().getContextClassLoader(),
       new ClientTubeAssemblerContext(
                   packet.endpointAddress, endpoint.getPort(), (WSService) null,
                   binding, endpoint.getContainer(),
                   ((BindingImpl) binding).createCodec(), null, null));
   Fiber fiber = endpoint.getEngine().createFiber();
   fiber.start(transport, packet, fiberCallback);

   // then we'll proceed the rest like one-way.
   Packet copy = packet.copy(false);
   copy.endpointAddress = null;

   return copy;
   }