revert Adam压测:暂时取消sendMqByRedis;

10ee3c9d · 张国柄 · 0b9f65f7 · 10ee3c9d
Commit 10ee3c9d authored Jul 31, 2021 by 张国柄
Hide 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));
    }
 }