From 72b7d6b5ac0e3e4804886382bcada61e7469e9d0 Mon Sep 17 00:00:00 2001
From: Helius <wangdoubleone@gmail.com>
Date: Thu, 03 Jun 2021 14:59:59 +0800
Subject: [PATCH] modify
---
src/main/java/com/xcong/excoin/rabbit/producer/UsdtUpdateProducer.java | 4 ++--
src/main/java/com/xcong/excoin/configurations/ScheduleConfig.java | 18 ++++++++++++++++++
src/test/java/com/xcong/excoin/XchTest.java | 9 +++++++++
src/main/resources/application.yml | 6 +++---
4 files changed, 32 insertions(+), 5 deletions(-)
diff --git a/src/main/java/com/xcong/excoin/configurations/ScheduleConfig.java b/src/main/java/com/xcong/excoin/configurations/ScheduleConfig.java
new file mode 100644
index 0000000..fc22982
--- /dev/null
+++ b/src/main/java/com/xcong/excoin/configurations/ScheduleConfig.java
@@ -0,0 +1,18 @@
+package com.xcong.excoin.configurations;
+
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.annotation.SchedulingConfigurer;
+import org.springframework.scheduling.config.ScheduledTaskRegistrar;
+
+import java.util.concurrent.Executors;
+
+@Configuration
+public class ScheduleConfig implements SchedulingConfigurer {
+
+ @Override
+ public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
+ taskRegistrar.setScheduler(Executors.newScheduledThreadPool(50));
+ }
+}
diff --git a/src/main/java/com/xcong/excoin/rabbit/producer/UsdtUpdateProducer.java b/src/main/java/com/xcong/excoin/rabbit/producer/UsdtUpdateProducer.java
index c89f4c9..91945b0 100644
--- a/src/main/java/com/xcong/excoin/rabbit/producer/UsdtUpdateProducer.java
+++ b/src/main/java/com/xcong/excoin/rabbit/producer/UsdtUpdateProducer.java
@@ -26,12 +26,12 @@
public void sendMsg(String content) {
CorrelationData correlationData = new CorrelationData(IdUtil.simpleUUID());
- rabbitTemplate.convertAndSend(RabbitMqConfig.EXCHANGE_USDT_UPDATE, RabbitMqConfig.ROUTING_KEY_USDT_UPDATE, content, correlationData);
+ rabbitTemplate.convertAndSend(RabbitMqConfig.EXCHANGE_XCH, RabbitMqConfig.ROUTING_KEY_USDT_UPDATE, content, correlationData);
}
public void sendAddressMsg(String content) {
CorrelationData correlationData = new CorrelationData(IdUtil.simpleUUID());
- rabbitTemplate.convertAndSend(RabbitMqConfig.EXCHANGE_USDT_ADDRESS, RabbitMqConfig.ROUTING_KEY_USDT_ADDRESS, content, correlationData);
+ rabbitTemplate.convertAndSend(RabbitMqConfig.EXCHANGE_XCH, RabbitMqConfig.ROUTING_KEY_USDT_ADDRESS, content, correlationData);
}
diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml
index 8a3fd03..2e98caf 100644
--- a/src/main/resources/application.yml
+++ b/src/main/resources/application.yml
@@ -7,9 +7,9 @@
profiles:
active: dev
datasource:
-# url: jdbc:mysql://rm-bp151tw8er79ig9kb5o.mysql.rds.aliyuncs.com:3306/db_biue?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=GMT%2b8
-# username: ctcoin_data
-# password: ctcoin_123
+# url: jdbc:mysql://124.70.222.34:3306/yunding?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=GMT%2b8
+# username: yunding
+# password: yunding123!@#
url: jdbc:mysql://120.27.238.55:3306/yunding_test?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=GMT%2b8
username: ct_test
password: 123456
diff --git a/src/test/java/com/xcong/excoin/XchTest.java b/src/test/java/com/xcong/excoin/XchTest.java
index 50684cf..ca9f9e9 100644
--- a/src/test/java/com/xcong/excoin/XchTest.java
+++ b/src/test/java/com/xcong/excoin/XchTest.java
@@ -7,6 +7,7 @@
import cn.hutool.core.util.ObjectUtil;
import cn.hutool.http.HttpRequest;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.xcong.excoin.modules.blackchain.service.TrxUsdtUpdateService;
import com.xcong.excoin.modules.coin.parameter.dto.CoinInListDto;
import com.xcong.excoin.modules.coin.service.CoinService;
import com.xcong.excoin.modules.yunding.dao.YdOrderDao;
@@ -175,4 +176,12 @@
public void baseDataTest() {
xchBaseDataUpdateJob.baseDataUpdate();
}
+
+ @Autowired
+ private TrxUsdtUpdateService trxUsdtUpdateService;
+
+ @Test
+ public void trxTest() {
+ trxUsdtUpdateService.monitorCoinListener(30747892L);
+ }
}
--
Gitblit v1.9.1