Examples of MeasurementDataTrait

Examples of org.rhq.core.domain.measurement.MeasurementDataTrait

170
171
172
173
174
175
176
177
178
179
180
                        } else {
                            report.addData(new MeasurementDataNumeric(request, value.doubleValue()));
                        }

                    } else {
                        report.addData(new MeasurementDataTrait(request, valueObject.toString()));
                    }
                } else {
                    LOG.warn("Attribute " + attributeName + " not found");
                }
            } else {
View Full Code Here

Examples of org.rhq.core.domain.measurement.MeasurementDataTrait

310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
                    try {
                        jdbcConnection = getPooledConnectionProvider().getPooledConnection();
                        statement = jdbcConnection.createStatement();
                        resultSet = statement.executeQuery("SELECT pg_postmaster_start_time()");
                        if (resultSet.next()) {
                            report.addData(new MeasurementDataTrait(request, resultSet.getTimestamp(1).toString()));
                        }
                    } catch (SQLException e) {
                        if (LOG.isDebugEnabled()) {
                            LOG.debug("Can not collect metric: " + metricName + ": " + e.getLocalizedMessage());
                        }
                    } finally {
                        DatabasePluginUtil.safeClose(jdbcConnection, statement, resultSet);
                    }
                } else if (metricName.endsWith("backends")) {
                    // number of connected backends
                    Connection jdbcConnection = null;
                    Statement statement = null;
                    ResultSet resultSet = null;
                    try {
                        jdbcConnection = getPooledConnectionProvider().getPooledConnection();
                        statement = jdbcConnection.createStatement();
                        resultSet = statement.executeQuery("select count(*) from pg_stat_activity");
                        if (resultSet.next()) {
                            report.addData(new MeasurementDataNumeric(request, (double) resultSet.getLong(1)));
                        }
                    } catch (SQLException e) {
                        if (LOG.isDebugEnabled()) {
                            LOG.debug("Can not collect metricName: " + metricName + ": " + e.getLocalizedMessage());
                        }
                    } finally {
                        DatabasePluginUtil.safeClose(jdbcConnection, statement, resultSet);
                    }
                }
            } else if (metricName.startsWith(METRIC_RUNTIME_PREFIX)) {
                runtimePropertiesRequests.put(metricName.substring(METRIC_RUNTIME_PREFIX.length()), request);
            }
        }

        if (!runtimePropertiesRequests.isEmpty()) {
            Connection jdbcConnection = null;
            Statement statement = null;
            ResultSet resultSet = null;
            try {
                jdbcConnection = getPooledConnectionProvider().getPooledConnection();
                statement = jdbcConnection.createStatement();
                resultSet = statement.executeQuery("show all");

                while (resultSet.next()) {
                    String runtimeProperty = resultSet.getString("name");
                    if (!runtimePropertiesRequests.containsKey(runtimeProperty)) {
                        continue;
                    }
                    String setting = resultSet.getString("setting");
                    MeasurementScheduleRequest request = runtimePropertiesRequests.get(runtimeProperty);
                    switch (request.getDataType()) {
                    case TRAIT:
                        report.addData(new MeasurementDataTrait(request, setting));
                        break;
                    default:
                        if (LOG.isDebugEnabled()) {
                            LOG.debug("Unsupported metric data type: " + request.getName() + ", "
                                + request.getDataType());
View Full Code Here

Examples of org.rhq.core.domain.measurement.MeasurementDataTrait

167
168
169
170
171
172
173
174
175
176
177
                        if ("model".equals(property) || "vendor".equals(property)) {
                            res = (String) o;
                        } else {
                            res = String.valueOf(o);
                        }
                        report.addData(new MeasurementDataTrait(request, res));
                    }
                }
            }
        }
        return;
View Full Code Here

Examples of org.rhq.core.domain.measurement.MeasurementDataTrait

124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
     */
    private void resolveDeployDir(MeasurementReport report, MeasurementScheduleRequest request) {

        if ("JDG".equals(pluginConfiguration.getSimpleValue("productType", "AS7"))) {
            LOG.debug("This is a JDG server, so there is no deployDir");
            MeasurementDataTrait trait = new MeasurementDataTrait(request, "- not applicable to JDG -");
            report.addData(trait);
            return;
        }

        // So we have an AS7/EAP6
        Address scanner = new Address("subsystem=deployment-scanner,scanner=default");
        ReadResource op = new ReadResource(scanner);
        Result res = getASConnection().execute(op);
        if (res.isSuccess()) {
            @SuppressWarnings("unchecked")
            Map<String, String> scannerMap = (Map<String, String>) res.getResult();
            String path = scannerMap.get("path");
            String relativeTo = scannerMap.get("relative-to");
            File basePath = resolveRelativePath(relativeTo);

            // It is safe to use File.separator, as the agent we are running in, will also lay down the plugins
            String deployDir = new File(basePath, path).getAbsolutePath();

            MeasurementDataTrait trait = new MeasurementDataTrait(request, deployDir);
            report.addData(trait);
        } else {
            LOG.error("No default deployment scanner was found, returning no value");
        }
    }
View Full Code Here

Examples of org.rhq.core.domain.measurement.MeasurementDataTrait

93
94
95
96
97
98
99
100
101
102
103
            resultSet = statement.executeQuery();
            if (resultSet.next()) {
                for (MeasurementScheduleRequest request : metrics) {
                    String name = request.getName().toUpperCase(Locale.US);
                    if (request.getDataType().equals(DataType.TRAIT)) {
                        report.addData(new MeasurementDataTrait(request, resultSet.getString(name)));
                    } else {
                        try {
                            report.addData(new MeasurementDataNumeric(request, resultSet.getDouble(name)));
                        } catch (SQLException e) {
                            // Ignoring metrics that cannot be read as a double
View Full Code Here

Examples of org.rhq.core.domain.measurement.MeasurementDataTrait

100
101
102
103
104
105
106
107
108
109
110
111
112
    @Override
    public void getValues(MeasurementReport report, Set<MeasurementScheduleRequest> metrics) throws Exception {
        for (MeasurementScheduleRequest request : metrics) {
            if (request.getName().equals("ipAddress")) {
                report.addData(new MeasurementDataTrait(request, address.getHostAddress()));
            } else if (request.getName().equals("hostName")) {
                report.addData(new MeasurementDataTrait(request, address.getCanonicalHostName()));
            } else if (request.getName().equals("responseTime")) {
                long start = System.currentTimeMillis();
                address.isReachable(PING_TIMEOUT);
                report.addData(new MeasurementDataNumeric(request, (double) (System.currentTimeMillis() - start)));
            }
View Full Code Here

Examples of org.rhq.core.domain.measurement.MeasurementDataTrait

233
234
235
236
237
238
239
240
241
242
243
                // add the metric value to the measurement report
                if (dataMustBeNumeric) {
                    Double numeric = Double.parseDouble(dataValue.toString().trim());
                    report.addData(new MeasurementDataNumeric(request, numeric));
                } else {
                    report.addData(new MeasurementDataTrait(request, dataValue.toString().trim()));
                }
            } catch (Exception e) {
                LOG.error("Failed to obtain measurement [" + metricPropertyName + "]. Cause: " + e);
            }
        }
View Full Code Here

Examples of org.rhq.core.domain.measurement.MeasurementDataTrait

57
58
59
60
61
62
63
64
65
66
67
    @Override
    protected void getValues(MeasurementReport report, Set requests, EmsBean bean) {
        for (MeasurementScheduleRequest request : (Set<MeasurementScheduleRequest>) requests) {
            if (request.getName().equals("ProxyInformation")) {
                String rawProxyInfo = JBossHelper.getRawProxyInfo(bean);
                report.addData(new MeasurementDataTrait(request, rawProxyInfo));
                requests.remove(request);
                break;
            }
        }
View Full Code Here

Examples of org.rhq.core.domain.measurement.MeasurementDataTrait

66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
        }
        Set<MeasurementScheduleRequest> filteredMetrics = new HashSet<MeasurementScheduleRequest>();
        for (MeasurementScheduleRequest request : metrics) {
            String requestName = request.getName();
            if (USAGE_THRESHOLD_SUPPORTED_ATTRIBUTE.equals(requestName)) {
                report.addData(new MeasurementDataTrait(request, String.valueOf(usageThresholdSupported)));
                continue;
            }
            if (requestName.startsWith(USAGE_THRESHOLD_PREFIX)) {
                if (usageThresholdSupported == TRUE) {
                    filteredMetrics.add(request);
                }
                continue;
            }
            if (COLLECTION_USAGE_THRESHOLD_SUPPORTED_ATTRIBUTE.equals(requestName)) {
                report.addData(new MeasurementDataTrait(request, String.valueOf(collectionUsageThresholdSupported)));
                continue;
            }
            if (requestName.startsWith(COLLECTION_USAGE_THRESHOLD_PREFIX)) {
                if (collectionUsageThresholdSupported == TRUE) {
                    filteredMetrics.add(request);
View Full Code Here

Examples of org.rhq.core.domain.measurement.MeasurementDataTrait

111
112
113
114
115
116
117
118
119
120
121
                    // text2
                    value = 1 - numberForTrait;
                }
                String traitValue = (value == 0) ? "red" : "green";

                MeasurementDataTrait datum = new MeasurementDataTrait(request, traitValue);
                report.addData(datum);
            }
        }
        if (flipMetrics) {
            count++;
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.