import org.globus.wsrf.container.ServiceHost; //导入依赖的package包/类
private void initializeDatabase() throws Exception
{
    // initialize database
    MessageContext context = MessageContext.getCurrentContext();
    String serviceName = ContextUtils.getTargetServicePath(context);
    String serviceAddr = 
        ServiceHost.getHost() + "." +  
            Integer.toString(ServiceHost.getPort());

    String rootCollectionName = serviceAddr + "." + serviceName;
    this.db = new XindiceIndexDatabase(rootCollectionName);

    if (logger.isDebugEnabled()) {
        logger.debug("Initialized database rootCollection: " +
                     rootCollectionName);
    }
    
    this.checkpointThread.setDaemon(true);
    this.checkpointThread.start();        
}
 

import org.globus.wsrf.container.ServiceHost; //导入依赖的package包/类
public workflowmanagementfactoryservice.WMSOutputType createWorkflow(workflowmanagementfactoryservice.WMSInputType wMSInputElement) throws RemoteException, gov.nih.nci.cagrid.workflow.factory.stubs.types.WorkflowException {

	  TavernaWorkflowServiceImplResourceHome home = null;
		ResourceKey key = null;
		int TERM_TIME = 180;
		try {
			System.out.println("Creating a resource for the workflow..");
			Context ctx = new InitialContext();
			String lookupString = Constants.JNDI_SERVICES_BASE_NAME +
			"cagrid/TavernaWorkflowServiceImpl"+ "/home";
			home = (TavernaWorkflowServiceImplResourceHome) ctx.lookup(lookupString);

			key = home.createResource();

			//Create a resource on the Impl Service.
			TavernaWorkflowServiceImplResource workflowResource = home.getResource(key);

			EndpointReferenceType epr = AddressingUtils.createEndpointReference(ServiceHost
					.getBaseURL() + "cagrid/TavernaWorkflowServiceImpl", key);
			
			//If the Client sends a Termination time, use it. Otherwise use the default 180min.
			Calendar termTime = wMSInputElement.getTerminationTime();
			
			if(termTime == null){
				termTime = Calendar.getInstance();
		        termTime.add(Calendar.MINUTE, TERM_TIME);
			}
			workflowResource.setTerminationTime(termTime);
	        
			workflowResource.createWorkflow(wMSInputElement, threadExecutor);
			WMSOutputType wMSOutputElement = new WMSOutputType();
			wMSOutputElement.setWorkflowEPR(epr);
			return wMSOutputElement;
			
		} catch (Exception e1) {
			
			e1.printStackTrace();
			throw new RemoteException(e1.getLocalizedMessage());
		}
	}
 

import org.globus.wsrf.container.ServiceHost; //导入依赖的package包/类
public static EnumerationResponseContainer createEnumerationResponse(EnumIterator enumIter)
    throws EnumerationCreationException {
    try {
        EnumResourceHome resourceHome = EnumResourceHome.getEnumResourceHome();
        VisibilityProperties visibility = new VisibilityProperties(
            "cagrid/" + WsEnumConstants.CAGRID_ENUMERATION_SERVICE_NAME, null);

        EnumResource resource = resourceHome.createEnumeration(
            enumIter, visibility, false);
        ResourceKey key = resourceHome.getKey(resource);

        EnumerationContextType enumContext = 
            EnumProvider.createEnumerationContextType(key);

        URL baseURL = ServiceHost.getBaseURL();
        String serviceURI = baseURL.toString() 
            + "cagrid/" + WsEnumConstants.CAGRID_ENUMERATION_SERVICE_NAME;

        EndpointReferenceType epr = 
            AddressingUtils.createEndpointReference(serviceURI, key);

        EnumerationResponseContainer container = new EnumerationResponseContainer();
        container.setContext(enumContext);
        container.setEPR(epr);
        return container;
    } catch (Exception ex) {
        throw new EnumerationCreationException(ex.getMessage(), ex);
    }
}