anchor.diff:  (alexandria:define-constant +crlf+ (format nil "~c~c" #\Return #\Newline) :test 'equal)
   (alexandria:define-constant +nl+ (format nil "~c" #\Newline) :test 'equal)
   (alexandria:define-constant +all-services+
  -    '(:content-p t :user-state-p t :user-notifications-p t :unread-p t :channel-updates-p t)
  +    '(:content-p t :user-state-p t :user-notifications-p t :unread-p t :channel-updates-p t :slashcommand-error-p t)
     :test 'equal)
   
   (defvar *notifications-timer-queue* (potato.common.timer:make-timer-queue :name "RabbitMQ Notifications timer queue"))
  
positive.code:     (let ((exchange (cl-rabbit:envelope/exchange msg)))
        (log:trace "Processing message on exchange: ~s" exchange)
        (string-case:string-case (exchange :default nil)
          (#.*channel-content-exchange-name*     (process-channel-message msg msg-formatter))
          (#.*state-server-sender-exchange-name* (process-state-server-message msg))
          (#.*user-notifications-exchange-name*  (process-user-notification-message msg))
          (#.*unread-state-exchange-name*        (process-unread-message msg))
          (#.*channel-exchange-name*             (potato.rabbitmq-channels:process-channel-update msg))))))
  
  ;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;
  ;;; Web handlers -- eventsource
  
negative.code: messages. Each element is a list of two values: the processed message
  and the delivery tag."
    (let ((existing-messages (loop
                               repeat num-messages
                               for msg = (consume-message-handle-timeout conn 1/1000)
                               while msg
                               for json = (process-message msg subscription-consumer-tag msg-formatter)
                               if json
                                 collect (list json (cl-rabbit:envelope/delivery-tag msg))
                               else do (cl-rabbit:basic-ack conn 1 (cl-rabbit:envelope/delivery-tag msg)))))
      (or existing-messages
          (alexandria:when-let ((msg (consume-message-handle-timeout conn timeout)))
            (alexandria:when-let ((json (process-message msg subscription-consumer-tag msg-formatter)))
  