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

Commit 23beae92 authored by zhanggb's avatar zhanggb

~consumer:+listener;

parent cfb6a42d
......@@ -69,7 +69,7 @@ public class ConsumerGoblinOrderCRedisStreamConfig extends RedisStreamConfig {
/* -------------------------------------------------------- | */
@Bean//
public List<Subscription> subscriptionSqlArtworkGen(RedisConnectionFactory factory) {
public List<Subscription> subscriptionSqlGoblinOrderClose(RedisConnectionFactory factory) {
List<Subscription> subscriptionList = new ArrayList<>();
MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_ORDER_CLOSE;
this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
......
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