 
 
 
-      (log/info (format "Started subscription on queue '%s' with tag '%s'"
-                        (:queue-name queue-config)
-                        consumer-tag))
+      (log/infof "Started subscription on queue '%s' with tag '%s'"
+                 (:queue-name queue-config)
+                 consumer-tag)
       (assoc this
              :rmq-chan rmq-chan
              :rmq-consumer rmq-consumer

    [rmq-connection rmq-chan queue-config buffer-size]
  component/Lifecycle
  (start [this]
    (log/info (format "Starting subscription on queue '%s'" (:queue-name queue-config)))
    (let [rmq-chan (or rmq-chan (make-channel (:conn rmq-connection) queue-config))
          new-messages (a/chan)
          pending-messages (a/chan buffer-size)

    ;; library has turned off the workers depending on this subscription.

    ;; Shut down the RMQ consumer, so we don't get any more messages delivered
    (log/infof "Shutting down subscription '%s' on queue '%s'"
               consumer-tag
               (:queue-name queue-config))
    (rmq.basic/cancel rmq-chan consumer-tag)

    ;; Wait until the server acknowledges the cancellation of our subscription
