本文整理了Java中org.apache.cxf.endpoint.Server.getEndpoint()
方法的一些代码示例,展示了Server.getEndpoint()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Server.getEndpoint()
方法的具体详情如下:
包路径:org.apache.cxf.endpoint.Server
类名称: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());
}
内容来源于网络,如有侵权,请联系作者删除!