anchor.diff:                                              auth)
                                         &body body)
     "Execute BODY inside WITH-CONNECTION. But if connection is broken
  -due to CL-DISQUE-CONNECTION-ERROR (a network error or timeout),
  +due to CL-DISQUE-CONNECTION-
  +  (a network error or timeout),
   transparently reopen it."
     `(with-connection (:host ,host :port ,port :auth ,auth)
  -     (handler-bind ((cl-disque-connection-error
  +     (handler-bind ((disque-connection-error
                        (lambda (e)
                          (declare (ignore e))
                          (warn "Reconnecting to Disque.")
  
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: ;;; Handling connection errors
  
  (defmacro reconnect-restart-case ((&key error comment) &body body)
    "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 'disque-connection-error
                              :error ,error :message ,comment)
           (:reconnect ()
             :report "Try to reconnect and repeat action."
  