wip

1 files changed, 12 insertions, 0 deletions

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);
+    }
+}