benhubert

@Aspect
public class MethodProfiler {

    private final StatsDClient statsd;

    public MethodProfiler(StatsDClient statsd) {
        this.statsd = statsd;
    }

    @Pointcut("execution(* at.willhaben.examples.statsd.rest.RandomController.*(..))")

benhubert

example.app.service.random:1|c

benhubert

statsd.incrementCounter("service.random");

benhubert

@Configuration
public class MetricsConfig {
   @Bean
   public StatsDClient statsDClient(
           @Value("${metrics.statsd.host:localhost}") String host,
           @Value("${metrics.statsd.port:8125}") int port,
           @Value("${metrics.prefix:example.app}") String prefix
   ) {
       return new NonBlockingStatsDClient(prefix, host, port);
   }

benhubert

<dependency>
    <groupid>com.timgroup</groupid>
    <artifactid>java-statsd-client</artifactid>
    <version>3.0.1</version>
</dependency>

benhubert

import java.io.*;
import java.net.*;

/**
 * Simple UDP server that listens for packets on port 8125 and
 * prints them. Intended for testing a StatsD client.
 */
public class StatsdLogger
{
	public static void main(String args[]) throws Exception {