org.apache.cxf.Bus.getProperties()方法的使用及代码示例

x33g5p2x  于2022-01-16 转载在 其他  
字(7.1k)|赞(0)|评价(0)|浏览(112)

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

Bus.getProperties介绍

暂无

代码示例

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

public Map<String, Object> getProperties() {
  if (bus != null) {
    return bus.getProperties();
  }
  return properties;
}
public void setProperties(Map<String, Object> s) {

代码示例来源:origin: org.apache.cxf/cxf-core

public Map<String, Object> getProperties() {
  if (bus != null) {
    return bus.getProperties();
  }
  return properties;
}
public void setProperties(Map<String, Object> s) {

代码示例来源:origin: io.cloudsoft.windows/winrm4j-client

static Bus configureBus(Bus bus) {
  // Needed to be async to force the use of Apache HTTP Components client.
  // Details at http://cxf.apache.org/docs/asynchronous-client-http-transport.html.
  // Apache HTTP Components needed to support NTLM authentication.
  bus.getProperties().put(AsyncHTTPConduit.USE_ASYNC, Boolean.TRUE);
  bus.getProperties().put(AsyncHTTPConduitFactory.USE_POLICY, UseAsyncPolicy.ALWAYS);
  return bus;
}

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

public ObjectName getObjectName() throws JMException {
    String busId = bus.getId();
    StringBuilder buffer = new StringBuilder(ManagementConstants.DEFAULT_DOMAIN_NAME).append(':');
    buffer.append(ManagementConstants.BUS_ID_PROP).append('=').append(busId).append(',');
    buffer.append(ManagementConstants.TYPE_PROP).append('=').append(TYPE_VALUE).append(',');
    // Added the instance id to make the ObjectName unique
    String instanceId = (String)bus.getProperties().get(INSTANCE_ID);
    if (StringUtils.isEmpty(instanceId)) {
      instanceId = new StringBuilder().append(bus.hashCode()).toString();
    }
    buffer.append(ManagementConstants.INSTANCE_ID_PROP).append('=').append(instanceId);

    return new ObjectName(buffer.toString());
  }
}

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

public ObjectName getObjectName() throws JMException {
    String busId = bus.getId();
    StringBuilder buffer = new StringBuilder(ManagementConstants.DEFAULT_DOMAIN_NAME).append(':');
    buffer.append(ManagementConstants.BUS_ID_PROP).append('=').append(busId).append(',');
    buffer.append(ManagementConstants.TYPE_PROP).append('=').append(TYPE_VALUE).append(',');
    // Added the instance id to make the ObjectName unique
    String instanceId = (String)bus.getProperties().get(INSTANCE_ID);
    if (StringUtils.isEmpty(instanceId)) {
      instanceId = new StringBuffer().append(bus.hashCode()).toString();
    }
    buffer.append(ManagementConstants.INSTANCE_ID_PROP).append('=').append(instanceId);
    

    return new ObjectName(buffer.toString());
  }
}

代码示例来源:origin: org.apache.cxf/cxf-core

public ObjectName getObjectName() throws JMException {
    String busId = bus.getId();
    StringBuilder buffer = new StringBuilder(ManagementConstants.DEFAULT_DOMAIN_NAME).append(':');
    buffer.append(ManagementConstants.BUS_ID_PROP).append('=').append(busId).append(',');
    buffer.append(ManagementConstants.TYPE_PROP).append('=').append(TYPE_VALUE).append(',');
    // Added the instance id to make the ObjectName unique
    String instanceId = (String)bus.getProperties().get(INSTANCE_ID);
    if (StringUtils.isEmpty(instanceId)) {
      instanceId = new StringBuilder().append(bus.hashCode()).toString();
    }
    buffer.append(ManagementConstants.INSTANCE_ID_PROP).append('=').append(instanceId);

    return new ObjectName(buffer.toString());
  }
}

代码示例来源:origin: org.apache.cxf/cxf-bundle-jaxrs

public ObjectName getObjectName() throws JMException {
    String busId = bus.getId();
    StringBuilder buffer = new StringBuilder(ManagementConstants.DEFAULT_DOMAIN_NAME).append(':');
    buffer.append(ManagementConstants.BUS_ID_PROP).append('=').append(busId).append(',');
    buffer.append(ManagementConstants.TYPE_PROP).append('=').append(TYPE_VALUE).append(',');
    // Added the instance id to make the ObjectName unique
    String instanceId = (String)bus.getProperties().get(INSTANCE_ID);
    if (StringUtils.isEmpty(instanceId)) {
      instanceId = new StringBuffer().append(bus.hashCode()).toString();
    }
    buffer.append(ManagementConstants.INSTANCE_ID_PROP).append('=').append(instanceId);
    

    return new ObjectName(buffer.toString());
  }
}

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

public AsyncHTTPConduitFactory(Bus b) {
  this();
  addListener(b);
  setProperties(b.getProperties());
}

代码示例来源:origin: org.mule.modules/mule-module-servicenow

public void initialize(String serviceEndpoint, String userName,
            String password) throws ConnectionException {
  Object proxy = this.serviceClient;
  java.util.Map<String, Object> requestContext = ((javax.xml.ws.BindingProvider) proxy)
      .getRequestContext();
  // This will show you how to configure the http conduit dynamically
  Client client = ClientProxy.getClient(proxy);
  Bus bus = ((EndpointImpl) client.getEndpoint()).getBus();
  bus.getProperties().put("soap.no.validate.parts", true);
  HTTPConduit http = (HTTPConduit) client.getConduit();
  HTTPClientPolicy httpClientPolicy = new HTTPClientPolicy();
  http.setClient(httpClientPolicy);
  if (StringUtils.isNotBlank(userName) && StringUtils.isNotBlank(password)) {
    requestContext.put(BindingProvider.ENDPOINT_ADDRESS_PROPERTY, serviceEndpoint);
    requestContext.put(BindingProvider.USERNAME_PROPERTY, userName);
    requestContext.put(BindingProvider.PASSWORD_PROPERTY, password);
  }
  setServiceClient(proxy);
}

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

public WSDiscoveryServiceImpl(Bus b) {
  bus = b == null ? BusFactory.newInstance().createBus() : b;
  client = new WSDiscoveryClient();
  update(bus.getProperties());
}
public WSDiscoveryServiceImpl() {

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

public WSDiscoveryServiceImpl() {
  bus = BusFactory.newInstance().createBus();
  client = new WSDiscoveryClient();
  update(bus.getProperties());
}
public WSDiscoveryServiceImpl(Bus b, Map<String, Object> props) {

代码示例来源:origin: org.apache.cxf.services.ws-discovery/cxf-services-ws-discovery-api

public WSDiscoveryServiceImpl(Bus b) {
  bus = b == null ? BusFactory.newInstance().createBus() : b;
  client = new WSDiscoveryClient();
  update(bus.getProperties());
}
public WSDiscoveryServiceImpl() {

代码示例来源:origin: org.apache.cxf.services.ws-discovery/cxf-services-ws-discovery-api

public WSDiscoveryServiceImpl() {
  bus = BusFactory.newInstance().createBus();
  client = new WSDiscoveryClient();
  update(bus.getProperties());
}
public WSDiscoveryServiceImpl(Bus b, Map<String, Object> props) {

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

@AfterClass
public static void afterClass() throws Exception {
  BusFactory.getDefaultBus().getProperties().remove("skip.default.json.provider.registration");
}

代码示例来源:origin: org.apache.cxf/cxf-core

Bus b = ex.getBus();
if (b != null) {
  o.putAll(b.getProperties());

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

Bus b = ex.getBus();
if (b != null) {
  o.putAll(b.getProperties());

代码示例来源:origin: org.apache.cxf/cxf-api

Bus b = ex.getBus();
if (b != null) {
  o.putAll(b.getProperties());

代码示例来源:origin: org.apache.cxf/cxf-bundle-jaxrs

Bus b = ex.getBus();
if (b != null) {
  o.putAll(b.getProperties());

代码示例来源:origin: org.apache.servicemix/servicemix-cxf-se

@Override
protected void doInit() throws Exception {
  //Load configuration
  configuration.setRootDir(context.getWorkspaceRoot());
  configuration.setComponentName(context.getComponentName());
  configuration.load();
  if (configuration.getBusCfg() != null && configuration.getBusCfg().length() > 0) {
    CXF_CONFIG[0] = configuration.getBusCfg();
  } 
  if (bus == null) {
    bus = new SpringBusFactory().createBus(CXF_CONFIG);
    bus.getProperties().put(org.apache.cxf.interceptor.OneWayProcessorInterceptor.USE_ORIGINAL_THREAD, "true");
  }
  super.doInit();
}

代码示例来源:origin: org.apache.tomee/openejb-cxf-transport

bus.getProperties().putAll(PropertiesHelper.map(busProperties));

相关文章