1
zj
2025-03-12 d12967b6b0d4a6da6946699aa14d7d008aa79db0
src/main/java/com/nq/ws/WsClientConfig.java
@@ -8,6 +8,7 @@
import com.nq.service.impl.MandatoryLiquidationService;
import com.nq.utils.ApplicationContextRegisterUtil;
import com.nq.utils.PropertiesUtil;
import com.nq.utils.redis.RedisKeyUtil;
import com.nq.ws.client.IO;
import com.nq.ws.client.Socket;
import io.socket.emitter.Emitter;
@@ -81,6 +82,8 @@
        socket.on("marketData", new Emitter.Listener() {
            @Override
            public void call(Object... args) {
                StockRealTimeBean stockDetailBean =  new Gson().fromJson(args[0].toString(), StockRealTimeBean.class);
                RedisKeyUtil.setCacheRealTimeStock(EStockType.IN,stockDetailBean);
                send(args[0].toString());
            }
        });