File tree Expand file tree Collapse file tree 5 files changed +5
-37
lines changed Expand file tree Collapse file tree 5 files changed +5
-37
lines changed Original file line number Diff line number Diff line change 99 :type " direct"
1010 :exchange " sorting-room"
1111 :queue " po-box"
12+ :durable true
1213 :routing-key " tata" })
1314
1415(defonce connection (rabbitmq/connect conn-map))
Load Diff This file was deleted.
Original file line number Diff line number Diff line change 22exec java -cp " lib/*:$PWD/*" clojure.main " $0" -- " $@"
33]
44
5-
65(ns rabbitmq-publisher
76 (:require [org.clojars.rabbitmq :as rabbitmq]))
87
@@ -14,6 +13,7 @@ exec java -cp "lib/*:$PWD/*" clojure.main "$0" -- "$@"
1413 :type " direct"
1514 :exchange " sorting-room"
1615 :queue " po-box"
16+ :durable true
1717 :routing-key " tata" })
1818
1919(println conn-map)
@@ -24,6 +24,7 @@ exec java -cp "lib/*:$PWD/*" clojure.main "$0" -- "$@"
2424
2525(def c (ref 0 ))
2626
27+
2728(while true
2829 (dosync (alter c inc))
2930 (println " cycle: " @c)
Original file line number Diff line number Diff line change @@ -14,6 +14,7 @@ exec java -cp "lib/*:$PWD/*" clojure.main "$0" -- "$@"
1414 :type " direct"
1515 :exchange " sorting-room"
1616 :queue " po-box"
17+ :durable true
1718 :routing-key " tata" })
1819
1920(println " Connecting ..." )
Original file line number Diff line number Diff line change 55 [commons-io " 1.2" ]
66 [commons-cli " 1.1" ]
77 [rabbitmq-client " 1.7.0" ]]
8- ; :dev-dependencies [[leiningen/lein-swank "1.0.0-SNAPSHOT"]]
8+ ; :dev-dependencies [[leiningen/lein-swank "1.0.0-SNAPSHOT"]]
99 )
You can’t perform that action at this time.
0 commit comments