quickstart.clj

(ns lotuc.examples.akka-clojure.quickstart
  (:require
   [lotuc.akka-clojure :as a]
   [lotuc.akka.actor.typed.actor-system :as actor-system]))

(set! *warn-on-reflection* true)

;;; https://developer.lightbend.com/guides/akka-quickstart-java/

(defn greeter-behavior []
  (a/receive-message
   (fn [{:keys [whom reply-to]}]
     (when whom
       (a/info "Hello {}!" whom)
       (a/! reply-to {:whom whom :reply-to (a/self)}))
     :same)))

(defn greeter-bot-behavior [max]
  (let [greeter-counter (atom 0)]
    (a/receive-message
     (fn [{:keys [whom reply-to]}]
       (when whom
         (swap! greeter-counter inc)
         (a/info "Greeting {} for {}" @greeter-counter whom)
         (if (= @greeter-counter max)
           :stopped
           (do (a/! reply-to {:whom whom :reply-to (a/self)})
               :same)))))))

(defn greeter-main []
  (a/setup*
   (fn [_ignored-ctx]
     (let [greeter (a/spawn (greeter-behavior) "greeter")]
       (a/receive-message
        (fn [{:keys [whom] :as m}]
          (when whom
            (let [bot (a/spawn (greeter-bot-behavior 3) whom)]
              (a/! greeter {:whom whom :reply-to bot})))
          :same))))))

;;; simplify the above pattern with setup macro
(a/setup greeter-main-1 []
  (let [greeter (a/spawn (greeter-behavior) "greeter")]
    (a/receive-message
     (fn [{:keys [whom] :as m}]
       (when whom
         (let [bot (a/spawn (greeter-bot-behavior 3) whom)]
           (a/! greeter {:whom whom :reply-to bot})))
       :same))))

(comment
  (def s (actor-system/create-system (greeter-main) "helloakka"))
  (def s (actor-system/create-system (greeter-main-1) "helloakka"))
  (.terminate s)
  (a/tell s {:whom "42"}))