Adam压测:暂时取消sendMqByRedis;

35ba42db · 张国柄 · ea50daca · 35ba42db
Commit 35ba42db authored Jul 31, 2021 by 张国柄
Show whitespace changes
Inline Side-by-side

Showing with 3 additions and 3 deletions

QueueUtils.java ...main/java/com/liquidnet/service/adam/util/QueueUtils.java +3 -3

No files found.
--- a/liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/util/QueueUtils.java
+++ b/liquidnet-bus-service/liquidnet-service-adam/liquidnet-service-adam-impl/src/main/java/com/liquidnet/service/adam/util/QueueUtils.java
@@ -34,8 +34,8 @@ public class QueueUtils {
     * @param jsonMsg   Json字符串
     */
    public void sendMsgByRedis(String streamKey, String jsonMsg) {
-        HashMap<String, String> map = CollectionUtil.mapStringString();
-        map.put("message", jsonMsg);
-        stringRedisTemplate.opsForStream().add(StreamRecords.mapBacked(map).withStreamKey(streamKey));
+//        HashMap<String, String> map = CollectionUtil.mapStringString();
+//        map.put("message", jsonMsg);
+//        stringRedisTemplate.opsForStream().add(StreamRecords.mapBacked(map).withStreamKey(streamKey));
    }
 }