kamon-examples/kamon-annotation-example/java/src/main/java/kamon/akka/pingpong/Pinger.java


1
2
3
4
5
6
7
8
9
10
11
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);
    }
}