From ccbf823a38bf8c403b5019fb8800123fa5183792 Mon Sep 17 00:00:00 2001
From: Ilya Khaprov <dead.trickster@gmail.com>
Date: Wed, 2 Mar 2016 03:24:16 -0800
Subject: [PATCH] common-lisp: tutorial two code

---
 common-lisp/new-task.lisp | 17 +++++++++++++++++
 common-lisp/worker.lisp   | 28 ++++++++++++++++++++++++++++
 2 files changed, 45 insertions(+)
 create mode 100755 common-lisp/new-task.lisp
 create mode 100755 common-lisp/worker.lisp

diff --git a/common-lisp/new-task.lisp b/common-lisp/new-task.lisp
new file mode 100755
index 0000000..10c66e9
--- /dev/null
+++ b/common-lisp/new-task.lisp
@@ -0,0 +1,17 @@
+#!/bin/sh
+
+sbcl --noinform --noprint $@ <<EOF
+
+(ql:quickload :cl-bunny.examples)
+
+(in-package :cl-bunny.examples)
+
+(with-connection ()
+  (with-channel ()
+    (let ((x (exchange.default))
+          (msg (format nil "~{~a~^ ~}" (cdr sb-ext:*posix-argv*))))
+      (publish x msg :routing-key "task_queue"
+                     :properties '(:persistent t))
+      (format t " [x] Sent '~a'~%" msg))))
+
+EOF
diff --git a/common-lisp/worker.lisp b/common-lisp/worker.lisp
new file mode 100755
index 0000000..09b4362
--- /dev/null
+++ b/common-lisp/worker.lisp
@@ -0,0 +1,28 @@
+#!/bin/sh
+
+sbcl --noinform --noprint <<EOF
+
+(ql:quickload :cl-bunny.examples)
+
+(in-package :cl-bunny.examples)
+
+(with-connection ()
+  (with-channel ()
+    (let ((q (queue.declare :name "task_queue" :durable t)))
+      (format t " [*] Waiting for messages in queue 'task_queue'. To exit press CTRL+C~%")
+      (qos :prefetch-count 1)
+      (handler-case
+          (progn
+            (subscribe q (lambda (message)
+                            (let ((body (message-body-string message)))
+                              (format t " [x] Received '~a'~%" body)
+                              ;; imitate some work
+                              (sleep (count #\. body))
+                              (message.ack message)
+                              (format t " [x] Done~%")))
+                       :type :sync)
+            (consume))
+        (sb-sys:interactive-interrupt ()
+          (sb-ext:exit))))))
+
+EOF