Package net.jini.discovery

Examples of net.jini.discovery.LookupDiscovery.addDiscoveryListener()


    try {
      lookupDiscovery = new LookupDiscovery(groups);

      // hook listener for finding the service
      lookupDiscovery.addDiscoveryListener(new DiscoveryListener() {
        public void discovered(DiscoveryEvent ev) {
          log.debug("received discovery event " + ev);
          ServiceRegistrar[] reg = ev.getRegistrars();
          // once the proxy if found, bail out
          for (int i = 0; i < reg.length && proxy == null; i++) {
View Full Code Here


    new LookupLocatorDiscovery(locArray);
      disco.addDiscoveryListener(new Discoverer());
  }
  else {
      LookupDiscovery disco = new LookupDiscovery(_groups);
      disco.addDiscoveryListener(new Discoverer());
  }
    }

    private final class Discoverer implements DiscoveryListener {
  public void discovered(DiscoveryEvent ev) {
View Full Code Here

  { new BasicServiceType(serviceType) };
  _serviceTemplate = new ServiceTemplate(null, null, attrs);
   
  // set up for discovery
  LookupDiscovery disco = new LookupDiscovery(_groups);
  disco.addDiscoveryListener(new Discoverer());
    }
   
    protected synchronized void addRegistrar(ServiceRegistrar reg) {
  if (_registrars.contains(reg.getServiceID()))
      return;
View Full Code Here

      LookupLocatorDiscovery disco = new LookupLocatorDiscovery(locArray);
      disco.addDiscoveryListener(new Discoverer());
    }
    else {
      LookupDiscovery disco = new LookupDiscovery(_groups);
      disco.addDiscoveryListener(new Discoverer());
    }
  }

  private final class Discoverer implements DiscoveryListener {
    public void discovered(DiscoveryEvent ev) {
View Full Code Here

      { new BasicServiceType(serviceType) };
    _serviceTemplate = new ServiceTemplate(null, null, attrs);
   
    // set up for discovery
    LookupDiscovery disco = new LookupDiscovery(_groups);
    disco.addDiscoveryListener(new Discoverer());
  }
   
  protected synchronized void addRegistrar(ServiceRegistrar reg) {
    if (_registrars.contains(reg.getServiceID()))
      return;
View Full Code Here

                new String[]{
                    "com.sun.jini.test.impl.reggie.MultihomedClientTest"},
                ConfigurationProvider.getInstance(new String[]{
                    System.getProperty("lookupConfig")}));
            Driver driver = new Driver();
            ld.addDiscoveryListener(driver);
            ServiceRegistrar[] registrars = ld.getRegistrars();
            for (int i=0; i < registrars.length; i++) {
                driver.done = true;
                System.out.println(registrars[i]);
            }
View Full Code Here

             getConfig().getConfiguration());
        lookupDiscoveryList.add(newLD);
        /* Verify discovery - set the expected groups to discover */
        mainListener.setLookupsToDiscover(allLookupsToStart);
        /* Add the listener to the LookupDiscovery utility */
        newLD.addDiscoveryListener(mainListener);
        /* Wait for the discovery of the expected lookup service(s) */
        waitForDiscovery(mainListener);
    }//end run

}//end class ConstructorAllGroups
View Full Code Here

        lookupDiscoveryList.add(ld);
        /* Add a listener to the lookup discovery utility created above,
         * and verify the listener receives no events.
         */
        mainListener.clearAllEventInfo();//listener expects no events
        ld.addDiscoveryListener(mainListener);
        waitForDiscovery(mainListener);
        /* Re-configure the listener to expect events for the lookups
         * started during setup.
         */
        logger.log(Level.FINE, "calling "+methodStr
View Full Code Here

      new LookupDiscovery(dupGroups, getConfig().getConfiguration());
        lookupDiscoveryList.add(newLD);
        /* Verify discovery - set the expected groups to discover */
        mainListener.setLookupsToDiscover(newLookups,dupGroups);
        /* Add the listener to the LookupDiscovery utility */
        newLD.addDiscoveryListener(mainListener);
        /* Wait for the discovery of the expected lookup service(s) */
        waitForDiscovery(mainListener);
    }//end run

}//end class ConstructorDups
View Full Code Here

         * discovered by both listeners.
         */
        logger.log(Level.FINE,
                      "verifying discovery for initial listener ...");
        mainListener.setLookupsToDiscover(initLookupsToStart);
        ld.addDiscoveryListener(mainListener);
        waitForDiscovery(mainListener);

        logger.log(Level.FINE,
                 "verifying discovery for listener to be removed ...");
        newListener.setLookupsToDiscover(initLookupsToStart);
View Full Code Here

TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.