add producer

Author: tamizhvendan

clojure/wheel/resources/config.edn

@@ -11,7 +11,8 @@
                        :qmgr     #or [#env "WHEEL_APP_MQ_QMGR" "QM1"]
                        :user-id  #or [#env "WHEEL_APP_MQ_USER_ID" "app"]
                        :password #or [#env "WHEEL_APP_MQ_PASSWORD" "test123"]}}
- :settings {:oms       {:ranging-queue-name "DEV.QUEUE.1"}
+ :settings {:oms       {:ranging-queue-name          "DEV.QUEUE.1"
+                        :order-allocating-queue-name "DEV.QUEUE.2"}
             :channels  {"UA" {:channel-name :tata-cliq
                               :base-url     "http://localhost:3000"
                               :bearer-token "top-secret!"}

clojure/wheel/src/wheel/infra/cron/job/core.clj

@@ -27,7 +27,10 @@
 
 (defn handle [channel-fn ctx]
   (let [{:strs [channel-config cron-job-config]} (qc/from-job-data ctx)]
-    (channel-fn (:channel-id cron-job-config) channel-config)))
+    (try
+      (channel-fn (:channel-id cron-job-config) channel-config)
+      (catch Throwable ex
+        (prn "==>" ex)))))
 
 (defn schedule [scheduler {:keys [channel-id]
                            :as   cron-job-config}]

clojure/wheel/src/wheel/infra/oms.clj

@@ -40,4 +40,15 @@
   :start (let [queue-name (:ranging-queue-name (config/oms-settings))
                listener   (message-listener :ranging :oms/items-ranged)]
            (start-consumer queue-name jms-ranging-session listener))
-  :stop (stop ranging-consumer))
+  :stop (stop ranging-consumer))
+
+(mount/defstate order-allocating-session
+  :start (.createSession ibmmq/jms-conn false Session/AUTO_ACKNOWLEDGE)
+  :stop (stop order-allocating-session))
+
+(mount/defstate order-allocating-producer
+  :start (let [queue-name       (:order-allocating-queue-name (config/oms-settings))
+               ibmmq-queue-name (str "queue:///" queue-name)
+               destination      (.createQueue order-allocating-session ibmmq-queue-name)]
+           (.createProducer order-allocating-session destination))
+  :stop (stop order-allocating-producer))

clojure/wheel/src/wheel/oms/client.clj

@@ -1,7 +1,15 @@
 (ns wheel.oms.client
   (:require [wheel.oms.order :as oms-order]
+            [wheel.infra.oms :as oms-infra]
             [clojure.spec.alpha :as s]))
 
+(defn- send [session producer xml-message]
+  (let [msg (.createTextMessage session)]
+    (.setText msg xml-message)
+    (.send producer msg)))
+
 (defn allocate-order [order]
   {:pre [(s/assert ::oms-order/order order)]}
-  (prn (oms-order/to-xml order)))
+  (send oms-infra/order-allocating-session
+        oms-infra/order-allocating-producer
+        (oms-order/to-xml order)))