=doc #3689 Make activator template for akka.Main

akka-samples/akka-sample-main-java/src/main/java/sample/hello/Greeter.java

@@ -0,0 +1,23 @@
+/**
+ * Copyright (C) 2009-2013 Typesafe Inc. <http://www.typesafe.com>
+ */
+package sample.hello;
+
+import akka.actor.UntypedActor;
+
+public class Greeter extends UntypedActor {
+
+  public static enum Msg {
+    GREET, DONE;
+  }
+
+  @Override
+  public void onReceive(Object msg) {
+    if (msg == Msg.GREET) {
+      System.out.println("Hello World!");
+      getSender().tell(Msg.DONE, getSelf());
+    } else
+      unhandled(msg);
+  }
+
+}

akka-samples/akka-sample-main-java/src/main/java/sample/hello/HelloWorld.java

@@ -0,0 +1,29 @@
+/**
+ * Copyright (C) 2009-2013 Typesafe Inc. <http://www.typesafe.com>
+ */
+
+package sample.hello;
+
+import akka.actor.Props;
+import akka.actor.UntypedActor;
+import akka.actor.ActorRef;
+
+public class HelloWorld extends UntypedActor {
+
+  @Override
+  public void preStart() {
+    // create the greeter actor
+    final ActorRef greeter = getContext().actorOf(Props.create(Greeter.class), "greeter");
+    // tell it to perform the greeting
+    greeter.tell(Greeter.Msg.GREET, getSelf());
+  }
+
+  @Override
+  public void onReceive(Object msg) {
+    if (msg == Greeter.Msg.DONE) {
+      // when the greeter is done, stop this actor and with it the application
+      getContext().stop(getSelf());
+    } else
+      unhandled(msg);
+  }
+}

akka-samples/akka-sample-main-java/src/main/java/sample/hello/Main.java

@@ -0,0 +1,11 @@
+/**
+ *  Copyright (C) 2009-2013 Typesafe Inc. <http://www.typesafe.com>
+ */
+package sample.hello;
+
+public class Main {
+
+  public static void main(String[] args) {
+    akka.Main.main(new String[] { HelloWorld.class.getName() });
+  }
+}

akka-samples/akka-sample-main-java/src/main/java/sample/hello/Main2.java

@@ -0,0 +1,43 @@
+/**
+ *  Copyright (C) 2009-2013 Typesafe Inc. <http://www.typesafe.com>
+ */
+package sample.hello;
+
+import akka.actor.ActorRef;
+import akka.actor.ActorSystem;
+import akka.actor.Props;
+import akka.actor.Terminated;
+import akka.actor.UntypedActor;
+import akka.event.Logging;
+import akka.event.LoggingAdapter;
+
+public class Main2 {
+
+  public static void main(String[] args) {
+    ActorSystem system = ActorSystem.create("Hello");
+    ActorRef a = system.actorOf(Props.create(HelloWorld.class), "helloWorld");
+    system.actorOf(Props.create(Terminator.class, a), "terminator");
+  }
+
+  public static class Terminator extends UntypedActor {
+
+    private final LoggingAdapter log = Logging.getLogger(getContext().system(), this);
+    private final ActorRef ref;
+
+    public Terminator(ActorRef ref) {
+      this.ref = ref;
+      getContext().watch(ref);
+    }
+
+    @Override
+    public void onReceive(Object msg) {
+      if (msg instanceof Terminated) {
+        log.info("{} has terminated, shutting down system", ref.path());
+        getContext().system().shutdown();
+      } else {
+        unhandled(msg);
+      }
+    }
+
+  }
+}