| | |
|---|
| | | import cc.mrbird.febs.common.exception.FebsException; |
|---|
| | | import cc.mrbird.febs.mall.chain.enums.ChainEnum; |
|---|
| | | import cc.mrbird.febs.mall.chain.enums.EthService; |
|---|
| | | import com.sun.xml.internal.bind.v2.TODO; |
|---|
| | | import io.reactivex.Flowable; |
|---|
| | | import io.reactivex.disposables.Disposable; |
|---|
| | | import lombok.extern.slf4j.Slf4j; |
|---|
| | | import org.java_websocket.WebSocket; |
|---|
| | | import org.web3j.crypto.Credentials; |
|---|
| | | import org.web3j.protocol.Web3j; |
|---|
| | | import org.web3j.protocol.core.DefaultBlockParameter; |
|---|
| | |
|---|
| | | } catch (Exception e) { |
|---|
| | | try { |
|---|
| | | ws.close(); |
|---|
| | | //TODO |
|---|
| | | |
|---|
| | | WebSocket.READYSTATE readyState = webSocketClient.getReadyState(); |
|---|
| | | |
|---|
| | | webSocketClient.reconnect(); |
|---|
| | | webSocketClient = new WebSocketClient(new URI("wss://bsc-mainnet.nodereal.io/ws/v1/78074065950e4915aef4f12b6f357d16")); |
|---|
| | | ws = new WebSocketService(webSocketClient, true); |
|---|
| | | ws.connect(); |
|---|
