diff --git a/common-lisp/emit-log-direct.lisp b/common-lisp/emit-log-direct.lisp
new file mode 100755
index 0000000..8dc55c4
--- /dev/null
+++ b/common-lisp/emit-log-direct.lisp
@@ -0,0 +1,18 @@
+#!/bin/sh
+
+sbcl --noinform --noprint $@ <<EOF
+
+(ql:quickload :cl-bunny.examples)
+
+(in-package :cl-bunny.examples)
+
+(with-connection ()
+  (with-channel ()
+    (let* ((args (rest sb-ext:*posix-argv*))
+           (severity (or (first args) "info"))
+           (msg (format nil "~{~a~^ ~}" (rest args)))
+           (x (exchange.direct "direct_logs")))
+      (publish x msg :routing-key severity)
+      (format t " [x] Sent '~a'~%" msg))))
+
+EOF
diff --git a/common-lisp/receive-logs-direct.lisp b/common-lisp/receive-logs-direct.lisp
new file mode 100755
index 0000000..4dbb6e1
--- /dev/null
+++ b/common-lisp/receive-logs-direct.lisp
@@ -0,0 +1,27 @@
+#!/bin/sh
+
+sbcl --noinform --noprint $@ <<EOF
+
+(ql:quickload :cl-bunny.examples)
+
+(in-package :cl-bunny.examples)
+
+(if-let ((args (rest sb-ext:*posix-argv*)))
+  (with-connection ()
+    (with-channel ()
+      (let ((q (queue.declare :auto-delete t))
+            (x (exchange.direct "direct_logs")))
+        (loop for severity in args do
+                 (queue.bind q x :routing-key severity))
+        (format t " [*] Waiting for logs. To exit press CTRL+C~%")
+        (handler-case
+            (progn
+              (subscribe q (lambda (message)
+                              (format t " [x] #~a:~a~%" (message-routing-key message) (message-body-string message)))
+                         :type :sync)
+              (consume))
+          (sb-sys:interactive-interrupt ()
+            (sb-ext:exit))))))
+  (format t "Usage: $0 [info] [warning] [error]~%"))
+
+EOF