import org.apache.cxf.aegis.databinding.AegisDatabinding; //导入依赖的package包/类
public <T> T createSoapClient(Class<T> serviceClass, URL endpoint, String namespace)
{
	ClientProxyFactoryBean factory = new ClientProxyFactoryBean();
	Bus bus = new ExtensionManagerBus(null, null, Bus.class.getClassLoader());
	factory.setBus(bus);
	factory.setServiceClass(serviceClass);
	factory.setServiceName(new QName(namespace, serviceClass.getSimpleName()));
	factory.setAddress(endpoint.toString());
	factory.getServiceFactory().getServiceConfigurations().add(0, new XFireCompatabilityConfiguration());
	factory.setDataBinding(new AegisDatabinding());
	@SuppressWarnings("unchecked")
	T soapClient = (T) factory.create();
	Client client = ClientProxy.getClient(soapClient);
	client.getRequestContext().put(Message.MAINTAIN_SESSION, true);
	HTTPClientPolicy policy = new HTTPClientPolicy();
	policy.setReceiveTimeout(600000);
	policy.setAllowChunking(false);
	HTTPConduit conduit = (HTTPConduit) client.getConduit();
	conduit.setClient(policy);
	return soapClient;
}
 

import org.apache.cxf.aegis.databinding.AegisDatabinding; //导入依赖的package包/类
@SuppressWarnings("unchecked")
public <T> T createSoap(Class<T> serviceClass, URL endpoint, String namespace, Object previousSession)
{
	ClientProxyFactoryBean factory = new ClientProxyFactoryBean();
	factory.setServiceClass(serviceClass);
	factory.setServiceName(new QName(namespace, serviceClass.getSimpleName()));
	factory.setAddress(endpoint.toString());
	List<AbstractServiceConfiguration> configs = factory.getServiceFactory().getServiceConfigurations();
	configs.add(0, new XFireReturnTypeConfig());
	factory.setDataBinding(new AegisDatabinding());
	T service = (T) factory.create();
	Client client = ClientProxy.getClient(service);
	client.getRequestContext().put(Message.MAINTAIN_SESSION, true);
	HTTPClientPolicy policy = new HTTPClientPolicy();
	policy.setReceiveTimeout(600000);
	policy.setAllowChunking(false);
	HTTPConduit conduit = (HTTPConduit) client.getConduit();
	conduit.setClient(policy);
	if( previousSession != null )
	{
		copyCookiesInt(conduit, previousSession);
	}
	return service;
}
 

import org.apache.cxf.aegis.databinding.AegisDatabinding; //导入依赖的package包/类
/**
* Creates a webservice endpoint for an interface/implementation pair based on their fullnames<p>
* Classes and Interfaces to be used as webservice should be made available in the pom.xml
* 
* @param	serviceInterface  		The interface fullname of the webservice to be added
* @param	serviceImplementation	The implementation class fullname of the webservice to be added
* @throws Exception 
* @see		WebServiceServlet, ServerFactoryBean
*/
  public void addService(String serviceInterface, String serviceImplementation) throws Exception
  {
  	String serviceName = extractServiceName(serviceInterface);
      ServerFactoryBean svrFactory = new ServerFactoryBean();
  	try {
  		if(bus != null) {
  			svrFactory.setBus(bus);
  		}
	svrFactory.setServiceClass(Class.forName(serviceInterface));
	svrFactory.setAddress(baseAddress + serviceName);
	svrFactory.setServiceBean(Class.forName(serviceImplementation).newInstance());
       svrFactory.getServiceFactory().setDataBinding(new AegisDatabinding());
       svrFactory.create();
       System.out.println(svrFactory.getServiceFactory().getEndpointInfo().getAddress());

} catch (Exception e) {
	logger.error("Error adding webservices with interface : " + serviceInterface  + " and implementation : " + serviceImplementation, e);
	throw e;
} 
  }
 

import org.apache.cxf.aegis.databinding.AegisDatabinding; //导入依赖的package包/类
@Before
public void setUp() {
	JaxWsProxyFactoryBean factory = new JaxWsProxyFactoryBean();
	Map<String, Object> props = new HashMap<String, Object>();
	
	List<String> list = new ArrayList<String>();
	list.add(People.class.getName());
	list.add(Boy.class.getName());
	list.add(Person.class.getName());
	props.put("writeXsiType", Boolean.TRUE);
	props.put("overrideTypesList", list);
	
	factory.getServiceFactory().setProperties(props);
	factory.setDataBinding(new AegisDatabinding());
	
	factory.setAddress(ENDPOINT);
	personService = (PersonServiceWithBaseClass)factory.create(PersonServiceWithBaseClass.class);
	
	// bind the outbound interceptor to the client proxy
	Client proxy = ClientProxy.getClient(personService);
	proxy.getOutInterceptors().add(new SystemTokenClientInterceptor(SYSTEM_NIC, SYSTEM_NIC_PW));  
}
 

import org.apache.cxf.aegis.databinding.AegisDatabinding; //导入依赖的package包/类
protected SoapHarvesterService getNewClient(String url, String sharedId, String sharedValue, String username)
{
	try
	{
		final URL endpointUrl = new URL(new URL(url), HARVESTER_ENDPOINT);

		ClientProxyFactoryBean factory = new ClientProxyFactoryBean();
		Bus bus = new ExtensionManagerBus(null, null, Bus.class.getClassLoader());
		factory.setBus(bus);
		factory.setServiceClass(SoapHarvesterService.class);
		factory.setServiceName(
			new QName("http://soap.harvester.core.tle.com", SoapHarvesterService.class.getSimpleName()));
		factory.setAddress(endpointUrl.toString());
		factory.setDataBinding(new AegisDatabinding());
		List<AbstractServiceConfiguration> configs = factory.getServiceFactory().getServiceConfigurations();
		configs.add(0, new XFireReturnTypeConfig());
		SoapHarvesterService soapClient = (SoapHarvesterService) factory.create();
		Client client = ClientProxy.getClient(soapClient);
		client.getRequestContext().put(Message.MAINTAIN_SESSION, true);
		HTTPClientPolicy policy = new HTTPClientPolicy();
		policy.setReceiveTimeout(600000);
		policy.setAllowChunking(false);
		HTTPConduit conduit = (HTTPConduit) client.getConduit();
		// Works?
		// conduit.getTlsClientParameters().setSSLSocketFactory(BlindSSLSocketFactory.getDefaultSSL());
		conduit.setClient(policy);

		soapClient.loginWithToken(TokenGenerator.createSecureToken(username, sharedId, sharedValue, null));
		return soapClient;
	}
	catch( Exception x )
	{
		LOGGER.error("Error connecting to remote EQUELLA server", x);
		throw new RuntimeException(
			CurrentLocale.get("com.tle.core.remoterepo.equella.error.communication", x.getMessage()));
	}
}
 

import org.apache.cxf.aegis.databinding.AegisDatabinding; //导入依赖的package包/类
@Before
  public void setUp() {
JaxWsProxyFactoryBean factory = new JaxWsProxyFactoryBean();
  	factory.getServiceFactory().setDataBinding(new AegisDatabinding());
  	factory.setAddress(ENDPOINT);
  	service = (SayHiService) factory.create(SayHiService.class);  
  }
 

import org.apache.cxf.aegis.databinding.AegisDatabinding; //导入依赖的package包/类
public void setup(Class<?> serviceClass, String wsUrl) {
    ClientFactoryBean factory = new ClientFactoryBean();
    factory.setServiceClass(serviceClass);
    factory.setAddress(wsUrl);
    AegisDatabinding aegisDatabinding = new AegisDatabinding();
    AegisContext aegisCtx = new AegisContext();
    aegisCtx.setReadXsiTypes(true);
    aegisDatabinding.setAegisContext(aegisCtx);
    factory.getServiceFactory().setDataBinding(aegisDatabinding);
    client = factory.create();
}
 

import org.apache.cxf.aegis.databinding.AegisDatabinding; //导入依赖的package包/类
@SuppressWarnings("unchecked")
@Before
   public void setUp() {
   	Map<String, Object> props = new HashMap<String, Object>();
   	List<String> list = new ArrayList<String>();
   	list.add(People.class.getName());
   	list.add(Boy.class.getName());
   	list.add(Person.class.getName());
   	props.put("writeXsiType", Boolean.TRUE);
   	props.put("overrideTypesList", list);
   	
   	//BOY Service
   	JaxWsProxyFactoryBean factory = new JaxWsProxyFactoryBean();
   	
   	factory.getServiceFactory().setProperties(props);
   	factory.setDataBinding(new AegisDatabinding());
   	
   	factory.setServiceClass(PersonServiceWithGeneric.class);
   	factory.setAddress(ENDPOINT);
   	boyService = (PersonServiceWithGeneric<Boy, String>) factory.create();  
   	
   	// bind the outbound interceptor to the client proxy
   	Client proxy1 = ClientProxy.getClient(boyService);
   	proxy1.getOutInterceptors().add(new SystemTokenClientInterceptor(SYSTEM_NIC, SYSTEM_NIC_PW));
   	
   	
   	//PERSON Service
   	JaxWsProxyFactoryBean factory2 = new JaxWsProxyFactoryBean();    	
   	factory2.getServiceFactory().setProperties(props);
   	factory2.getServiceFactory().setDataBinding(new AegisDatabinding());
   	
   	factory2.setAddress(ENDPOINT);
   	personService = (PersonServiceWithGeneric<Person, String>)factory2.create(PersonServiceWithGeneric.class);
   	
   	// bind the outbound interceptor to the client proxy
   	Client proxy2 = ClientProxy.getClient(personService);
   	proxy2.getOutInterceptors().add(new SystemTokenClientInterceptor(SYSTEM_NIC, SYSTEM_NIC_PW));
   	
   	
   	//Generic Service?
   	JaxWsProxyFactoryBean factory3 = new JaxWsProxyFactoryBean();    	
   	factory3.getServiceFactory().setProperties(props);
   	factory3.getServiceFactory().setDataBinding(new AegisDatabinding());
   	
   	factory3.setAddress(ENDPOINT);
   	genericService = (PersonServiceWithGeneric<? super Person, String>)factory3.create(PersonServiceWithGeneric.class);
   	
   	// bind the outbound interceptor to the client proxy
   	Client proxy3 = ClientProxy.getClient(genericService);
   	proxy3.getOutInterceptors().add(new SystemTokenClientInterceptor(SYSTEM_NIC, SYSTEM_NIC_PW));
   }