Examples of MulticastDetector

org.jboss.mx.remote.discovery.multicast.MulticastDetector
MulticastDetector is an implementation of MulticastDetectorMBean that uses multicast for detection @author Tom Elrod @author Jeff Haynie
org.jboss.remoting.detection.multicast.MulticastDetector
MulticastDetector is a remoting detector that broadcasts detection messages using muliticast. The default multicast ip is 224.1.9.1 and port 2410. @author Jeff Haynie @author Adrian Brock @author Tom Elrod @version $Revision: 4969 $

Examples of org.jboss.mx.remote.discovery.multicast.MulticastDetector


            SocketConnector connector = new SocketConnector();
            server.registerMBean(connector, new ObjectName("jmx.remoting:type=Connector,transport=socket"));
            connector.start();


            MulticastDetector detector = new MulticastDetector();
            server.registerMBean(detector, new ObjectName("jmx.remoting:type=Detector,transport=multicast"));
            detector.start();


            ObjectInstance html = server.createMBean("com.sun.jdmk.comm.HtmlAdaptorServer",
                                                     null);
            server.invoke(html.getObjectName(), "setPort",
                          new Object[]{new Integer("8084")}, new String[]{"java.lang.Integer"});

View Full Code Here

Examples of org.jboss.mx.remote.discovery.multicast.MulticastDetector

            SocketConnector connector = new SocketConnector();
            server.registerMBean(connector, new ObjectName("jmx.remoting:type=Connector,transport=socket"));
            connector.start();
            System.err.println("Starting SocketConnector");


            MulticastDetector detector = new MulticastDetector();
            server.registerMBean(detector, new ObjectName("jmx.remoting:type=Detector,transport=multicast"));
            detector.start();
            System.err.println("Starting MulticastDetector");


            CascadingAgent agent = new CascadingAgent();
            server.registerMBean(agent, new ObjectName("jmx.remoting:type=CascadingAgent"));
            agent.start();

View Full Code Here

Examples of org.jboss.remoting.detection.multicast.MulticastDetector

      {
         // we need an MBeanServer to store our network registry and multicast detector services
         MBeanServer server = MBeanServerFactory.createMBeanServer();


         // multicast detector will detect new network registries that come online
         MulticastDetector detector = new MulticastDetector();
         NetworkRegistry registry = NetworkRegistry.getInstance();
         services.setup(server, detector, null, registry, null, true, true);
         detector.start();
      }
      else
      {
         // the internal services singleton is already setup, but make sure it has the services we need
         if (services.getDetector() == null)
         {
            MulticastDetector detector = new MulticastDetector();
            services.assignDetector(detector, null, true);
            detector.start();
         }


         if (services.getNetworkRegistry() == null)
         {
            NetworkRegistry registry = NetworkRegistry.getInstance();

View Full Code Here

Examples of org.jboss.remoting.detection.multicast.MulticastDetector

         Detector detector = null;
         ObjectName objName = null;


         if(type.equals(TYPE_MULTICAST))
         {
            MulticastDetector mdet = new MulticastDetector();
            mdet.setPort(port);
            detector = mdet;
            objName = new ObjectName("remoting:type=Detector,transport=multicast");
         }
         else if(type.equals(TYPE_JNDI))
         {

View Full Code Here

Examples of org.jboss.remoting.detection.multicast.MulticastDetector

      {
         // we need an MBeanServer to store our network registry and multicast detector services
         MBeanServer server = MBeanServerFactory.createMBeanServer();


         // multicast detector will detect new network registries that come online
         MulticastDetector detector = new MulticastDetector();
         services.setup(server, detector, null, null, null, true, false);
         detector.start();
      }
      else if (services.getDetector() == null)
      {
         // the internal services singleton is already setup, make sure it has a detector because we need it
         MulticastDetector detector = new MulticastDetector();
         services.assignDetector(detector, null, true);
         detector.start();
      }


      return;
   }

View Full Code Here

Examples of org.jboss.remoting.detection.multicast.MulticastDetector

        LOG.debug(CommI18NResourceKeys.SERVICE_CONTAINER_REGISTRY_CREATED, OBJECTNAME_NETWORK_REGISTRY);


        if (m_configuration.isMulticastDetectorEnabled()) {
            try {
                // multicast detector will detect new network registries that come online
                m_detector = new MulticastDetector();


                String address = m_configuration.getMulticastDetectorMulticastAddress();
                String bind_address = m_configuration.getMulticastDetectorBindAddress();
                long default_delay = m_configuration.getMulticastDetectorDefaultTimeDelay();
                long heartbeat_delay = m_configuration.getMulticastDetectorHeartbeatTimeDelay();

View Full Code Here

Examples of org.jboss.remoting.detection.multicast.MulticastDetector

            ObjectName obj = new ObjectName("jboss.remoting:type=Connector,transport=" + locator.getProtocol());
            server.registerMBean(connector, obj);


            connector.start();


            MulticastDetector detector = new MulticastDetector();
            server.registerMBean(detector, new ObjectName("remoting:type=Detector,transport=multicast"));
            detector.start();


            PingPong pp = new PingPong();
            ObjectName objName = new ObjectName("test:type=PingPong");
            server.registerMBean(pp, objName);
        }

View Full Code Here

Examples of org.jboss.remoting.detection.multicast.MulticastDetector

   {
      // we need an MBeanServer to store our network registry and multicast detector services
      server = MBeanServerFactory.createMBeanServer();


      // multicast detector will detect new network registries that come online
      detector = new MulticastDetector();
      server.registerMBean(detector, new ObjectName("remoting:type=MulticastDetector"));
      detector.start();


      return;
   }

View Full Code Here

Examples of org.jboss.remoting.detection.multicast.MulticastDetector

      // the registry will house all remoting servers discovered
      registry = NetworkRegistry.getInstance();
      server.registerMBean(registry, new ObjectName("remoting:type=NetworkRegistry"));


      // multicast detector will detect new network registries that come online
      detector = new MulticastDetector();
      server.registerMBean(detector, new ObjectName("remoting:type=MulticastDetector"));
      detector.start();
   }

View Full Code Here

Examples of org.jboss.remoting.detection.multicast.MulticastDetector

   {
      // we need an MBeanServer to store our network registry and multicast detector services
      MBeanServer server = MBeanServerFactory.createMBeanServer();


      // multicast detector will detect new network registries that come online
      MulticastDetector detector = new MulticastDetector();
      server.registerMBean(detector, new ObjectName("remoting:type=MulticastDetector"));
      detector.start();
      println("MulticastDetector has been created and is listening for new NetworkRegistries to come online");


      return;
   }

View Full Code Here

0 1 2 3 4

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.