diff --git a/zc-business/src/main/java/com/zc/business/constant/RedisStreamConstants.java b/zc-business/src/main/java/com/zc/business/constant/RedisStreamConstants.java index c1a102da..164aa588 100644 --- a/zc-business/src/main/java/com/zc/business/constant/RedisStreamConstants.java +++ b/zc-business/src/main/java/com/zc/business/constant/RedisStreamConstants.java @@ -10,7 +10,7 @@ public class RedisStreamConstants { */ public static class DeviceOnline { public final static String KEY = "device:online"; - public final static String GROUP = "group1"; + public final static String GROUP = "group2"; public final static String CONSUMER = "consumer1"; } @@ -19,7 +19,7 @@ public class RedisStreamConstants { */ public static class DeviceOffline { public final static String KEY = "device:offline"; - public final static String GROUP = "group1"; + public final static String GROUP = "group2"; public final static String CONSUMER = "consumer1"; } @@ -28,7 +28,7 @@ public class RedisStreamConstants { */ public static class DeviceEvent { public final static String KEY = "device:event"; - public final static String GROUP = "group1"; + public final static String GROUP = "group2"; public final static String CONSUMER = "consumer1"; } @@ -37,7 +37,7 @@ public class RedisStreamConstants { */ public static class DevicePropertyReport { public final static String KEY = "device:property:report"; - public final static String GROUP = "group1"; + public final static String GROUP = "group2"; public final static String CONSUMER = "consumer1"; } @@ -46,7 +46,7 @@ public class RedisStreamConstants { */ public static class DevicePropertyReadReply { public final static String KEY = "device:property:read:reply"; - public final static String GROUP = "group1"; + public final static String GROUP = "group2"; public final static String CONSUMER = "consumer1"; } @@ -56,7 +56,7 @@ public class RedisStreamConstants { */ public static class DevicePropertyWriteReply { public final static String KEY = "device:property:write:reply"; - public final static String GROUP = "group1"; + public final static String GROUP = "group2"; public final static String CONSUMER = "consumer1"; } @@ -65,7 +65,7 @@ public class RedisStreamConstants { */ public static class DeviceFunctionReply { public final static String KEY = "device:function:reply"; - public final static String GROUP = "group1"; + public final static String GROUP = "group2"; public final static String CONSUMER = "consumer1"; }