aboutsummaryrefslogtreecommitdiff
path: root/kamon-examples/kamon-annotation-example/java/src/main/java/kamon/akka/pingpong/Ponger.java
diff options
context:
space:
mode:
Diffstat (limited to 'kamon-examples/kamon-annotation-example/java/src/main/java/kamon/akka/pingpong/Ponger.java')
-rw-r--r--kamon-examples/kamon-annotation-example/java/src/main/java/kamon/akka/pingpong/Ponger.java12
1 files changed, 12 insertions, 0 deletions
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);
+ }
+}