cleaned up streaming

Author: tuddman

project.clj

@@ -1,8 +1,10 @@
-(defproject clj-dde "0.1.0-SNAPSHOT"
-  :description "clj-dde: for when you need to connect to a DDE (dynamic data exchange) source"
-  :url "http://github.com/tuddman/clj-dde"
-  :license {:name "Eclipse Public License"
-            :url "http://www.eclipse.org/legal/epl-v10.html"}
-  :dependencies [[org.clojure/clojure "1.5.1"]]
-  :source-paths ["src/clojure"]
-  :java-source-paths ["src/java"])
+(defproject clj-dde "0.1.0-SNAPSHOT"
+  :description "clj-dde: for when you need to connect to a DDE (dynamic data exchange) source"
+  :url "http://github.com/tuddman/clj-dde"
+  :license {:name "Eclipse Public License"
+            :url "http://www.eclipse.org/legal/epl-v10.html"}
+  :dependencies [[org.clojure/clojure "1.5.1"]]
+  :source-paths ["src/clojure"]
+  :java-source-paths ["src/java"]
+  :main src/clojure/core)
+

src/clojure/core.clj

@@ -1,53 +1,108 @@
 (ns clj-dde.core
+  (:gen-class)
   [:import
-        [com.pretty_tools.dde.client.DDEClientConversation]
-        [com.pretty_tools.dde.client.DDEClientEventListener]
+        [com.pretty_tools.dde.client DDEClientConversation]
+        [com.pretty_tools.dde.client DDEClientEventListener]
         [com.pretty_tools.dde ClipboardFormat]
         [com.pretty_tools.dde DDEException]
-        [com.pretty_tools.dde DDEMLException]
-        [java.util Date]])
+        [com.pretty_tools.dde DDEMLException]])
 
 (System/getProperty "java.library.path")
 
-(Date.)
-
 
 ;; instantiate a DDEClientConversation
 
-;; ** DDEClientConversation member functions:
+;; MetaTrader --
+
+(def mt4-conv-bid (DDEClientConversation.))
+(def mt4-conv-ask (DDEClientConversation.))
+
+(.setTimeout mt4-conv-bid 3000)
+(.setTimeout mt4-conv-ask 3000)
+
+(.connect mt4-conv-bid "MT4" "BID")
+(.connect mt4-conv-ask "MT4" "ASK")
+
+(.startAdvice mt4-conv-bid "EURUSD")
+(.startAdvice mt4-conv-ask "EURUSD")
+
+; (.request mt4-conv-bid "EURUSD")
+; (.request mt4-conv-ask "EURUSD")
+
+
+(defn get-eu-bid
+  []
+ (Float. (.request mt4-conv-bid "EURUSD")))
+
+
+(defn get-bid
+  [ccy]
+  (Float. (.request mt4-conv-bid #(clojure.string/upper-case ccy))))
+
+
+(def eubid  (get-eu-bid))
+
+(def eubid-now (atom 1.0))
+
+eubid
+
+@eubid-now
+
+(compare-and-set! eubid-now @eubid-now (get-eu-bid))
 
-; (.connect conversation "excel" "sheet1")
-; (.request conversation "R1C1")
-; (.poke conversation "R1C1", "new val")
+@eubid-now
+
+
+(defn stream-pair [ccy]
+  ())
+
+
+#_(while (not= @eubid-now 1.0 )
+  (do
+    (if-not (= @eubid-now (get-eu-bid) )
+      (do
+      (compare-and-set! eubid-now @eubid-now (get-eu-bid))
+      (println @eubid-now)))))
 
-(def mt4-conv (DDEClientConversation.))
 
-(.connect mt4-conv "MT4" "BID")
 
-(.startAdvice mt4-conv "EURUSD")
 
 ; (.setEventListener mt4-link (DDEClientEventListener))
 
 ;    void onItemChanged(String topic, String item, String data);
 
-(defn ELOnItemChanged
+#_(defn ELOnItemChanged
   []
 (reify DDEClientEventListener
   (onItemChanged [this topic item data]
                (str "onItemChanged: " topic  " , " item  " , " data " )"))))
 
-(defn ELOnDisconnect
+#_(defn ELOnDisconnect
   []
 (reify DDEClientEventListener
   (onDisconnect [this]
                (str "onDisconnect called."))))
 
-(.setEventListener mt4-conv (ELOnItemChanged))
+; (.setEventListener mt4-conv (ELOnItemChanged))
+
+; (ELOnItemChanged)
+
+
+(defn -main
+  [& args]
+  (str "main got called."))
+
+
+
+
+
+
+
+
+
 
-(ELOnItemChanged)
 
 
-(str "the" "string" "gets")
 
 
 

src/clojure/sandbox.clj

@@ -20,17 +20,17 @@
 
 (.getTimeout conversation)
 
-(.setTimeout conversation)
+(.setTimeout conversation 2000)
 
 (.getEventListener conversation)
 
 (.setEventListener conversation an-event-listener)
 
-(.checkConversation conversation)
+; (.checkConversation conversation)
 
-(.fireEventOnDisconnect conversation)
+; (.fireEventOnDisconnect conversation)
 
-(.fireEventOnAdvData conversation)
+; (.fireEventOnAdvData conversation)
 
 
 ; #(com.pretty_tools.dde.client.DDEClientConversation. %)
@@ -41,4 +41,15 @@
 
 #_(defn get-a-conversation
   []
-  (DDEClientConversation. com.pretty_tools.dde.client.DDEClientConversation))
+  (DDEClientConversation. com.pretty_tools.dde.client.DDEClientConversation))
+
+;; EXCEL setup --
+; (def excel-conv (DDEClientConversation.))
+; (.connect excel-conv "excel" "sheet1")
+; (.request excel-conv "R1C1")
+; (.startAdvice excel-conv "R1C1")
+; (.poke conversation "R1C1", "new val")
+
+
+
+