       (extensions/create-queue-on-session queue session queue-name))
     (.close session)))
 
-(defmethod extensions/create-queue-on-session HornetQClusteredConnection
+(defmethod extensions/create-queue-on-session HornetQConnection
   [queue session queue-name]
   (try
     (.createQueue session queue-name queue-name true)

    (extensions/commit-tx queue session)
    (extensions/close-resource queue session)))

(defmethod extensions/produce-message HornetQClusteredConnection
  ([queue producer session msg]
     (let [message (.createMessage session true)]
       (.writeBytes (.getBodyBuffer message) msg)

      (doall (map #(.close %) locators))
      (apply + consumer-counts))))

(defmethod extensions/bootstrap-queue HornetQConnection
  [queue task]
  (let [session (extensions/create-tx-session queue)
        producer (extensions/create-producer queue session (:ingress-queues task))]
