From 849f20bc7696e1739a8ea7ad6424007c0b53ba1b Mon Sep 17 00:00:00 2001
From: Helius <wangdoubleone@gmail.com>
Date: Fri, 05 Jun 2020 19:05:53 +0800
Subject: [PATCH] modify

---
 src/test/java/com/xcong/excoin/RabbitMqTest.java |    9 +++++++++
 src/main/resources/application-test.yml          |    4 ++--
 src/main/resources/application.yml               |    4 ++--
 3 files changed, 13 insertions(+), 4 deletions(-)

diff --git a/src/main/resources/application-test.yml b/src/main/resources/application-test.yml
index 5b5008b..6400960 100644
--- a/src/main/resources/application-test.yml
+++ b/src/main/resources/application-test.yml
@@ -94,9 +94,9 @@
   debug: true
   redis_expire: 3000
   kline-update-job: false
-  newest-price-update-job: true
+  newest-price-update-job: false
   other-job: true
-  rabbit-consumer: true
+  rabbit-consumer: false
 
 aliyun:
   oss:
diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml
index cf1a6f1..b28cd2d 100644
--- a/src/main/resources/application.yml
+++ b/src/main/resources/application.yml
@@ -96,10 +96,10 @@
   # k线更新任务控制
   kline-update-job: false
   #最新价任务控制
-  newest-price-update-job: false
+  newest-price-update-job: true
   #其他任务控制
   other-job: false
-  rabbit-consumer: false
+  rabbit-consumer: true
 
 aliyun:
   oss:
diff --git a/src/test/java/com/xcong/excoin/RabbitMqTest.java b/src/test/java/com/xcong/excoin/RabbitMqTest.java
index 82b668b..0b171e8 100644
--- a/src/test/java/com/xcong/excoin/RabbitMqTest.java
+++ b/src/test/java/com/xcong/excoin/RabbitMqTest.java
@@ -1,5 +1,6 @@
 package com.xcong.excoin;
 
+import com.xcong.excoin.rabbit.pricequeue.WebsocketPriceService;
 import com.xcong.excoin.rabbit.producer.TestProducer;
 import org.junit.jupiter.api.Test;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -16,9 +17,17 @@
 
     @Autowired
     private TestProducer testProducer;
+    @Resource
+    private WebsocketPriceService websocketPriceService;
 
     @Test
     public void sendTestMsg() {
         testProducer.sendTestMsg("this is test msg");
     }
+
+    @Test
+    public void bombTest() {
+
+        websocketPriceService.comparePriceDesc("BTC/USDT", "9726.8");
+    }
 }

--
Gitblit v1.9.1