ivanursul

import java.util.*;
import java.util.Queue;

public class PubSubModel {

    public static void main(String[] args) {
        List<Consumer> consumers = new ArrayList<>();

        for (int i = 0; i < 3; i++ ) {
            Consumer consumer = new Consumer(

ivanursul

import java.util.*;

public class QueueModel {

    public static void main(String[] args) {
        Queue<String> queue = new LinkedList<>();
        QueueMessageProducer producer = new QueueMessageProducer(queue);

        List<QueueConsumer> consumers = new ArrayList<>();

ivanursul

{
  "version": "3.0.0",
  "gauges": {
    "gauge.response.unmapped": {
      "value": 536
    }
  },
  "counters": {
    "counter.status.401.unmapped": {
      "count": 1

ivanursul

	dependencies {
	  ...
	  
		// metrics
		compile('com.ryantenney.metrics:metrics-spring:3.1.2')
		compile('io.dropwizard.metrics:metrics-jvm:3.1.2')
		compile('io.dropwizard.metrics:metrics-servlets:3.1.2')
	}

ivanursul

graphite.host=localhost  
graphite.port=2003  
graphite.amount.of.time.between.polls=10000  

ivanursul

package org.startup.queue.config;

import com.codahale.metrics.JmxReporter;
import com.codahale.metrics.MetricFilter;
import com.codahale.metrics.MetricRegistry;
import com.codahale.metrics.graphite.Graphite;
import com.codahale.metrics.graphite.GraphiteReporter;
import com.codahale.metrics.graphite.GraphiteReporter.Builder;
import com.codahale.metrics.health.HealthCheckRegistry;
import com.codahale.metrics.jvm.GarbageCollectorMetricSet;

ivanursul

{
  "version": "3.0.0",
  "gauges": {
    "gauge.response.api.establishments.qr.qr": {
      "value": 3
    },
    ...
    "threads.daemon.count": {
      "value": 21
    },

ivanursul

    @Timed
    @ExceptionMetered
    @RequestMapping(method = RequestMethod.POST)
    public ResponseEntity<MessageResource> handleRequest(@RequestBody EstablishmentRequest request) {
        logger.info("Received a new request: {}", request);
        publisher.publishEvent(request);

        return ResponseEntity.ok(
                new MessageResource("ok")
        );

ivanursul

package org.startup.queue.metrics;

import com.codahale.metrics.MetricRegistry;
import com.codahale.metrics.health.HealthCheckRegistry;
import com.codahale.metrics.servlets.HealthCheckServlet;
import com.codahale.metrics.servlets.MetricsServlet;

import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;

ivanursul

package org.startup.queue.config;

import com.codahale.metrics.JmxReporter;
import com.codahale.metrics.MetricRegistry;
import com.codahale.metrics.health.HealthCheckRegistry;
import com.codahale.metrics.servlets.AdminServlet;
import com.ryantenney.metrics.spring.config.annotation.EnableMetrics;
import com.ryantenney.metrics.spring.config.annotation.MetricsConfigurerAdapter;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.context.embedded.ServletRegistrationBean;