asp.net upc-a ACTIVATION in Font

Generator DataMatrix in Font ACTIVATION

proxy = (Remote) exporter.export(this); } public void notify(RemoteEvent evt) { System.out.println("expiring... " + evt.toString()); ExpirationWarningEvent eevt = (ExpirationWarningEvent) evt; Lease lease = eevt.getRenewalSetLease(); try { // This is short, for testing. Try 2+ hours lease.renew(20000L); } catch(Exception e) { e.printStackTrace(); } System.out.println("Lease renewed for " + (lease.getExpiration() System.currentTimeMillis())); } public Object getProxy() { return proxy; } } The server will need to register the service and export it as an activatable object. This is done in exactly the same way as in the first example of this chapter. In addition, it will need to 1. Register the lease listener (such as the previous RenewLease) with the activation system as an activatable object. 2. Find a LeaseRenewalService from a lookup service. 3. Register all leases from lookup services with the LeaseRenewalService. Since it may find lookup services before it finds the renewal service, it will need to keep a list of lookup services found before finding the service, in order to register them with it. package activation; import rmi.RemoteFileClassifier; import net.jini.discovery.LookupDiscovery; import net.jini.discovery.DiscoveryListener; import net.jini.discovery.DiscoveryEvent; import net.jini.core.lookup.ServiceRegistrar; import net.jini.core.lookup.ServiceItem; import net.jini.core.lookup.ServiceRegistration; import net.jini.core.lookup.ServiceTemplate; import net.jini.core.event.RemoteEvent; import net.jini.core.event.RemoteEventListener; import net.jini.core.lease.Lease; import net.jini.lease.LeaseRenewalService; import net.jini.lease.LeaseRenewalSet;

import java.rmi.RMISecurityManager; import java.rmi.MarshalledObject; import java.rmi.activation.ActivationDesc; import java.rmi.activation.ActivationGroupDesc; import java.rmi.activation.ActivationGroupDesc.CommandEnvironment; import java.rmi.activation.Activatable; import java.rmi.activation.ActivationGroup; import java.rmi.activation.ActivationGroupID; import java.rmi.activation.ActivationID; import java.rmi.MarshalledObject; import java.util.Properties; import java.util.Vector; import java.rmi.activation.UnknownGroupException; import java.rmi.activation.ActivationException; import java.rmi.RemoteException; /** * FileClassifierServer.java */ public class FileClassifierServerLease implements DiscoveryListener { static final protected String SECURITY_POLICY_FILE = "/home/jan/projects/jini/doc/policy.all"; // Don't forget the trailing '/'! static final protected String CODEBASE = "http://localhost/classes/"; protected RemoteFileClassifier proxy; protected RemoteEventListener leaseProxy; // Lease renewal management protected LeaseRenewalSet leaseRenewalSet = null; // List of leases not yet managed by a LeaseRenewalService protected Vector leases = new Vector(); public static void main(String argv[]) { new FileClassifierServerLease(argv); // stick around while lookup services are found try { Thread.sleep(10000L); } catch(InterruptedException e) { // do nothing } // the server doesn't need to exist anymore System.exit(0); } public FileClassifierServerLease(String[] argv) { // install suitable security manager System.setSecurityManager(new RMISecurityManager()); // Install an activation group Properties props = new Properties();

props.put("java.security.policy", SECURITY_POLICY_FILE); ActivationGroupDesc.CommandEnvironment ace = null; ActivationGroupDesc group = new ActivationGroupDesc(props, ace); ActivationGroupID groupID = null; try { groupID = ActivationGroup.getSystem().registerGroup(group); } catch(RemoteException e) { e.printStackTrace(); System.exit(1); } catch(ActivationException e) { e.printStackTrace(); System.exit(1); } try { ActivationGroup.createGroup(groupID, group, 0); } catch(ActivationException e) { e.printStackTrace(); System.exit(1); } String codebase = CODEBASE; MarshalledObject data = null; ActivationDesc desc = null; ActivationDesc descLease = null; try { desc = new ActivationDesc("activation.FileClassifierImpl", codebase, data); descLease = new ActivationDesc("activation.RenewLease", codebase, data); } catch(ActivationException e) { e.printStackTrace(); System.exit(1); } try { proxy = (RemoteFileClassifier) Activatable.register(desc); leaseProxy = (RemoteEventListener) Activatable.register(descLease); } catch(UnknownGroupException e) { e.printStackTrace(); System.exit(1); } catch(ActivationException e) { e.printStackTrace(); System.exit(1); } catch(RemoteException e) { e.printStackTrace();

System.exit(1); } LookupDiscovery discover = null; try { discover = new LookupDiscovery(LookupDiscovery.ALL_GROUPS); } catch(Exception e) { System.err.println(e.toString()); System.exit(1); } discover.addDiscoveryListener(this); } public void discovered(DiscoveryEvent evt) { ServiceRegistrar[] registrars = evt.getRegistrars(); RemoteFileClassifier service; for (int n = 0; n < registrars.length; n++) { ServiceRegistrar registrar = registrars[n]; // export the proxy service ServiceItem item = new ServiceItem(null, proxy, null); ServiceRegistration reg = null; try { reg = registrar.register(item, Lease.FOREVER); } catch(java.rmi.RemoteException e) { System.err.print("Register exception: "); e.printStackTrace(); continue; } try { System.out.println("service registered at " + registrar.getLocator().getHost()); } catch(Exception e) { } Lease lease = reg.getLease(); // if we have a lease renewal manager, use it if (leaseRenewalSet != null) { try { leaseRenewalSet.renewFor(lease, Lease.FOREVER); } catch(RemoteException e) { e.printStackTrace(); } } else { // add to the list of unmanaged leases leases.add(lease); // see if this lookup service has a lease renewal manager

findLeaseService(registrar); } } } public void findLeaseService(ServiceRegistrar registrar) { System.out.println("Trying to find a lease service"); Class[] classes = {LeaseRenewalService.class}; ServiceTemplate template = new ServiceTemplate(null, classes, null); LeaseRenewalService leaseService = null; try { leaseService = (LeaseRenewalService) registrar.lookup(template); } catch(RemoteException e) { e.printStackTrace(); return; } if (leaseService == null) { System.out.println("No lease service found"); return; } try { // This time is unrealistically small - try 10000000L leaseRenewalSet = leaseService.createLeaseRenewalSet(20000); System.out.println("Found a lease service"); // register a timeout listener leaseRenewalSet.setExpirationWarningListener(leaseProxy, 5000, null); // manage all the leases found so far for (int n = 0; n < leases.size(); n++) { Lease ll = (Lease) leases.elementAt(n); leaseRenewalSet.renewFor(ll, Lease.FOREVER); } leases = null; } catch(RemoteException e) { e.printStackTrace(); } Lease renewalLease = leaseRenewalSet.getRenewalSetLease(); System.out.println("Lease expires in " + (renewalLease.getExpiration() System.currentTimeMillis())); } public void discarded(DiscoveryEvent evt) { } } // FileClassifierServerLease An Ant file to build, deploy, and run the service is activation. FileClassifierServerLease.xml. It only differs from the previous Ant files in the files used.