anchor.diff:  ;;; Handling connection errors
   
   (defmacro reconnect-restart-case ((&key error comment) &body body)
  -  "Signal the condition of type CL-DISQUE-CONNECTION-ERROR denoted by
  +  "Signal the condition of type DISQUE-CONNECTION-ERROR denoted by
   the given ERROR and COMMENT offering a :RECONNECT restart to re-evaluate BODY."
     `(if *pipelined*
          ;; don't intercept connection-errors inside a pipeline -
          ;; it will be done on the highest level of a pipeline to allow
          ;; the whole pipeline (with possible nestsed pipelines) to restart
          (progn ,@body)
  -       (restart-case (error 'cl-disque-connection-error
  +       (restart-case (error 'disque-connection-error
                               :error ,error :message ,comment)
            (:reconnect ()
              :report "Try to reconnect and repeat action."
  
positive.code: 
  (defmacro with-reconnect-restart (&body body)
    "When, during the execution of BODY, an error occurs that breaks
  the connection, a CL-DISQUE-CONNECTION-ERROR is signalled,
  offering a :RECONNECT restart that will re-evaluate body after
  the conenction is re-established."
    (with-gensyms (e)
  
negative.code:                                             auth)
                                        &body body)
    "Execute BODY inside WITH-CONNECTION. But if connection is broken
  due to CL-DISQUE-CONNECTION-
    (a network error or timeout),
  transparently reopen it."
    `(with-connection (:host ,host :port ,port :auth ,auth)
       (handler-bind ((disque-connection-error
                       (lambda (e)
                         (declare (ignore e))
                         (warn "Reconnecting to Disque.")
  