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

x33g5p2x  于2022-01-30 转载在 其他  
字(6.1k)|赞(0)|评价(0)|浏览(143)

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

Server.getEndpoint介绍

暂无

代码示例

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

@Override
public Map<String, Object> getProperties() {
  if (server != null) {
    return server.getEndpoint();
  }
  if (properties == null) {
    properties = new HashMap<>();
  }
  return properties;
}

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

@Override
public void setProperties(Map<String, Object> properties) {
  this.properties = properties;
  if (server != null) {
    server.getEndpoint().putAll(properties);
  }
}

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

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

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

public List<Interceptor<? extends Message>> getOutInterceptors() {
  if (server == null) {
    return out;
  }
  return new DoubleAddInterceptorList(out, server.getEndpoint().getOutInterceptors());
}

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

public List<Interceptor<? extends Message>> getOutFaultInterceptors() {
  if (server == null) {
    return outFault;
  }
  return new DoubleAddInterceptorList(outFault, server.getEndpoint().getOutFaultInterceptors());
}

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

public List<Interceptor<? extends Message>> getInFaultInterceptors() {
  if (server == null) {
    return inFault;
  }
  return new DoubleAddInterceptorList(inFault, server.getEndpoint().getInFaultInterceptors());
}

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

public List<Interceptor<? extends Message>> getInInterceptors() {
  if (server == null) {
    return in;
  }
  return new DoubleAddInterceptorList(in, server.getEndpoint().getInInterceptors());
}

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

/**
 * Obtain handler chain from annotations.
 * @param server
 *
 */
private void buildHandlerChain(Server server) {
  AnnotationHandlerChainBuilder builder = new AnnotationHandlerChainBuilder();
  @SuppressWarnings("rawtypes")
  List<Handler> chain = new ArrayList<>(handlers);
  chain.addAll(builder.buildHandlerChainFromClass(getServiceBeanClass(),
                          server.getEndpoint().getEndpointInfo().getName(),
                          server.getEndpoint().getService().getName(),
                          this.getBindingId()));
  for (Handler<?> h : chain) {
    injectResources(h);
  }
  ((JaxWsEndpointImpl)server.getEndpoint()).getJaxwsBinding().setHandlerChain(chain);
}

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

public Server create() {
  ClassLoaderHolder orig = null;
  try {
    if (bus != null) {
      ClassLoader loader = bus.getExtension(ClassLoader.class);
      if (loader != null) {
        orig = ClassLoaderUtils.setThreadContextClassloader(loader);
      }
    }
    Server server = super.create();
    initializeResourcesAndHandlerChain(server);
    checkPrivateEndpoint(server.getEndpoint());
    return server;
  } finally {
    if (orig != null) {
      orig.reset();
    }
  }
}

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

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

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

public void startServer(Server server) {
  if (server.getEndpoint().getBinding() instanceof SoapBinding) {
    //found a SOAP binding, add the javascript generation interceptor
    server.getEndpoint().getBinding().getInInterceptors().add(JavascriptGetInterceptor.INSTANCE);
  }
}

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

public void serverStopped(Server server) {
  HelloType ht = (HelloType)server.getEndpoint().get(HelloType.class.getName());
  if (ht != null) {
    unregister(ht);
  }
}

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

public List<Interceptor<? extends Message>> getInInterceptors() {
  if (server == null) {
    return in;
  }
  return new DoubleAddInterceptorList(in, server.getEndpoint().getInInterceptors());
}

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

public List<Interceptor<? extends Message>> getOutFaultInterceptors() {
  if (server == null) {
    return outFault;
  }
  return new DoubleAddInterceptorList(outFault, server.getEndpoint().getOutFaultInterceptors());
}

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

public List<Interceptor<? extends Message>> getInFaultInterceptors() {
  if (server == null) {
    return inFault;
  }
  return new DoubleAddInterceptorList(inFault, server.getEndpoint().getInFaultInterceptors());
}

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

public List<Interceptor<? extends Message>> getOutInterceptors() {
  if (server == null) {
    return out;
  }
  return new DoubleAddInterceptorList(out, server.getEndpoint().getOutInterceptors());
}

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

private void deregisterServants(Bus aBus) {
  synchronized (servantsCache) {
    for (Server servant : servantsCache) {
      //REVISIT: seems using server.stop() doesn't release resource properly.
      servant.destroy();
      LOG.info("Shutdown the EJB Endpoint: " + servant.getEndpoint().getEndpointInfo().getName());
    }
    servantsCache.clear();
  }
}

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

public void stopServer(Server server) {
    updateMap(stopNotificationMap,
         server.getEndpoint().getEndpointInfo().getAddress());
  }
});

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

protected List<PolicyAssertion> getAssertions(PolicyEngine pe, org.apache.cxf.endpoint.Server s) {
    Policy p1 = pe.getServerEndpointPolicy(
             s.getEndpoint().getEndpointInfo(), null, null).getPolicy();
    List<ExactlyOne> pops =
      CastUtils.cast(p1.getPolicyComponents(), ExactlyOne.class);
    assertEquals("New policy must have 1 top level policy operator", 1, pops.size());
    List<All> alts =
      CastUtils.cast(pops.get(0).getPolicyComponents(), All.class);
    assertEquals("1 alternatives should be available", 1, alts.size());
    return CastUtils.cast(alts.get(0).getAssertions(), PolicyAssertion.class);
  }
}

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

@Test
public void testServerFactory() {
  JaxWsServerFactoryBean sf = new JaxWsServerFactoryBean();
  sf.getFeatures().add(new WSAddressingFeature());
  sf.setServiceBean(new GreeterImpl());
  sf.setAddress("http://localhost:" + PORT + "/test");
  sf.setStart(false);
  sf.setBus(getBus());
  Server server = sf.create();
  Endpoint endpoint = server.getEndpoint();
  checkAddressInterceptors(endpoint.getInInterceptors());
}

相关文章