Package com.streamreduce.core.model

Examples of com.streamreduce.core.model.Metric

36
37
38
39
40
41
42
43
44
45
46
    public ObjectId objectId;

    @Before
    public void setUp() throws Exception {
        MetricDAO metricDao = new MetricDAO(messageDBDatastore);
        Key<Metric> key = metricDao.save(new Metric()
                .setAccountId(ACCOUNT_ID)
                .setName(MetricName.INVENTORY_ITEM_RESOURCE_USAGE.toString())
                .setType(MetricModeType.ABSOLUTE.toString())
                .setTs(System.currentTimeMillis())
                .setValue(48.12f)
View Full Code Here
59
60
61
62
63
64
65
66
67
    @Test
    public void testGet() throws Exception {
        Assert.assertNotNull(objectId);
        MetricDAO metricDao = new MetricDAO(messageDBDatastore);
        Metric metric = metricDao.get(objectId, ACCOUNT_ID);
        Assert.assertNotNull(metric);
        Assert.assertEquals(metric.getId(), objectId);
    }
View Full Code Here
50
51
52
53
54
55
56
57
    @Override
    public void process(Exchange exchange) throws Exception {
        String payload = exchange.getIn().getBody(String.class);
        JSONObject json = JSONObject.fromObject(payload);
        consumedCounter.inc();
        Metric metric = processPayload(json);
        exchange.getOut().setBody(metric);
    }
View Full Code Here
62
63
64
65
66
67
68
69
70
71
72
73
74
            account = (String) payload.get("account");
        }

        LOGGER.info("Received event {} from queue for account {}", consumedCounter.count(), account);

        Metric metric = null;
        try {
            metric = new Metric(payload);
            metricDAO.save(metric);
            processedCounter.inc();
        }
        catch (Exception e) {
            errorCounter.inc();
View Full Code Here
127
128
129
130
131
132
133
    }

    public Metric get(ObjectId id, String accountId) {
        DBCollection collection = getCollection(accountId);
        BasicDBObject result = (BasicDBObject) collection.findOne(new BasicDBObject("_id", id));
        return new Metric(result);
    }
View Full Code Here
TOP

Related Classes of com.streamreduce.core.model.Metric

  • com.mongodb.BasicDBObject
  • com.streamreduce.core.component.QueueMessageProcessor
  • com.streamreduce.core.dao.MetricDAO
  • com.streamreduce.core.dao.MetricDAOIT
    • Copyright © 2018 www.massapicom. 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.