diff options
| -rw-r--r-- | src/weepinbell/processor.clj | 13 |
1 files changed, 6 insertions, 7 deletions
diff --git a/src/weepinbell/processor.clj b/src/weepinbell/processor.clj index 95476b3..42e973f 100644 --- a/src/weepinbell/processor.clj +++ b/src/weepinbell/processor.clj @@ -48,13 +48,12 @@ [wmc] (println "Processor started.") (go-loop [] - (let [wm (<! wmc)] + (when-let [wm (<! wmc)] (println "Webmention found in queue.") - (if wm - (let [{:keys [s t]} wm] - (if (verify-mention s t) - (process-verified-webmention s t) - (println "Invalid mention"))) - (println "Idling"))) + (let [{:keys [s t]} wm] + (if (verify-mention s t) + (process-verified-webmention s t) + (println "Invalid mention"))) + (println "Idling")) (recur))) |