| | |
| | | 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; |
| | |
| | | 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()); |
| | | } |
| | | }); |