Merge branch 'dev' into test

00ca7df3 · 张国柄 · 75056eb9 · 10ee3c9d · 00ca7df3
Commit 00ca7df3 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));
    }
 }