Examples of DiscoveryListener

net.jini.discovery.DiscoveryListener
This interface must be implemented by parties that wish to obtain notifications from a LookupDiscovery object. @author Sun Microsystems, Inc. @see LookupDiscovery
nu.fw.jeti.events.DiscoveryListener
@author E.S. de BoerThe listener interface for receiving disco or browse results. The results are cached for later use.
org.apache.activemq.transport.discovery.DiscoveryListener
A listener of services being added or removed from a network @version $Revision$
org.apache.geronimo.farm.discovery.DiscoveryListener
@version $Rev$ $Date$
org.apache.openejb.server.DiscoveryListener
@version $Rev$ $Date$
org.rzo.netty.mcast.discovery.DiscoveryListener

Examples of org.apache.openejb.server.DiscoveryListener

            }
        }


        private void fireServiceAddedEvent(final URI uri) {
            if (discoveryListener != null) {
                final DiscoveryListener discoveryListener = this.discoveryListener;


                // Have the listener process the event async so that
                // he does not block this thread since we are doing time sensitive
                // processing of events.
                executor.execute(new Runnable() {
                    public void run() {
                        if (discoveryListener != null) {
                            discoveryListener.serviceAdded(uri);
                        }
                    }
                });
            }
        }

View Full Code Here

Examples of org.apache.openejb.server.DiscoveryListener

        final CountDownLatch[] latches = {
            new CountDownLatch(PEERS + 1),
            new CountDownLatch(PEERS + 1)
        };


        final DiscoveryListener listener = new DiscoveryListener() {
            public void serviceAdded(final URI service) {
                System.out.println("added = " + service);
                if (testService.equals(service)) {
                    latches[0].countDown();
                }

View Full Code Here

Examples of org.apache.openejb.server.DiscoveryListener

    }


    @Test
    public void testBroadcastBadUri() throws Exception {


        final DiscoveryListener original = agent.getDiscoveryListener();


        final CountDownLatch latch = new CountDownLatch(1);


        final DiscoveryListener listener = new DiscoveryListener() {
            @Override
            public void serviceAdded(final URI service) {
                latch.countDown();
                System.out.println("added = " + service);
            }

View Full Code Here

Examples of org.apache.openejb.server.DiscoveryListener

        if (log.isInfoEnabled()) {
            log.info(String.format("Removed Service{uri=%s}", uri));
        }


        if (discoveryListener != null) {
            final DiscoveryListener discoveryListener = this.discoveryListener;


            // Have the listener process the event async so that
            // he does not block this thread since we are doing time sensitive
            // processing of events.
            executor.execute(new Runnable() {
                @Override
                public void run() {
                    discoveryListener.serviceRemoved(uri);
                }
            });
        }
    }

View Full Code Here

Examples of org.apache.openejb.server.DiscoveryListener

        if (log.isInfoEnabled()) {
            log.info(String.format("Added Service{uri=%s}", uri));
        }


        if (discoveryListener != null) {
            final DiscoveryListener discoveryListener = this.discoveryListener;


            // Have the listener process the event async so that
            // he does not block this thread since we are doing time sensitive
            // processing of events.
            executor.execute(new Runnable() {
                @Override
                public void run() {
                    discoveryListener.serviceAdded(uri);
                }
            });
        }
    }

View Full Code Here

Examples of org.apache.openejb.server.DiscoveryListener

        if (log.isInfoEnabled()) {
            log.info(String.format("Removed Service{uri=%s}", uri));
        }


        if (discoveryListener != null) {
            final DiscoveryListener discoveryListener = this.discoveryListener;


            // Have the listener process the event async so that
            // he does not block this thread since we are doing time sensitive
            // processing of events.
            executor.execute(new Runnable() {
                @Override
                public void run() {
                    discoveryListener.serviceRemoved(uri);
                }
            });
        }
    }

View Full Code Here

Examples of org.apache.openejb.server.DiscoveryListener

        if (log.isInfoEnabled()) {
            log.info(String.format("Added Service{uri=%s}", uri));
        }


        if (discoveryListener != null) {
            final DiscoveryListener discoveryListener = this.discoveryListener;


            // Have the listener process the event async so that
            // he does not block this thread since we are doing time sensitive
            // processing of events.
            executor.execute(new Runnable() {
                @Override
                public void run() {
                    discoveryListener.serviceAdded(uri);
                }
            });
        }
    }

View Full Code Here

Examples of org.apache.openejb.server.DiscoveryListener

        final CountDownLatch[] latches = {
                new CountDownLatch(PEERS + 1),
                new CountDownLatch(PEERS + 1)
        };


        final DiscoveryListener listener = new DiscoveryListener() {
            public void serviceAdded(URI service) {
                System.out.println("added = " + service);
                if (testService.equals(service)) {
                    latches[0].countDown();
                }

View Full Code Here

Examples of org.rzo.netty.mcast.discovery.DiscoveryListener

        
      }, 0, 500);




        discovery.setName("serviceManagerServer");
        discovery.addListener(new DiscoveryListener()
        {


      public void newHost(String serviceName, String host)
      {
        try

View Full Code Here

Examples of org.rzo.netty.mcast.discovery.DiscoveryListener

    {
      discovery = new DiscoveryClient();
      bootstrap.setPipelineFactory(new AHessianClientPipelineFactory(executor, factory, null));


      discovery.setName(discoveryName);
      discovery.addListener(new DiscoveryListener()
      {
        // we have discovered our mbean server
        public void newHost(String name, String host)
        {
          try

View Full Code Here

0 1 2 3 4 5

TOP

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.