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

Merge remote-tracking branch 'origin/retifive' into retifive

Browse Source
This commit is contained in:
zhangjian
2024-04-23 09:51:49 +08:00
parent 0696f91ef8 3fb3e9918f
commit 888ce2adeb
2 changed files with 7 additions and 6 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) {

1
src/main/java/cn/stock/market/web/RefinitivApiController.java
View File

@@ -37,7 +37,6 @@ import java.util.concurrent.TimeUnit;
@RequestMapping({"/api/market/refinitiv", "/api/hq/refinitiv"}) @RequestMapping({"/api/market/refinitiv", "/api/hq/refinitiv"})
public class RefinitivApiController { public class RefinitivApiController {
@Resource @Resource
private AppClient appClient; private AppClient appClient;
@Autowired @Autowired