javax.management.JMX.newMBeanProxy()方法的使用及代码示例

x33g5p2x  于2022-01-21 转载在 其他  
字(8.8k)|赞(0)|评价(0)|浏览(147)

本文整理了Java中javax.management.JMX.newMBeanProxy()方法的一些代码示例，展示了JMX.newMBeanProxy()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。JMX.newMBeanProxy()方法的具体详情如下：
包路径：javax.management.JMX
类名称：JMX
方法名：newMBeanProxy

JMX.newMBeanProxy介绍

暂无

代码示例

代码示例来源：origin: apache/geode

  1. /**
  2.  * Retrieve a new proxy MBean
  3.  *
  4.  * @return A new proxy MBean of the same type with which the class was constructed
  5.  */
  6. public <T> T getProxyMBean(Class<T> proxyClass, String beanQueryName)
  7.   throws IOException, MalformedObjectNameException {
  8.  return JMX.newMBeanProxy(con, getObjectName(proxyClass, beanQueryName), proxyClass);
  9. }

代码示例来源：origin: neo4j/neo4j

  1. private DiagnosticsReportSource newReportsBeanSource( String destination, ReportsInvoker reportsInvoker )
  2. {
  3.   return DiagnosticsReportSources.newDiagnosticsString( destination, () ->
  4.   {
  5.     try
  6.     {
  7.       ObjectName name = new ObjectName( "org.neo4j:instance=kernel#0,name=Reports" );
  8.       Reports reportsBean = JMX.newMBeanProxy( mBeanServer, name, Reports.class );
  9.       return reportsInvoker.invoke( reportsBean );
  10.     }
  11.     catch ( MalformedObjectNameException ignored )
  12.     {
  13.     }
  14.     return "Unable to invoke ReportsBean";
  15.   } );
  16. }

代码示例来源：origin: apache/geode

  1. @Override
  2. public <T> T getMBeanProxy(final ObjectName objectName, final Class<T> mbeanInterface) {
  3.  if (DistributedSystemMXBean.class.equals(mbeanInterface)
  4.    && ManagementConstants.OBJECTNAME__DISTRIBUTEDSYSTEM_MXBEAN.equals(objectName.toString())) {
  5.   return mbeanInterface.cast(getDistributedSystemMXBean());
  6.  } else if (JMX.isMXBeanInterface(mbeanInterface)) {
  7.   return JMX.newMXBeanProxy(getMBeanServerConnection(), objectName, mbeanInterface);
  8.  } else {
  9.   return JMX.newMBeanProxy(getMBeanServerConnection(), objectName, mbeanInterface);
  10.  }
  11. }

代码示例来源：origin: Netflix/Priam

  1. public static <T> T getRemoteBean(
  2.     Class<T> clazz, String mbeanName, IConfiguration config, boolean mxbean)
  3.     throws IOException, MalformedObjectNameException {
  4.   if (mxbean)
  5.     return ManagementFactory.newPlatformMXBeanProxy(
  6.         JMXNodeTool.instance(config).mbeanServerConn, mbeanName, clazz);
  7.   else
  8.     return JMX.newMBeanProxy(
  9.         JMXNodeTool.instance(config).mbeanServerConn, new ObjectName(mbeanName), clazz);
  10. }

代码示例来源：origin: apache/geode

  1. this.memberMXBeanProxy =
  2.   JMX.newMXBeanProxy(mbsc, managerMemberObjectName, MemberMXBean.class);
  3. this.fileUploadMBeanProxy = JMX.newMBeanProxy(mbsc,
  4.   new ObjectName(ManagementConstants.OBJECTNAME__FILEUPLOADER_MBEAN),
  5.   FileUploaderMBean.class);

代码示例来源：origin: apache/ignite

  1. TcpDiscoverySpi.class.getSimpleName());
  2. TcpDiscoverySpiMBean bean = JMX.newMBeanProxy(srv, spiName, TcpDiscoverySpiMBean.class);

代码示例来源：origin: apache/ignite

  1. /**
  2.  * Test reproduces failure in case of client resolution failure
  3.  * {@link org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi#createTcpClient} from server side, further
  4.  * client reconnect and proper grid work.
  5.  *
  6.  * @throws Exception If failed.
  7.  */
  8. @Test
  9. public void testClientReconnects() throws Exception {
  10.   blockCommSpi = true;
  11.   Ignite srv1 = startGrid("server1-block");
  12.   helper.clientModeThreadLocal(true);
  13.   IgniteEx cli = startGrid("client-block");
  14.   IgniteCache<Object, Object> cache = cli.getOrCreateCache(DEFAULT_CACHE_NAME);
  15.   cache.put(1, 1);
  16.   assertEquals(cache.get(1), 1);
  17.   assertEquals(1, srv1.cluster().forClients().nodes().size());
  18.   MBeanServer srv = ManagementFactory.getPlatformMBeanServer();
  19.   IgniteEx ignite = grid("server1-block");
  20.   ObjectName spiName = U.makeMBeanName(ignite.context().igniteInstanceName(), "SPIs",
  21.     ZookeeperDiscoverySpi.class.getSimpleName());
  22.   ZookeeperDiscoverySpiMBean bean = JMX.newMBeanProxy(srv, spiName, ZookeeperDiscoverySpiMBean.class);
  23.   assertNotNull(bean);
  24.   assertEquals(0, bean.getCommErrorProcNum());
  25. }

代码示例来源：origin: apache/ignite

  1. /**
  2.  * @throws Exception if failed.
  3.  */
  4. @Test
  5. public void testMbean() throws Exception {
  6.   startGrids(3);
  7.   MBeanServer srv = ManagementFactory.getPlatformMBeanServer();
  8.   UUID crdNodeId = grid(0).localNode().id();
  9.   try {
  10.     for (int i = 0; i < 3; i++) {
  11.       IgniteEx grid = grid(i);
  12.       ObjectName spiName = U.makeMBeanName(grid.context().igniteInstanceName(), "SPIs",
  13.         ZookeeperDiscoverySpi.class.getSimpleName());
  14.       ZookeeperDiscoverySpiMBean bean = JMX.newMBeanProxy(srv, spiName, ZookeeperDiscoverySpiMBean.class);
  15.       assertNotNull(bean);
  16.       assertEquals(String.valueOf(grid.cluster().node(crdNodeId)), bean.getCoordinatorNodeFormatted());
  17.       assertEquals(String.valueOf(grid.cluster().localNode()), bean.getLocalNodeFormatted());
  18.       assertEquals(zkCluster.getConnectString(), bean.getZkConnectionString());
  19.       assertEquals((long)grid.configuration().getFailureDetectionTimeout(), bean.getZkSessionTimeout());
  20.     }
  21.   }
  22.   finally {
  23.     stopAllGrids();
  24.   }
  25. }

代码示例来源：origin: palantir/atlasdb

  1. /**
  2.  * Setup JMX client.  This is only used for trace logging.
  3.  */
  4. private HikariPoolMXBean initPoolMbeans() {
  5.   MBeanServer mbeanServer = ManagementFactory.getPlatformMBeanServer();
  6.   ObjectName poolName = null;
  7.   try {
  8.     poolName = new ObjectName("com.zaxxer.hikari:type=Pool (" + connConfig.getConnectionPoolName() + ")");
  9.   } catch (MalformedObjectNameException e) {
  10.     log.error("Unable to setup mBean monitoring for pool {}.", connConfig.getConnectionPoolName(), e);
  11.   }
  12.   return JMX.newMBeanProxy(mbeanServer, poolName, HikariPoolMXBean.class);
  13. }

代码示例来源：origin: com.github.nyla-solutions/nyla.solutions.core

  1. @SuppressWarnings("unchecked")
  2. public <T> T newBean(Class<?> interfaceClass, ObjectName objectName)
  3. {
  4.   if(interfaceClass == null)
  5.     return null;
  6.   return (T)javax.management.JMX.newMBeanProxy(connection, objectName, interfaceClass);
  7. }// --------------------------------------------------------
  8. /**

代码示例来源：origin: org.opendaylight.controller/config-util

  1. /**
  2.  * Usage of this method indicates error as config JMX uses solely MXBeans.
  3.  * Use {@link #newMXBeanProxy(javax.management.ObjectName, Class)}
  4.  * or {@link JMX#newMBeanProxy(javax.management.MBeanServerConnection, javax.management.ObjectName, Class)}
  5.  * This method will be removed soon.
  6.  */
  7. @Deprecated
  8. public <T> T newMBeanProxy(ObjectName on, Class<T> clazz) {
  9.   return JMX.newMBeanProxy(configMBeanServer, on, clazz);
  10. }

代码示例来源：origin: jsevellec/cassandra-unit

  1. public DynamicEndpointSnitchMBean getDynamicEndpointSnitchInfoProxy()
  2. {
  3.   try
  4.   {
  5.     return JMX.newMBeanProxy(mbeanServerConn, new ObjectName("org.apache.cassandra.db:type=DynamicEndpointSnitch"), DynamicEndpointSnitchMBean.class);
  6.   }
  7.   catch (MalformedObjectNameException e)
  8.   {
  9.     throw new RuntimeException(e);
  10.   }
  11. }

代码示例来源：origin: jsevellec/cassandra-unit

  1. public CacheServiceMBean getCacheServiceMBean()
  2. {
  3.   String cachePath = "org.apache.cassandra.db:type=Caches";
  4.   try
  5.   {
  6.     return JMX.newMBeanProxy(mbeanServerConn, new ObjectName(cachePath), CacheServiceMBean.class);
  7.   }
  8.   catch (MalformedObjectNameException e)
  9.   {
  10.     throw new RuntimeException(e);
  11.   }
  12. }

代码示例来源：origin: jsevellec/cassandra-unit

  1. public EndpointSnitchInfoMBean getEndpointSnitchInfoProxy()
  2. {
  3.   try
  4.   {
  5.     return JMX.newMBeanProxy(mbeanServerConn, new ObjectName("org.apache.cassandra.db:type=EndpointSnitchInfo"), EndpointSnitchInfoMBean.class);
  6.   }
  7.   catch (MalformedObjectNameException e)
  8.   {
  9.     throw new RuntimeException(e);
  10.   }
  11. }

代码示例来源：origin: QSFT/Doradus

  1. @SuppressWarnings("unused")
  2. private <T> T createMBeanProxy(String beanName, Class<T> clazz) throws IOException {
  3.   try {
  4.     ObjectName objectName = new ObjectName(beanName);
  5.     return JMX.newMBeanProxy(connection, objectName, clazz);
  6.   } catch (MalformedObjectNameException ex) {
  7.     throw new RuntimeException(ex);
  8.   }
  9. }

代码示例来源：origin: org.apache.cassandra/cassandra-all

  1. public EndpointSnitchInfoMBean getEndpointSnitchInfoProxy()
  2. {
  3.   try
  4.   {
  5.     return JMX.newMBeanProxy(mbeanServerConn, new ObjectName("org.apache.cassandra.db:type=EndpointSnitchInfo"), EndpointSnitchInfoMBean.class);
  6.   }
  7.   catch (MalformedObjectNameException e)
  8.   {
  9.     throw new RuntimeException(e);
  10.   }
  11. }

代码示例来源：origin: org.apache.cassandra/cassandra-all

  1. public DynamicEndpointSnitchMBean getDynamicEndpointSnitchInfoProxy()
  2. {
  3.   try
  4.   {
  5.     return JMX.newMBeanProxy(mbeanServerConn, new ObjectName("org.apache.cassandra.db:type=DynamicEndpointSnitch"), DynamicEndpointSnitchMBean.class);
  6.   }
  7.   catch (MalformedObjectNameException e)
  8.   {
  9.     throw new RuntimeException(e);
  10.   }
  11. }

代码示例来源：origin: org.apache.cassandra/cassandra-all

  1. public CacheServiceMBean getCacheServiceMBean()
  2. {
  3.   String cachePath = "org.apache.cassandra.db:type=Caches";
  4.   try
  5.   {
  6.     return JMX.newMBeanProxy(mbeanServerConn, new ObjectName(cachePath), CacheServiceMBean.class);
  7.   }
  8.   catch (MalformedObjectNameException e)
  9.   {
  10.     throw new RuntimeException(e);
  11.   }
  12. }

代码示例来源：origin: com.facebook.presto.cassandra/cassandra-server

  1. public EndpointSnitchInfoMBean getEndpointSnitchInfoProxy()
  2. {
  3.   try
  4.   {
  5.     return JMX.newMBeanProxy(mbeanServerConn, new ObjectName("org.apache.cassandra.db:type=EndpointSnitchInfo"), EndpointSnitchInfoMBean.class);
  6.   }
  7.   catch (MalformedObjectNameException e)
  8.   {
  9.     throw new RuntimeException(e);
  10.   }
  11. }

代码示例来源：origin: org.apache.geode/gemfire-core

  1. public <T> T getMBeanProxy(final ObjectName objectName, final Class<T> mbeanInterface) {
  2.  if (DistributedSystemMXBean.class.equals(mbeanInterface)
  3.   && ManagementConstants.OBJECTNAME__DISTRIBUTEDSYSTEM_MXBEAN.equals(objectName.toString())) {
  4.   return mbeanInterface.cast(getDistributedSystemMXBean());
  5.  }
  6.  else if (JMX.isMXBeanInterface(mbeanInterface)) {
  7.   return JMX.newMXBeanProxy(getMBeanServerConnection(), objectName, mbeanInterface);
  8.  }
  9.  else {
  10.   return JMX.newMBeanProxy(getMBeanServerConnection(), objectName, mbeanInterface);
  11.  }
  12. }

内容来源于网络，如有侵权，请联系作者删除！

JMX

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com