client_sched.java

globus toolkit Math例子

package org.globus.examples.clients.FactoryService_Math_rl;

import java.util.Calendar;
import java.rmi.RemoteException;

import org.apache.axis.message.addressing.Address;
import org.apache.axis.message.addressing.EndpointReferenceType;

import org.globus.examples.stubs.MathService_instance_rl.MathPortType;
import org.globus.examples.stubs.MathService_instance_rl.service.MathServiceAddressingLocator;
import org.globus.examples.stubs.Factory.service.FactoryServiceAddressingLocator;
import org.globus.examples.stubs.Factory.FactoryPortType;
import org.globus.examples.stubs.Factory.CreateResource;
import org.globus.examples.stubs.Factory.CreateResourceResponse;

import org.oasis.wsrf.lifetime.SetTerminationTime;
import org.oasis.wsrf.lifetime.SetTerminationTimeResponse;

/*
 * This client creates a new MathService instance through a FactoryService. This
 * client expects one parameter: the factory URI.
 */
public class Client_sched {

	public static void main(String[] args) {
		FactoryServiceAddressingLocator factoryLocator = new FactoryServiceAddressingLocator();
		MathServiceAddressingLocator instanceLocator = new MathServiceAddressingLocator();

		try {
			String factoryURI = args[0];
			EndpointReferenceType factoryEPR, instanceEPR;
			FactoryPortType mathFactory;
			MathPortType math;

			// Get factory portType
			factoryEPR = new EndpointReferenceType();
			factoryEPR.setAddress(new Address(factoryURI));
			mathFactory = factoryLocator.getFactoryPortTypePort(factoryEPR);

			// Create resource and get endpoint reference of WS-Resource.
			// This resource is our "instance".
			CreateResourceResponse createResponse = mathFactory
					.createResource(new CreateResource());
			instanceEPR = createResponse.getEndpointReference();

			// Get instance PortType
			math = instanceLocator.getMathPortTypePort(instanceEPR);

			System.out.println("Created instance.");

			// Schedule termination in 10 seconds
			Calendar termination = Calendar.getInstance();
			termination.add(Calendar.SECOND, 10);

			SetTerminationTime request;
			SetTerminationTimeResponse response;
			request = new SetTerminationTime(termination);
			response = math.setTerminationTime(request);

			System.out.println("Current time               "
					+ response.getCurrentTime().getTime());
			System.out.println("Requested termination time "
					+ termination.getTime());
			System.out.println("Scheduled termination time "
					+ response.getNewTerminationTime().getTime());

			boolean terminated = false;
			int seconds = 0;
			while (!terminated) {
				try {
					System.out.println("Second " + seconds);
					math.add(10);
					Thread.sleep(1000);
					seconds++;
				} catch (RemoteException e) {
					System.out.println("Resource has been destroyed");
					terminated = true;
				}
			}
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

}