commit for sendorder/ cancel_order

Cargo.toml

@@ -17,14 +17,11 @@ license = "MIT"
 [dependencies]
 mongodb = "0.3.11" # mongodb
 amiquip = "0.3"
-futures = "^0.1"
-log = "^0.4"
 chrono = { version = "0.4", features = ["serde"] } # datetime
-env_logger = "^0.7" 
+# env_logger = "^0.7"
 serde_json = "1.0"
 serde_derive = "1.0"
 serde = { version = "1.0", features = ["derive"] } # 序列化
-rayon = "1.1" # 多线程
 ndarray = "0.13.0" # ndarray
 wsq = '0.9.1'
 crossbeam = "0.7"

src/main.rs

@@ -32,7 +32,7 @@ fn main() {
 
  thread::spawn(move || {
  let mut client = qaeventmq::QAEventMQ{
- amqp: "amqp:https://admin:admin@192.168.2.118:5672/".to_string(),
+ amqp: "amqp:https://admin:admin@127.0.0.1:5672/".to_string(),
  exchange: "QAORDER_ROUTER".to_string(),
  model: "direct".to_string(),
  routing_key: user_name.clone(),
@@ -41,13 +41,14 @@ fn main() {
  qaeventmq::QAEventMQ::consume(client, s1).unwrap();
  });
  }
- let user_name = "000002".to_string();
+ let user_name = "133495".to_string();
+ let password = "QCHL1234".to_string();
 
  let mut ws = WebSocket::new(move |out| {
  qawebsocket::QAtradeR{
  user_name: user_name.clone(),
- password: user_name.clone(),
- broker:"QUANTAXIS".to_string(),
+ password: password.clone(),
+ broker:"simnow".to_string(),
  out:out,
 
  }}