Java源码示例：com.sun.xml.internal.ws.api.pipe.helper.PipeAdapter
示例1
@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));
}
示例2
/**
* 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;
}
示例3
/**
* 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;
}
示例4
/**
* 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;
}
示例5
/**
* 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;
}
示例6
@Override
public Pipe getAdaptedTubelineHead() {
if (adaptedHead == null) {
adaptedHead = PipeAdapter.adapt(head);
}
return adaptedHead;
}
示例7
@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));
}
示例8
@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));
}
示例9
/**
* 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;
}
示例10
/**
* 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;
}
示例11
/**
* 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;
}
示例12
/**
* 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;
}
示例13
@Override
public Pipe getAdaptedTubelineHead() {
if (adaptedHead == null) {
adaptedHead = PipeAdapter.adapt(head);
}
return adaptedHead;
}
示例14
@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));
}
示例15
@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));
}
示例16
/**
* 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;
}
示例17
/**
* 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;
}
示例18
/**
* 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;
}
示例19
@Override
public Pipe getAdaptedTubelineHead() {
if (adaptedHead == null) {
adaptedHead = PipeAdapter.adapt(head);
}
return adaptedHead;
}
示例20
@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));
}
示例21
@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));
}
示例22
@Override
public Pipe getAdaptedTubelineHead() {
if (adaptedHead == null) {
adaptedHead = PipeAdapter.adapt(head);
}
return adaptedHead;
}
示例23
/**
* 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;
}
示例24
/**
* 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)));
}
示例25
/**
* Creates a {@link Pipe} that adds container specific security
*/
public @NotNull Pipe createSecurityPipe(@NotNull Pipe next) {
return PipeAdapter.adapt(super.createSecurityTube(PipeAdapter.adapt(next)));
}
示例26
/**
* creates a {@link Pipe} that validates messages against schema
*/
public @NotNull Pipe createValidationPipe(@NotNull Pipe next) {
return PipeAdapter.adapt(super.createValidationTube(PipeAdapter.adapt(next)));
}
示例27
/**
* Creates a {@link Pipe} that invokes protocol and logical handlers.
*/
public @NotNull Pipe createHandlerPipe(@NotNull Pipe next) {
return PipeAdapter.adapt(super.createHandlerTube(PipeAdapter.adapt(next)));
}
示例28
/**
* Creates a {@link Tube} that adds container specific security
*/
public @NotNull Pipe createSecurityPipe(@NotNull Pipe next) {
return PipeAdapter.adapt(super.createSecurityTube(PipeAdapter.adapt(next)));
}
示例29
/**
* Creates WS-Addressing pipe
*/
public Pipe createWsaPipe(Pipe next) {
return PipeAdapter.adapt(super.createWsaTube(PipeAdapter.adapt(next)));
}
示例30
/**
* 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)));
}
