                                     ))]
     (.close browser)
     (.close s)
+    (.close c)
     converted-messages))
 
 (defn browse-queue-messages [connection-info queue-info]

                                   )
    :else (throw (IOException. (str "Not supported message class!" (.getClass msg))))))

(defn get-type[v]
  (if (nil? v)
    :string
    (condp instance? v
        String :string
        Long :long
        Integer :int
        Short :short
        Double :double
        Float :float
        Boolean :boolean
        :string
      )))

(defn convert-message [^Message msg]

           (java.io IOException))
  (:use ru.jms.testingtool.mq-init))

(defn ^Connection get-connection [connection-info]
  (try
    (let [^QueueConnectionFactory qcf (create-qcf connection-info)
          ^Connection q (if (clojure.string/blank? (:user connection-info))
                          (.createConnection qcf)
                          (.createConnection qcf (:user connection-info) (:password connection-info)))
          _ (.start q)]
      q)
    (catch Exception e
      (throw (IOException. e)))))

(defn ^Session get-session
  ([^Connection c ack-mode]
   (try
       (.createSession c false ack-mode)
     (catch Exception e
       (throw (IOException. e)))))
  ([^Connection c ]
   (get-session c Session/AUTO_ACKNOWLEDGE)))


(defn ^Queue get-queue [^Session s queue-info]
