Examples of JmxManager


Examples of com.linkedin.d2.jmx.JmxManager

    wait.await();

    _announcer = new ZooKeeperServer(zk);

    new JmxManager().registerZooKeeperServer("server", (ZooKeeperServer) _announcer);
    new JmxManager().registerZooKeeperEphemeralStore("uris", zk);
    // announce that the server has started
  }
View Full Code Here

Examples of com.linkedin.d2.jmx.JmxManager

                                    loadBalancerStrategyFactories,
                                    null, null, false);

    SimpleLoadBalancer balancer = new SimpleLoadBalancer(state, 5, TimeUnit.SECONDS);

    new JmxManager().registerLoadBalancer("balancer", balancer)
                    .registerLoadBalancerState("state", state);

    return balancer;
  }
View Full Code Here

Examples of com.linkedin.d2.jmx.JmxManager

    // add a bad scheme to possible uris
    _possibleUris.add(URI.create("BADSCHEME://host1001:" + (1000 + _random.nextInt(1000))
        + random(_possiblePaths)));

    // register jmx goodies
    new JmxManager().registerLoadBalancer("SimpleLoadBalancer", _loadBalancer)
                    .registerLoadBalancerState("SimpleLoadBalancerState", _state);
  }
View Full Code Here

Examples of com.linkedin.d2.jmx.JmxManager

    SimpleLoadBalancer balancer = new SimpleLoadBalancer(state, 5, TimeUnit.SECONDS);
    FutureCallback<None> callback = new FutureCallback<None>();
    balancer.start(callback);
    callback.get(5, TimeUnit.SECONDS);

    new JmxManager().registerLoadBalancer("balancer", balancer)
                    .registerLoadBalancerState("state", state)
                    .registerScheduledThreadPoolExecutor("executorService", executor)
                    .registerZooKeeperPermanentStore("zkClusterRegistry", zkClusterRegistry)
                    .registerZooKeeperPermanentStore("zkServiceRegistry",
                                                     zkServiceRegistry)
View Full Code Here

Examples of de.innovationgate.monitoring.JmxManager

           
            // Create JMX monitoring information
            try {
                String dbKey = (String) props.get("hibernate.dbcp.dbkey");
                if (dbKey != null) {
                    _jmxManager = new JmxManager(new DBCPPoolInformation(this), new ObjectName("de.innovationgate.WGAMonitor:name=DBCP-Connection-Pooling,dbkey=" + dbKey));
                }
            }
            catch (Throwable e) {
                log.error("Error enabling JMX metrics for connection pool", e);
            }
View Full Code Here

Examples of de.innovationgate.monitoring.JmxManager

            // Try to instantiate JmxManager. We must test if jmx classes are
            // available
            try {
                Class.forName("java.lang.management.ManagementFactory");
                _wgaMonitor = new JmxManager(new WGAInformation(this), new ObjectName("de.innovationgate.WGAMonitor:context=" + arg0.getServletContext().getServletContextName() + ",name=Information"));
                if (!JmxManager.JMX_DISABLED) {
                log.info("WGA JMX metrics enabled");
            }
            }
            catch (UnsupportedOperationException e) {
View Full Code Here

Examples of org.apache.uima.aae.jmx.JmxManager

      casMultiplier = true;
    }

    paramsMap = new HashMap();
    if (aJmxManagement == null) {
      jmxManagement = new JmxManager(getJMXDomain());
    } else {
      jmxManagement = aJmxManagement;
      if (jmxManagement.getMBeanServer() != null) {
        paramsMap.put(AnalysisEngine.PARAM_MBEAN_SERVER, jmxManagement.getMBeanServer());
      }
View Full Code Here

Examples of org.apache.uima.aae.jmx.JmxManager

      String uuid = UUIDGenerator.generate();
      // JMX does not allow ':' in the ObjectName so replace these with underscore
      uuid = uuid.replaceAll(":", "_");
      uuid = uuid.replaceAll("-", "_");
      applicationName += "_" + uuid;
      jmxManager = new JmxManager("org.apache.uima");
      clientSideJmxStats.setApplicationName(applicationName);
      clientJmxObjectName = new ObjectName("org.apache.uima:name=" + applicationName);
      jmxManager.registerMBean(clientSideJmxStats, clientJmxObjectName);

      // these next lines were an experiment - not used https://issues.apache.org/jira/browse/UIMA-2249
View Full Code Here

Examples of org.apache.uima.aae.jmx.JmxManager

      casMultiplier = true;
    }

    paramsMap = new HashMap();
    if (aJmxManagement == null) {
      jmxManagement = new JmxManager(getJMXDomain());
    } else {
      jmxManagement = aJmxManagement;
      if (jmxManagement.getMBeanServer() != null) {
        paramsMap.put(AnalysisEngine.PARAM_MBEAN_SERVER, jmxManagement.getMBeanServer());
      }
View Full Code Here

Examples of org.apache.uima.aae.jmx.JmxManager

      String uuid = UUIDGenerator.generate();
      // JMX does not allow ':' in the ObjectName so replace these with underscore
      uuid = uuid.replaceAll(":", "_");
      uuid = uuid.replaceAll("-", "_");
      applicationName += "_" + uuid;
      jmxManager = new JmxManager("org.apache.uima");
      clientSideJmxStats.setApplicationName(applicationName);
      clientJmxObjectName = new ObjectName("org.apache.uima:name=" + applicationName);
      jmxManager.registerMBean(clientSideJmxStats, clientJmxObjectName);

      Properties props = new Properties();
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.