记得上下班打卡 | git大法好，push需谨慎

Skip to content

L
liquidnet-bus-v1
Commit 68bcd56f authored by jiangxiulong's avatar jiangxiulong
Browse files
Options

注释

parent c34d8671
Hide whitespace changes
Inline Side-by-side
Showing with 3 additions and 2 deletions
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/config/ConsumerCommonBizRedisStreamConfig.java
View file @ 68bcd56f
...@@ -47,6 +47,7 @@ public class ConsumerCommonBizRedisStreamConfig extends RedisStreamConfig { ...@@ -47,6 +47,7 @@ public class ConsumerCommonBizRedisStreamConfig extends RedisStreamConfig {
ConsumerSweetTemplateMsgReceiver consumerSweetTemplateMsgReceiver; ConsumerSweetTemplateMsgReceiver consumerSweetTemplateMsgReceiver;
@Autowired @Autowired
ConsumerSweetStoneIntegralReceiver consumerSweetStoneIntegralReceiver; ConsumerSweetStoneIntegralReceiver consumerSweetStoneIntegralReceiver;
/*------chime------*/
@Autowired @Autowired
ConsumerChimeUserOperationLikeReceiver consumerChimeUserOperationLikeReceiver; ConsumerChimeUserOperationLikeReceiver consumerChimeUserOperationLikeReceiver;
@Autowired @Autowired
...@@ -68,7 +69,7 @@ public class ConsumerCommonBizRedisStreamConfig extends RedisStreamConfig { ...@@ -68,7 +69,7 @@ public class ConsumerCommonBizRedisStreamConfig extends RedisStreamConfig {
} }
return subscriptionList; return subscriptionList;
} }
@Bean @Bean // 增减积分
public List<Subscription> subscriptionSweetSqlApiStoneIntgral(RedisConnectionFactory factory) { public List<Subscription> subscriptionSweetSqlApiStoneIntgral(RedisConnectionFactory factory) {
List<Subscription> subscriptionList = new ArrayList<>(); List<Subscription> subscriptionList = new ArrayList<>();
MQConst.SweetQueue stream = MQConst.SweetQueue.SWEET_STONE_INTEGRAL; MQConst.SweetQueue stream = MQConst.SweetQueue.SWEET_STONE_INTEGRAL;
...@@ -176,7 +177,7 @@ public class ConsumerCommonBizRedisStreamConfig extends RedisStreamConfig { ...@@ -176,7 +177,7 @@ public class ConsumerCommonBizRedisStreamConfig extends RedisStreamConfig {
return subscriptionList; return subscriptionList;
} }
@Bean @Bean // 增减积分
public List<Subscription> subscriptionGoblinBizIntegral(RedisConnectionFactory factory) { public List<Subscription> subscriptionGoblinBizIntegral(RedisConnectionFactory factory) {
List<Subscription> subscriptionList = new ArrayList<>(); List<Subscription> subscriptionList = new ArrayList<>();
MQConst.GoblinQueue stream = MQConst.GoblinQueue.BIZ_INTEGRAL; MQConst.GoblinQueue stream = MQConst.GoblinQueue.BIZ_INTEGRAL;
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment