| | |
| | | JSONObject msg = new JSONObject(); |
| | | JSONObject arg = new JSONObject(); |
| | | arg.put("channel", CHANNEL_NAME); |
| | | arg.put("instType", "SWAP"); |
| | | arg.put("instId", instId); |
| | | msg.put("op", "subscribe"); |
| | | JSONArray args = new JSONArray(); |
| | | args.add(arg); |
| | | msg.put("args", args); |
| | | ws.send(msg.toJSONString()); |
| | | log.info("[OKX-WS] {} 订阅成功", CHANNEL_NAME); |
| | | log.info("[OKX-WS] {} 订阅成功, instId:{}", CHANNEL_NAME, instId); |
| | | } |
| | | |
| | | @Override |
| | |
| | | JSONObject msg = new JSONObject(); |
| | | JSONObject arg = new JSONObject(); |
| | | arg.put("channel", CHANNEL_NAME); |
| | | arg.put("instType", "SWAP"); |
| | | arg.put("instId", instId); |
| | | msg.put("op", "unsubscribe"); |
| | | JSONArray args = new JSONArray(); |
| | | args.add(arg); |