smile-user 迁移

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/config/smile/ConsumerSmileUserRedisStreamConfig.java

@@ -27,11 +27,11 @@ public class ConsumerSmileUserRedisStreamConfig extends RedisStreamConfig {
     StringRedisTemplate stringRedisTemplate;
 
     @Bean// 创建订单
-    public List<Subscription> subscriptionSqlOrderCreate(RedisConnectionFactory factory) {
+    public List<Subscription> smileUser(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.SmileQueue stream = MQConst.SmileQueue.SMILE_USER;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
-        for (int i = 0; i < 20; i++) {
+        for (int i = 0; i < 3; i++) {
             StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer = this.buildStreamMessageListenerContainer(factory);
             subscriptionList.add(listenerContainer.receiveAutoAck(
                     Consumer.from(stream.getGroup(), getConsumerName(stream.name() + i)),