|
Akka/Scala example source code file (HelloKernel.java)
The HelloKernel.java Akka example source codepackage sample.kernel.hello.java; import akka.actor.ActorRef; import akka.actor.UntypedActor; import akka.actor.ActorSystem; import akka.actor.Props; import akka.kernel.Bootable; public class HelloKernel implements Bootable { final ActorSystem system = ActorSystem.create("hellokernel"); public static class HelloActor extends UntypedActor { final ActorRef worldActor = getContext().actorOf( Props.create(WorldActor.class)); public void onReceive(Object message) { if (message == "start") worldActor.tell("Hello", getSelf()); else if (message instanceof String) System.out.println(String.format("Received message '%s'", message)); else unhandled(message); } } public static class WorldActor extends UntypedActor { public void onReceive(Object message) { if (message instanceof String) getSender().tell(((String) message).toUpperCase() + " world!", getSelf()); else unhandled(message); } } public void startup() { system.actorOf(Props.create(HelloActor.class)).tell("start", null); } public void shutdown() { system.shutdown(); } } Other Akka source code examplesHere is a short list of links related to this Akka HelloKernel.java source code file: |
... this post is sponsored by my books ... | |
#1 New Release! |
FP Best Seller |
Copyright 1998-2021 Alvin Alexander, alvinalexander.com
All Rights Reserved.
A percentage of advertising revenue from
pages under the /java/jwarehouse
URI on this website is
paid back to open source projects.