From 2eebadc490b460a3e97666ce33d46397e3fdfdd2 Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Mon, 07 Aug 2023 22:01:32 +0800
Subject: [PATCH] 数据修改
---
src/main/java/cc/mrbird/febs/dapp/contract/andao/AndaoContractMain.java | 10 ++++++++--
1 files changed, 8 insertions(+), 2 deletions(-)
diff --git a/src/main/java/cc/mrbird/febs/dapp/contract/andao/AndaoContractMain.java b/src/main/java/cc/mrbird/febs/dapp/contract/andao/AndaoContractMain.java
index 230a79a..00629f9 100644
--- a/src/main/java/cc/mrbird/febs/dapp/contract/andao/AndaoContractMain.java
+++ b/src/main/java/cc/mrbird/febs/dapp/contract/andao/AndaoContractMain.java
@@ -29,7 +29,7 @@
@Component
-@ConditionalOnProperty(prefix = "system", name = "quartz-job", havingValue = "true")
+@ConditionalOnProperty(prefix = "system", name = "chain-listener", havingValue = "true")
public class AndaoContractMain {
@Autowired
@@ -77,6 +77,12 @@
}
private static Web3j getInstanceScope() {
+
+ HttpService httpService = new HttpService(blockchainNode);
+ return Web3j.build(httpService);
+ }
+
+ private static Web3j getInstanceScopes() {
HttpService httpService = new HttpService(blockchainNode);
return Web3j.build(httpService);
@@ -170,7 +176,7 @@
System.out.println("启动投注监听事件");
// 指定密钥文件并进行账号和密码的验证
Credentials credentials = Credentials.create(privateKey);
- Abi contract = Abi.load(contractAddr, getInstanceScope(), credentials, new DefaultGasProvider());
+ Abi contract = Abi.load(contractAddr, getInstanceScopes(), credentials, new DefaultGasProvider());
EthFilter filter = getFilter(startBlock);
contract.withdrawnEventFlowable(filter).subscribe(e->{
try {
--
Gitblit v1.9.1