org.apache.cxf.endpoint.Client.getEndpoint()方法的使用及代码示例

x33g5p2x  于2022-01-18 转载在 其他  
字(8.0k)|赞(0)|评价(0)|浏览(298)

本文整理了Java中org.apache.cxf.endpoint.Client.getEndpoint()方法的一些代码示例，展示了Client.getEndpoint()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Client.getEndpoint()方法的具体详情如下：
包路径：org.apache.cxf.endpoint.Client
类名称：Client
方法名：getEndpoint

Client.getEndpoint介绍

暂无

代码示例

代码示例来源：origin: org.apache.cxf/cxf-rt-frontend-jaxws

public JaxWsClientProxy(Client c, Binding b) {
  super(c);
  this.binding = b;
  setupEndpointAddressContext(getClient().getEndpoint());
  this.builder = new EndpointReferenceBuilder((JaxWsEndpointImpl)getClient().getEndpoint());
}
public void close() throws IOException {

代码示例来源：origin: org.apache.cxf/cxf-rt-frontend-jaxws

private boolean addressChanged(String address) {
  return !(address == null
       || getClient().getEndpoint().getEndpointInfo() == null
       || address.equals(getClient().getEndpoint().getEndpointInfo().getAddress()));
}

代码示例来源：origin: org.apache.cxf/cxf-rt-transports-http

@Override
public void initialize(Client client, Bus bus) {
  if (contraints == null) {
    return;
  }
  initializeProvider(client, bus);
  CertConstraints c = CertConstraintsJaxBUtils.createCertConstraints(contraints);
  client.getEndpoint().put(CertConstraints.class.getName(), c);
}

代码示例来源：origin: org.apache.cxf/cxf-rt-frontend-jaxws

@Override
protected ClientProxy clientClientProxy(Client c) {
  JaxWsClientProxy cp = new JaxWsClientProxy(c,
                        ((JaxWsEndpointImpl)c.getEndpoint()).getJaxwsBinding());
  cp.getRequestContext().putAll(this.getProperties());
  buildHandlerChain(cp);
  return cp;
}

代码示例来源：origin: org.apache.cxf/cxf-rt-frontend-jaxws

Endpoint endpoint = getClient().getEndpoint();
String address = endpoint.getEndpointInfo().getAddress();
MethodDispatcher dispatcher = (MethodDispatcher)endpoint.getService().get(
} finally {
  if (addressChanged(address)) {
    setupEndpointAddressContext(getClient().getEndpoint());

代码示例来源：origin: org.apache.cxf/cxf-rt-frontend-jaxws

DispatchImpl(Client client, Service.Mode m, JAXBContext ctx, Class<T> clazz) {
  this.binding = ((JaxWsEndpointImpl)client.getEndpoint()).getJaxwsBinding();
  this.builder = new EndpointReferenceBuilder((JaxWsEndpointImpl)client.getEndpoint());
  context = ctx;
  cl = clazz;
  setupEndpointAddressContext(client.getEndpoint());
  addInvokeOperation(false);
  addInvokeOperation(true);
      client.getOutInterceptors().
        add(new MessageModeOutInterceptor(saajOut,
                         client.getEndpoint()
                           .getBinding().getBindingInfo().getName()));
      client.getInInterceptors().add(new SAAJInInterceptor());
      client.getInInterceptors()
        .add(new MessageModeInInterceptor(clazz,
                         client.getEndpoint()
                           .getBinding().getBindingInfo().getName()));

代码示例来源：origin: org.apache.cxf/cxf-rt-frontend-jaxws

= ((JaxWsClientEndpointImpl)client.getEndpoint()).getFeatures();
  List<Feature> allFeatures;
  if (client.getBus().getFeatures() != null) {
    client.getEndpoint().getBinding().getBindingInfo(), hasOpName);
if (findDispatchOp && !payloadOPMap.isEmpty()) {
  QName payloadElementName = null;
            client.getEndpoint().getBinding().getBindingInfo(), hasOpName);
      BindingOperationInfo dbop = client.getEndpoint().getBinding().getBindingInfo()
        .getOperation(dispatchedOpName);
      if (dbop != null) {

代码示例来源：origin: org.apache.cxf/cxf-rt-frontend-jaxws

@SuppressWarnings("unchecked")
private Object invokeAsync(Method method, final BindingOperationInfo oi, Object[] params) throws Exception {
  client.setExecutor(getClient().getEndpoint().getExecutor());
  AsyncHandler<Object> handler;
  if (params.length > 0 && params[params.length - 1] instanceof AsyncHandler) {
    handler = (AsyncHandler<Object>)params[params.length - 1];
    Object[] newParams = new Object[params.length - 1];
    for (int i = 0; i < newParams.length; i++) {
      newParams[i] = params[i];
    }
    params = newParams;
  } else {
    handler = null;
  }
  ClientCallback callback = new JaxwsClientCallback<Object>(handler, this) {
    @Override
    protected Throwable mapThrowable(Throwable t) {
      if (t instanceof Exception) {
        t = mapException(null, oi, (Exception)t);
      }
      return t;
    }
  };
  Response<Object> ret = new JaxwsResponseCallback<>(callback);
  client.invoke(callback, oi, params);
  return ret;
}

代码示例来源：origin: apache/cxf

public ClientProxy(Client c) {
  endpoint = c.getEndpoint();
  client = c;
}
public void close() throws IOException {

代码示例来源：origin: org.apache.cxf/cxf-rt-frontend-jaxws

private void addInvokeOperation(QName operationName, boolean oneWay) {
  ServiceInfo info = client.getEndpoint().getEndpointInfo().getService();
  OperationInfo invokeOpInfo = info.getInterface()
          .getOperation(oneWay ? INVOKE_ONEWAY_QNAME : INVOKE_QNAME);
  OperationInfo opInfo = info.getInterface().addOperation(operationName);
  opInfo.setInput(invokeOpInfo.getInputName(), invokeOpInfo.getInput());
  if (!oneWay) {
    opInfo.setOutput(invokeOpInfo.getOutputName(), invokeOpInfo.getOutput());
  }
  for (BindingInfo bind : client.getEndpoint().getEndpointInfo().getService().getBindings()) {
    BindingOperationInfo bo = new BindingOperationInfo(bind, opInfo);
    bind.addOperation(bo);
  }
}

代码示例来源：origin: org.apache.cxf/cxf-rt-frontend-jaxws

private void addInvokeOperation(boolean oneWay) {
  String name = oneWay ? INVOKE_ONEWAY_NAME : INVOKE_NAME;
  ServiceInfo info = client.getEndpoint().getEndpointInfo().getService();
  OperationInfo opInfo = info.getInterface()
    .addOperation(oneWay ? INVOKE_ONEWAY_QNAME : INVOKE_QNAME);
  MessageInfo mInfo = opInfo.createMessage(new QName(DISPATCH_NS, name + "Request"), Type.INPUT);
  opInfo.setInput(name + "Request", mInfo);
  MessagePartInfo mpi = mInfo.addMessagePart("parameters");
  if (context == null) {
    mpi.setTypeClass(cl);
  }
  mpi.setElement(true);
  if (!oneWay) {
    mInfo = opInfo.createMessage(new QName(DISPATCH_NS, name + "Response"), Type.OUTPUT);
    opInfo.setOutput(name + "Response", mInfo);
    mpi = mInfo.addMessagePart("parameters");
    mpi.setElement(true);
    if (context == null) {
      mpi.setTypeClass(cl);
    }
  }
  for (BindingInfo bind : client.getEndpoint().getEndpointInfo().getService().getBindings()) {
    BindingOperationInfo bo = new BindingOperationInfo(bind, opInfo);
    bind.addOperation(bo);
  }
}

代码示例来源：origin: org.apache.cxf/cxf-rt-frontend-jaxws

public Future<?> invokeAsync(T obj, AsyncHandler<T> asyncHandler) {
  checkError();
  client.setExecutor(getClient().getEndpoint().getExecutor());
    } else {
      hasOpName = true;
      BindingOperationInfo bop = client.getEndpoint().getBinding()
        .getBindingInfo().getOperation(opName);
      if (bop == null) {

代码示例来源：origin: org.apache.cxf/cxf-rt-frontend-jaxws

} else {
  hasOpName = true;
  BindingOperationInfo bop = client.getEndpoint().getBinding()
                .getBindingInfo().getOperation(opName);
  if (bop == null) {

代码示例来源：origin: org.apache.cxf/cxf-rt-frontend-jaxws

client.getEndpoint().setExecutor(executor);
  client.getEndpoint().getEndpointInfo().setAddress(clientFac.getAddress());
} else {
    client.getEndpoint().getEndpointInfo().setAddress(portInfo.getAddress());

代码示例来源：origin: org.apache.cxf/cxf-rt-frontend-jaxws

client.getEndpoint().setExecutor(executor);
client.setExecutor(executor);
JaxWsEndpointImpl jaxwsEndpoint = (JaxWsEndpointImpl) client.getEndpoint();
configureObject(jaxwsEndpoint);
@SuppressWarnings("rawtypes")

代码示例来源：origin: apache/cxf

private boolean addressChanged(String address) {
  return !(address == null
       || getClient().getEndpoint().getEndpointInfo() == null
       || address.equals(getClient().getEndpoint().getEndpointInfo().getAddress()));
}

代码示例来源：origin: apache/cxf

@Override
public void initialize(Client client, Bus bus) {
  client.getEndpoint().getOutInterceptors().add(new JMSConduitConfigOutInterceptor());
  super.initialize(client, bus);
}
@Override

代码示例来源：origin: apache/cxf

@Override
protected ClientProxy clientClientProxy(Client c) {
  JaxWsClientProxy cp = new JaxWsClientProxy(c,
                        ((JaxWsEndpointImpl)c.getEndpoint()).getJaxwsBinding());
  cp.getRequestContext().putAll(this.getProperties());
  buildHandlerChain(cp);
  return cp;
}

代码示例来源：origin: apache/cxf

private WSS4JOutInterceptor addToClient(Object svc) {
  Client client = ClientProxy.getClient(svc);
  WSS4JOutInterceptor wssOut = new WSS4JOutInterceptor();
  client.getEndpoint().getOutInterceptors().add(wssOut);
  client.getOutInterceptors().add(wssOut);
  return wssOut;
}

代码示例来源：origin: org.apache.cxf/cxf-rt-ws-policy

@Override
public void initialize(Client client, Bus bus) {
  Endpoint endpoint = client.getEndpoint();
  Policy p = initializeEndpointPolicy(endpoint, bus);
  PolicyEngine pe = bus.getExtension(PolicyEngine.class);
  EndpointInfo ei = endpoint.getEndpointInfo();
  EndpointPolicy ep = pe.getClientEndpointPolicy(ei, null, null);
  pe.setClientEndpointPolicy(ei, ep.updatePolicy(p, createMessage(endpoint, bus)));
}

内容来源于网络，如有侵权，请联系作者删除！

Client

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com