 	 server-fn (fn [target end-point]
 		       (println "SERVER INSTANCE" target)
 		       (.setMessageListener
-			(.createConsumer session (.createQueue session end-point))
+			(.createConsumer session (.createDestination destination-factory session end-point))
 			(proxy [MessageListener] [] (onMessage [message] (.execute executor-service (proxy [Runnable] [] (run [] (invoke target message session mapper producer))))))))
 
 	 client-fn (fn [#^String end-point]


(defn -client [#^org.dada.core.jms.JMSServiceFactory this #^String end-point]
  (let [[_ client-fn] (.state this)]
    (client-fn)))

(defn -server [#^org.dada.core.jms.JMSServiceFactory this #^Object target #^String end-point]
  (let [[_ _ server-fn] (.state this)]

	     #^Boolean true-async
	     #^Long timeout
	     #^Getter name-getter
	     #^JMSServiceFactory$DestinationFactory destination-factory]

  [ ;; super ctor args
   []
