From 6aa023e14ff225a43700cc2e8700131dd9bda5ef Mon Sep 17 00:00:00 2001
From: Ilya Khaprov <dead.trickster@gmail.com>
Date: Wed, 2 Mar 2016 04:32:01 -0800
Subject: [PATCH] common-lisp: tutorial three code

---
 common-lisp/emit-log.lisp     | 16 ++++++++++++++++
 common-lisp/receive-logs.lisp | 23 +++++++++++++++++++++++
 2 files changed, 39 insertions(+)
 create mode 100755 common-lisp/emit-log.lisp
 create mode 100755 common-lisp/receive-logs.lisp

diff --git a/common-lisp/emit-log.lisp b/common-lisp/emit-log.lisp
new file mode 100755
index 00000000..42945af2
--- /dev/null
+++ b/common-lisp/emit-log.lisp
@@ -0,0 +1,16 @@
+#!/bin/sh
+
+sbcl --noinform --noprint $@ <<EOF
+
+(ql:quickload :cl-bunny.examples)
+
+(in-package :cl-bunny.examples)
+
+(with-connection ("amqp://")
+  (with-channel ()
+    (let ((msg (format nil "~{~a~^ ~}" (cdr sb-ext:*posix-argv*)))
+          (x (exchange.fanout "logs")))
+      (publish x msg)
+      (format t " [x] Sent '~a'~%" msg))))
+
+EOF
diff --git a/common-lisp/receive-logs.lisp b/common-lisp/receive-logs.lisp
new file mode 100755
index 00000000..531cdb88
--- /dev/null
+++ b/common-lisp/receive-logs.lisp
@@ -0,0 +1,23 @@
+#!/bin/sh
+
+sbcl --noinform --noprint <<EOF
+
+(ql:quickload :cl-bunny.examples)
+
+(in-package :cl-bunny.examples)
+
+(with-connection ("amqp://")
+  (with-channel ()
+    (let ((q (queue.declare-temp)))
+      (queue.bind q "logs")
+      (format t " [*] Waiting for logs. To exit press CTRL+C~%")
+      (handler-case
+          (progn
+            (subscribe q (lambda (message)
+                            (format t " [x] #~a~%" (message-body-string message)))
+                       :type :sync)
+            (consume))
+        (sb-sys:interactive-interrupt ()
+          (sb-ext:exit))))))
+
+EOF