message-wants-reply
message-ref
- send-message send-message-wait
- reply-message reply-message-wait
-
<- <-wait <-reply <-reply-wait
ez-run-hive
args)))))
-(define (send-message from-actor to-id action . message-body-args)
+;;; See: https://web.archive.org/web/20081223021934/http://mumble.net/~jar/articles/oo-moon-weinreb.html
+;;; (also worth seeing: http://mumble.net/~jar/articles/oo.html )
+
+(define (<- from-actor to-id action . message-body-args)
"Send a message from an actor to another actor"
(let* ((hive (actor-hive from-actor))
(message (make-message (hive-gen-message-id hive) to-id
(kwarg-list-to-alist message-body-args))))
(8sync (hive-process-message hive message))))
-(define (send-message-wait from-actor to-id action . message-body-args)
+(define (<-wait from-actor to-id action . message-body-args)
"Send a message from an actor to another, but wait until we get a response"
(let* ((hive (actor-hive from-actor))
(abort-to (hive-prompt (actor-hive from-actor)))
;; not have an exception thrown and instead just have a message with
;; the appropriate '*error* message returned.
-(define (reply-message from-actor original-message
- . message-body-args)
+(define (<-reply from-actor original-message . message-body-args)
"Reply to a message"
(set-message-replied! original-message #t)
(let* ((hive (actor-hive from-actor))
#:in-reply-to (message-id original-message))))
(8sync (hive-process-message hive new-message))))
-(define (reply-message-wait from-actor original-message
- . message-body-args)
+(define (<-reply-wait from-actor original-message . message-body-args)
"Reply to a messsage, but wait until we get a response"
(set-message-replied! original-message #t)
(let* ((hive (actor-hive from-actor))
(abort-to-prompt abort-to from-actor new-message)))
-;;; Aliases!
-;;; See: http://mumble.net/~jar/articles/oo-moon-weinreb.html
-;;; (also worth seeing: http://mumble.net/~jar/articles/oo.html )
-
-(define <- send-message)
-(define <-wait send-message-wait)
-(define <-reply reply-message)
-(define <-reply-wait reply-message-wait)
-
-
\f
;;; Main actor implementation
;;; =========================
;; Possibly autoreply
(if (message-needs-reply message)
;; @@: Should we give *autoreply* as the action instead of *reply*?
- (reply-message actor message
- #:*auto-reply* #t)))
+ (<-reply actor message #:*auto-reply* #t)))
(define (resolve-actor-to)
"Get the actor the message was aimed at"
(define (bootstrap-message hive to-id action . message-body-args)
(wrap
- (apply send-message hive to-id action message-body-args)))
+ (apply <- hive to-id action message-body-args)))
\f
(define-simple-actor <antsy-caller>
((pester-rep actor message)
(~display "customer> I'm calling customer service about this!\n")
- (let ((reply (send-message-wait actor (message-ref message 'who-to-call)
- 'field-call)))
+ (let ((reply (<-wait actor (message-ref message 'who-to-call)
+ 'field-call)))
(if (message-ref reply '*auto-reply* #f)
(~display "customer> Whaaaaat? I can't believe I got voice mail!\n")
(begin
(~format "*customer hears*: ~a\n" (message-ref reply 'msg))
- (let ((reply (reply-message-wait
+ (let ((reply (<-reply-wait
actor reply
#:msg "Yes, it didn't work, I'm VERY ANGRY!")))
(if (message-ref reply '*auto-reply* #f)
((field-call actor message)
(~display "good-rep> Hm, another call from a customer...\n")
(let ((reply
- (reply-message-wait
+ (<-reply-wait
actor message
#:msg "Have you tried turning it off and on?")))
(~format "*rep hears*: ~a\n" (message-ref reply 'msg))