javax.management.openmbean.TabularData#keySet ( )源码实例Demo

下面列出了javax.management.openmbean.TabularData#keySet ( ) 实例代码，或者点击链接到github查看源代码，也可以在右侧发表评论。

源代码1 项目： activemq-artemis 文件： JobSchedulerJmxManagementTests.java

@Test
public void testRemvoeJob() throws Exception {
   JobSchedulerViewMBean view = getJobSchedulerMBean();
   assertNotNull(view);
   assertTrue(view.getAllJobs().isEmpty());
   scheduleMessage(60000, -1, -1);
   assertFalse(view.getAllJobs().isEmpty());
   TabularData jobs = view.getAllJobs();
   assertEquals(1, jobs.size());
   for (Object key : jobs.keySet()) {
      String jobId = ((List<?>) key).get(0).toString();
      LOG.info("Attempting to remove Job: {}", jobId);
      view.removeJob(jobId);
   }
   assertTrue(view.getAllJobs().isEmpty());
}

源代码2 项目： activemq-artemis 文件： JobSchedulerJmxManagementTests.java

@Test
public void testGetExecutionCount() throws Exception {
   final JobSchedulerViewMBean view = getJobSchedulerMBean();
   assertNotNull(view);
   assertTrue(view.getAllJobs().isEmpty());
   scheduleMessage(10000, 1000, 10);
   assertFalse(view.getAllJobs().isEmpty());
   TabularData jobs = view.getAllJobs();
   assertEquals(1, jobs.size());
   String jobId = null;
   for (Object key : jobs.keySet()) {
      jobId = ((List<?>) key).get(0).toString();
   }

   final String fixedJobId = jobId;
   LOG.info("Attempting to get execution count for Job: {}", jobId);
   assertEquals(0, view.getExecutionCount(jobId));

   assertTrue("Should execute again", Wait.waitFor(new Wait.Condition() {

      @Override
      public boolean isSatisified() throws Exception {
         return view.getExecutionCount(fixedJobId) > 0;
      }
   }));
}

源代码3 项目： stratio-cassandra 文件： NodeTool.java

@Override
public void execute(NodeProbe probe)
{
    System.out.println("Compaction History: ");

    TabularData tabularData = probe.getCompactionHistory();
    if (tabularData.isEmpty())
    {
        System.out.printf("There is no compaction history");
        return;
    }

    String format = "%-41s%-19s%-29s%-26s%-15s%-15s%s%n";
    List<String> indexNames = tabularData.getTabularType().getIndexNames();
    System.out.printf(format, toArray(indexNames, Object.class));

    Set<?> values = tabularData.keySet();
    for (Object eachValue : values)
    {
        List<?> value = (List<?>) eachValue;
        System.out.printf(format, toArray(value, Object.class));
    }
}

源代码4 项目： boon 文件： MBeans.java

private static Object convertFromTabularDataToMap( Object value ) {
    final TabularData data = ( TabularData ) value;

    final Set<List<?>> keys = ( Set<List<?>> ) data.keySet();

    final Map<String, Object> map = new HashMap<>();
    for ( final List<?> key : keys ) {
        final Object subValue = convertValue( data.get( key.toArray() ) );

        if ( key.size() == 1 ) {
            map.put( convertValue( key.get( 0 ) ).toString(), subValue );
        } else {
            map.put( convertValue( key ).toString(), subValue );
        }
    }

    value = map;
    return value;
}

源代码5 项目： dragonwell8_jdk 文件： RecordingInfo.java

private RecordingInfo(CompositeData cd) {
    id = (int) cd.get("id");
    name = (String) cd.get("name");
    state = (String) cd.get("state");
    dumpOnExit = (boolean) cd.get("dumpOnExit");
    size = (long) cd.get("size");
    disk = (boolean) cd.get("disk");
    maxAge = (Long) cd.get("maxAge");
    maxSize = (Long) cd.get("maxSize");
    startTime = (Long) cd.get("startTime");
    stopTime = (Long) cd.get("stopTime");
    destination = (String) cd.get("destination");
    durationInSeconds = (long) cd.get("duration");
    settings = new LinkedHashMap<>();
    Object map = cd.get("settings");
    if (map instanceof TabularData) {
        TabularData td = (TabularData) map;
        List<String> keyNames = td.getTabularType().getIndexNames();
        int size = keyNames.size();
        for (Object keys : td.keySet()) {
            Object[] keyValues = ((List<?>) keys).toArray();
            for (int i = 0; i < size; i++) {
                String key = keyNames.get(i);
                Object value = keyValues[i];
                if (value instanceof String) {
                    settings.put(key, (String) value);
                }
            }
        }
    }
}

源代码6 项目： TencentKona-8 文件： RecordingInfo.java

private RecordingInfo(CompositeData cd) {
    id = (int) cd.get("id");
    name = (String) cd.get("name");
    state = (String) cd.get("state");
    dumpOnExit = (boolean) cd.get("dumpOnExit");
    size = (long) cd.get("size");
    disk = (boolean) cd.get("disk");
    maxAge = (Long) cd.get("maxAge");
    maxSize = (Long) cd.get("maxSize");
    startTime = (Long) cd.get("startTime");
    stopTime = (Long) cd.get("stopTime");
    destination = (String) cd.get("destination");
    durationInSeconds = (long) cd.get("duration");
    settings = new LinkedHashMap<>();
    Object map = cd.get("settings");
    if (map instanceof TabularData) {
        TabularData td = (TabularData) map;
        List<String> keyNames = td.getTabularType().getIndexNames();
        int size = keyNames.size();
        for (Object keys : td.keySet()) {
            Object[] keyValues = ((List<?>) keys).toArray();
            for (int i = 0; i < size; i++) {
                String key = keyNames.get(i);
                Object value = keyValues[i];
                if (value instanceof String) {
                    settings.put(key, (String) value);
                }
            }
        }
    }
}

源代码7 项目： openjdk-jdk8u 文件： RecordingInfo.java

private RecordingInfo(CompositeData cd) {
    id = (int) cd.get("id");
    name = (String) cd.get("name");
    state = (String) cd.get("state");
    dumpOnExit = (boolean) cd.get("dumpOnExit");
    size = (long) cd.get("size");
    disk = (boolean) cd.get("disk");
    maxAge = (Long) cd.get("maxAge");
    maxSize = (Long) cd.get("maxSize");
    startTime = (Long) cd.get("startTime");
    stopTime = (Long) cd.get("stopTime");
    destination = (String) cd.get("destination");
    durationInSeconds = (long) cd.get("duration");
    settings = new LinkedHashMap<>();
    Object map = cd.get("settings");
    if (map instanceof TabularData) {
        TabularData td = (TabularData) map;
        List<String> keyNames = td.getTabularType().getIndexNames();
        int size = keyNames.size();
        for (Object keys : td.keySet()) {
            Object[] keyValues = ((List<?>) keys).toArray();
            for (int i = 0; i < size; i++) {
                String key = keyNames.get(i);
                Object value = keyValues[i];
                if (value instanceof String) {
                    settings.put(key, (String) value);
                }
            }
        }
    }
}

源代码8 项目： brooklyn-server 文件： JmxValueFunctions.java

public static Map<List<?>, Map<String, Object>> tabularDataToMapOfMaps(TabularData table) {
    Map<List<?>, Map<String, Object>> result = Maps.newLinkedHashMap();
    for (Object k : table.keySet()) {
        final Object[] kValues = ((List<?>)k).toArray();
        CompositeData v = table.get(kValues);
        result.put((List<?>)k, compositeDataToMap(v));
    }
    return result;
}

源代码9 项目： glowroot 文件： LiveJvmServiceImpl.java

private static MBeanDump.MBeanValue getTabularDataValue(TabularData tabularData) {
    // linked hash map used to preserve row ordering
    List<MBeanDump.MBeanValueMapEntry> outerEntries = Lists.newArrayList();
    Set<String> attributeNames = tabularData.getTabularType().getRowType().keySet();
    for (Object key : tabularData.keySet()) {
        // TabularData.keySet() returns "Set<List<?>> but is declared Set<?> for
        // compatibility reasons" (see javadocs) so safe to cast to List<?>
        List<?> keyList = (List<?>) key;
        @SuppressWarnings("argument.type.incompatible")
        String keyString = Joiner.on(", ").join(keyList);
        @SuppressWarnings("argument.type.incompatible")
        CompositeData compositeData = tabularData.get(keyList.toArray());
        // linked hash map used to preserve attribute ordering
        List<MBeanDump.MBeanValueMapEntry> innerEntries = Lists.newArrayList();
        for (String attributeName : attributeNames) {
            innerEntries.add(MBeanDump.MBeanValueMapEntry.newBuilder()
                    .setKey(attributeName)
                    .setValue(getMBeanAttributeValue(compositeData.get(attributeName)))
                    .build());
        }
        outerEntries.add(MBeanDump.MBeanValueMapEntry.newBuilder()
                .setKey(keyString)
                .setValue(MBeanDump.MBeanValue.newBuilder()
                        .setMap(MBeanDump.MBeanValueMap.newBuilder()
                                .addAllEntry(innerEntries))
                        .build())
                .build());
    }
    return MBeanDump.MBeanValue.newBuilder()
            .setMap(MBeanDump.MBeanValueMap.newBuilder()
                    .addAllEntry(outerEntries))
            .build();
}

方法所在类

javax.management.openmbean.TabularData