import com.sun.xml.internal.ws.api.pipe.helper.PipeAdapter; //导入依赖的package包/类
@Override
public @NotNull Tube createClient(@NotNull ClientTubeAssemblerContext context) {
    ClientPipeAssemblerContext ctxt = new ClientPipeAssemblerContext(
            context.getAddress(), context.getWsdlModel(), context.getService(),
            context.getBinding(), context.getContainer());
    return PipeAdapter.adapt(assembler.createClient(ctxt));
}
 

import com.sun.xml.internal.ws.api.pipe.helper.PipeAdapter; //导入依赖的package包/类
@Override
public @NotNull Tube createServer(@NotNull ServerTubeAssemblerContext context) {
    if (!(context instanceof ServerPipeAssemblerContext)) {
        throw new IllegalArgumentException("{0} is not instance of ServerPipeAssemblerContext");
    }
    return PipeAdapter.adapt(assembler.createServer((ServerPipeAssemblerContext) context));
}
 

import com.sun.xml.internal.ws.api.pipe.helper.PipeAdapter; //导入依赖的package包/类
/**
 * Creates a {@link Tube} that does the monitoring of the invocation for a
 * container
 */
public @NotNull Tube createMonitoringTube(@NotNull Tube next) {
    ServerPipelineHook hook = endpoint.getContainer().getSPI(ServerPipelineHook.class);
    if (hook != null) {
        ServerPipeAssemblerContext ctxt = new ServerPipeAssemblerContext(seiModel, wsdlModel, endpoint, terminal, isSynchronous);
        return PipeAdapter.adapt(hook.createMonitoringPipe(ctxt, PipeAdapter.adapt(next)));
    }
    return next;
}
 

import com.sun.xml.internal.ws.api.pipe.helper.PipeAdapter; //导入依赖的package包/类
/**
 * Creates a {@link Tube} that adds container specific security
 */
public @NotNull Tube createSecurityTube(@NotNull Tube next) {
    ServerPipelineHook hook = endpoint.getContainer().getSPI(ServerPipelineHook.class);
    if (hook != null) {
        ServerPipeAssemblerContext ctxt = new ServerPipeAssemblerContext(seiModel, wsdlModel, endpoint, terminal, isSynchronous);
        return PipeAdapter.adapt(hook.createSecurityPipe(ctxt, PipeAdapter.adapt(next)));
    }
    return next;
}
 

import com.sun.xml.internal.ws.api.pipe.helper.PipeAdapter; //导入依赖的package包/类
/**
 * Creates a {@link Tube} that adds container specific security
 */
public @NotNull Tube createSecurityTube(@NotNull Tube next) {
    ClientPipelineHook hook = container.getSPI(ClientPipelineHook.class);
    if (hook != null) {
        ClientPipeAssemblerContext ctxt = new ClientPipeAssemblerContext(address, wsdlModel,
                                  rootOwner, binding, container);
        return PipeAdapter.adapt(hook.createSecurityPipe(ctxt, PipeAdapter.adapt(next)));
    }
    return next;
}
 

import com.sun.xml.internal.ws.api.pipe.helper.PipeAdapter; //导入依赖的package包/类
@Override
public Pipe getAdaptedTubelineHead() {
    if (adaptedHead == null) {
        adaptedHead = PipeAdapter.adapt(head);
    }
    return adaptedHead;
}
 

import com.sun.xml.internal.ws.api.pipe.helper.PipeAdapter; //导入依赖的package包/类
/**
 * creates a {@link Pipe} that dumps messages that pass through.
 */
public Pipe createDumpPipe(String name, PrintStream out, Pipe next) {
    return PipeAdapter.adapt(super.createDumpTube(name, out, PipeAdapter.adapt(next)));
}