nhanvubk/ger-market-java
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

支持Retifive的操作,调试自动打包 优化代码

Browse Source
This commit is contained in:
Achilles
2024-04-23 09:40:06 +08:00
parent 6daf6e7150
commit 3fb3e9918f
1 changed files with 7 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/main/java/cn/stock/market/web/MessageRetifiveController.java
View File

@@ -222,11 +222,13 @@ public class MessageRetifiveController {
RefreshMsg refreshMsg = appClient.getMessageFuture().get(10, TimeUnit.SECONDS);// 设置超时时间，例如10秒 RefreshMsg refreshMsg = appClient.getMessageFuture().get(10, TimeUnit.SECONDS);// 设置超时时间，例如10秒
if (DataType.DataTypes.FIELD_LIST == refreshMsg.payload().dataType()){ if (DataType.DataTypes.FIELD_LIST == refreshMsg.payload().dataType()){
List<String> strings = decode4(refreshMsg.payload().fieldList()); List<String> strings = decode4(refreshMsg.payload().fieldList());
appClient.subscribeList(strings); // 根据itemName订阅 if(strings.size()>0){
// 等待消息 appClient.subscribeList(strings); // 根据itemName订阅
List<RefreshMsg> refreshMsgs = appClient.getMessagesFuture().get(10, TimeUnit.SECONDS); // 等待消息
for (RefreshMsg msg : refreshMsgs) { List<RefreshMsg> refreshMsgs = appClient.getMessagesFuture().get(10, TimeUnit.SECONDS);
list.add(decode3(msg.payload().fieldList(),msg.name())); for (RefreshMsg msg : refreshMsgs) {
list.add(decode3(msg.payload().fieldList(),msg.name()));
}
} }
} }
} catch (Exception e) { } catch (Exception e) {