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


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