Skip to content
Browse files

making the project lein

  • Loading branch information...
1 parent 4f9d14e commit a72726d4cffb628b6beee8c2145ae95a1104b127 @amitrathore committed
View
8 .gitignore
@@ -4,4 +4,10 @@
.project
config/config.clj
scripts/furtive
-logs/*
+logs/*
+pom.xml
+lib/
+lib/*
+classes/
+classes/*
+swarmiji.jar
1 lib/clojure/clj-record
@@ -1 +0,0 @@
-Subproject commit c8d124847eb11f0b69b13eb1873dcfef3931ebd6
1 lib/clojure/clj-utils
@@ -1 +0,0 @@
-Subproject commit c5e4efd973931462bc500adb3d343eef91fafcd7
1 lib/clojure/postal
@@ -1 +0,0 @@
-Subproject commit ee9c7af364633d6072f88904c2b0dfffec9cb10c
View
BIN lib/java/clojure-contrib.jar
Binary file not shown.
View
BIN lib/java/clojure-json.jar
Binary file not shown.
View
BIN lib/java/clojure.jar
Binary file not shown.
View
BIN lib/java/commons-io-1.4.jar
Binary file not shown.
View
BIN lib/java/grizzly-framework-1.9.10.jar
Binary file not shown.
View
BIN lib/java/grizzly-http-1.9.10.jar
Binary file not shown.
View
BIN lib/java/grizzly-utils-1.9.10.jar
Binary file not shown.
View
BIN lib/java/mail.jar
Binary file not shown.
View
BIN lib/java/mysql-connector-java-5.1.7-bin.jar
Binary file not shown.
View
BIN lib/java/rabbitmq-client.jar
Binary file not shown.
View
BIN lib/java/swarmiji-java.jar
Binary file not shown.
View
15 project.clj
@@ -0,0 +1,15 @@
+(defproject swarmiji "0.3.0"
+ :description "A distributed computing framework to help write and run Clojure code in parallel, across cores and processors"
+ :url "http://github.com/amitrathore/swarmiji"
+ :dependencies [[org.clojure/clojure "1.1.0"]
+ [org.clojure/clojure-contrib "1.1.0"]
+ [org.danlarkin/clojure-json "1.1"]
+ [org.clojars.kjw/commons-io "1.4"]
+ [mysql/mysql-connector-java "5.1.6"]
+ [rabbitmq-client "1.7.0"]
+ [org.clojars.sethtrain/postal "0.2.0"]
+ [clj-utils "0.1.0"]
+ [org.clojars.macourtney/clj-record "1.0.1"]
+ [org.runa.swarmiji/swarmiji-java "0.1"]]
+ :dev-dependencies [[swank-clojure "1.2.1"]])
+
View
7 src/org/runa/swarmiji/monitor/recorder.clj
@@ -1,6 +1,7 @@
(ns org.runa.swarmiji.monitor.recorder
(:use [org.runa.swarmiji.mpi.transport])
(:use [org.runa.swarmiji.sevak.bindings])
+ (:use [org.rathore.amit.utils.rabbitmq])
(:use [org.runa.swarmiji.config.system-config])
(:use [org.rathore.amit.utils.config])
(:use [org.rathore.amit.utils.logger])
@@ -12,14 +13,14 @@
(str (.toString (Date. time-in-millis)) " " (.toString (Time. time-in-millis))))
(defn persist-message [control-message-str]
- (let [control-message (read-clojure-str control-message-str)
+ (let [control-message (read-string control-message-str)
_ (log-message "control-message:" control-message)
now (timestamp-for-sql (System/currentTimeMillis))
with-timestamps (merge {:created_at now :updated_at now} control-message)]
(control-message/insert with-timestamps)))
(defn start []
- (binding-for-swarmiji [*rathore-utils-config* (config-for-rathore-utils "recorder")]
+ (binding-for-swarmiji [*clj-utils-config* (config-for-rathore-utils "recorder")]
(log-message "Swarmiji: Starting Control-Message-Recorder...")
(log-message "Listening on:" (queue-diagnostics-q-name))
- (start-handler-on-queue (queue-diagnostics-q-name) persist-message)))
+ (start-queue-message-handler (queue-diagnostics-q-name) persist-message)))

0 comments on commit a72726d

Please sign in to comment.
Something went wrong with that request. Please try again.