aboutsummaryrefslogtreecommitdiff
path: root/kamon-examples/kamon-annotation-example/java/src/main/java
diff options
context:
space:
mode:
Diffstat (limited to 'kamon-examples/kamon-annotation-example/java/src/main/java')
-rw-r--r--kamon-examples/kamon-annotation-example/java/src/main/java/kamon/KamonSpringApplication.java12
-rw-r--r--kamon-examples/kamon-annotation-example/java/src/main/java/kamon/akka/pingpong/PingPong.java22
-rw-r--r--kamon-examples/kamon-annotation-example/java/src/main/java/kamon/akka/pingpong/Pinger.java12
-rw-r--r--kamon-examples/kamon-annotation-example/java/src/main/java/kamon/akka/pingpong/Ponger.java12
-rw-r--r--kamon-examples/kamon-annotation-example/java/src/main/java/kamon/annotation/KamonController.java17
5 files changed, 75 insertions, 0 deletions
diff --git a/kamon-examples/kamon-annotation-example/java/src/main/java/kamon/KamonSpringApplication.java b/kamon-examples/kamon-annotation-example/java/src/main/java/kamon/KamonSpringApplication.java
new file mode 100644
index 00000000..8103306b
--- /dev/null
+++ b/kamon-examples/kamon-annotation-example/java/src/main/java/kamon/KamonSpringApplication.java
@@ -0,0 +1,12 @@
+package kamon;
+
+import kamon.akka.pingpong.PingPong;
+import kamon.annotation.KamonController;
+import org.springframework.boot.SpringApplication;
+
+public class KamonSpringApplication {
+ public static void main(String... args) {
+ Kamon.start();
+ SpringApplication.run(new Object[] {KamonController.class, PingPong.class}, args);
+ }
+}
diff --git a/kamon-examples/kamon-annotation-example/java/src/main/java/kamon/akka/pingpong/PingPong.java b/kamon-examples/kamon-annotation-example/java/src/main/java/kamon/akka/pingpong/PingPong.java
new file mode 100644
index 00000000..8ef2f621
--- /dev/null
+++ b/kamon-examples/kamon-annotation-example/java/src/main/java/kamon/akka/pingpong/PingPong.java
@@ -0,0 +1,22 @@
+package kamon.akka.pingpong;
+
+import akka.actor.ActorRef;
+import akka.actor.ActorSystem;
+import akka.actor.Props;
+import org.springframework.stereotype.Component;
+
+import javax.annotation.PostConstruct;
+
+@Component
+public class PingPong {
+
+ @PostConstruct
+ public void initialize() {
+ final ActorSystem system = ActorSystem.create("kamon-spring-boot-actor-system");
+
+ final ActorRef pinger = system.actorOf(Props.create(Pinger.class), "pinger");
+ final ActorRef ponger = system.actorOf(Props.create(Ponger.class), "ponger");
+
+ pinger.tell(new Ponger.PongMessage(), ponger);
+ }
+}
diff --git a/kamon-examples/kamon-annotation-example/java/src/main/java/kamon/akka/pingpong/Pinger.java b/kamon-examples/kamon-annotation-example/java/src/main/java/kamon/akka/pingpong/Pinger.java
new file mode 100644
index 00000000..dcab35b6
--- /dev/null
+++ b/kamon-examples/kamon-annotation-example/java/src/main/java/kamon/akka/pingpong/Pinger.java
@@ -0,0 +1,12 @@
+package kamon.akka.pingpong;
+
+import akka.actor.UntypedActor;
+
+class Pinger extends UntypedActor {
+ static final class PingMessage {}
+
+ public void onReceive(Object message) throws Exception {
+ if (message instanceof Ponger.PongMessage) getSender().tell(new PingMessage(), getSelf());
+ else unhandled(message);
+ }
+}
diff --git a/kamon-examples/kamon-annotation-example/java/src/main/java/kamon/akka/pingpong/Ponger.java b/kamon-examples/kamon-annotation-example/java/src/main/java/kamon/akka/pingpong/Ponger.java
new file mode 100644
index 00000000..b4e8ecfa
--- /dev/null
+++ b/kamon-examples/kamon-annotation-example/java/src/main/java/kamon/akka/pingpong/Ponger.java
@@ -0,0 +1,12 @@
+package kamon.akka.pingpong;
+
+import akka.actor.UntypedActor;
+
+class Ponger extends UntypedActor {
+ static final class PongMessage {}
+
+ public void onReceive(Object message) throws Exception {
+ if (message instanceof Pinger.PingMessage) getSender().tell(new PongMessage(), getSelf());
+ else unhandled(message);
+ }
+}
diff --git a/kamon-examples/kamon-annotation-example/java/src/main/java/kamon/annotation/KamonController.java b/kamon-examples/kamon-annotation-example/java/src/main/java/kamon/annotation/KamonController.java
new file mode 100644
index 00000000..27eeda53
--- /dev/null
+++ b/kamon-examples/kamon-annotation-example/java/src/main/java/kamon/annotation/KamonController.java
@@ -0,0 +1,17 @@
+package kamon.annotation;
+
+import org.springframework.boot.autoconfigure.*;
+import org.springframework.stereotype.*;
+import org.springframework.web.bind.annotation.*;
+
+@Controller
+@EnableAutoConfiguration
+@RequestMapping("/kamon")
+@EnableKamon
+public class KamonController {
+
+ @RequestMapping("/counter")
+ @ResponseBody
+ @Count(name = "awesomeCounter")
+ public String counter() { return "count!!!"; }
+}