记得上下班打卡 | git大法好,push需谨慎
Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Submit feedback
Contribute to GitLab
Sign in
Toggle navigation
L
liquidnet-bus-v1
Project
Project
Details
Activity
Releases
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
董敬伟
liquidnet-bus-v1
Commits
c5b3d56f
Commit
c5b3d56f
authored
Mar 11, 2022
by
anjiabin
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
优化dragon消费组功能
parent
610fde0b
Changes
7
Hide whitespace changes
Inline
Side-by-side
Showing
7 changed files
with
501 additions
and
896 deletions
+501
-896
ConsumerMchNotifyFailRedisStreamConfig.java
...dragon/config/ConsumerMchNotifyFailRedisStreamConfig.java
+76
-0
ConsumerMchNotifyRedisStreamConfig.java
...mer/dragon/config/ConsumerMchNotifyRedisStreamConfig.java
+76
-0
ConsumerPayNotifyRedisStreamConfig.java
...mer/dragon/config/ConsumerPayNotifyRedisStreamConfig.java
+76
-0
ConsumerPayRedisStreamConfig.java
.../consumer/dragon/config/ConsumerPayRedisStreamConfig.java
+197
-0
ConsumerRefundRedisStreamConfig.java
...nsumer/dragon/config/ConsumerRefundRedisStreamConfig.java
+76
-0
RedisStreamConfig.java
...net/service/consumer/dragon/config/RedisStreamConfig.java
+0
-448
RedisStreamConfig2.java
...et/service/consumer/dragon/config/RedisStreamConfig2.java
+0
-448
No files found.
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-dragon/src/main/java/com/liquidnet/service/consumer/dragon/config/ConsumerMchNotifyFailRedisStreamConfig.java
0 → 100644
View file @
c5b3d56f
package
com
.
liquidnet
.
service
.
consumer
.
dragon
.
config
;
import
com.liquidnet.common.cache.redis.config.RedisStreamConfig
;
import
com.liquidnet.service.consumer.dragon.receiver.RedisMchNotifyFailReceiver
;
import
com.liquidnet.service.dragon.constant.DragonConstant
;
import
lombok.var
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.context.annotation.Bean
;
import
org.springframework.context.annotation.Configuration
;
import
org.springframework.data.redis.connection.RedisConnectionFactory
;
import
org.springframework.data.redis.connection.stream.Consumer
;
import
org.springframework.data.redis.connection.stream.MapRecord
;
import
org.springframework.data.redis.connection.stream.ReadOffset
;
import
org.springframework.data.redis.connection.stream.StreamOffset
;
import
org.springframework.data.redis.stream.StreamMessageListenerContainer
;
import
org.springframework.data.redis.stream.Subscription
;
/**
* @author AnJiabin <anjiabin@zhengzai.tv>
* @version V1.0
* @Description: TODO
* @class: ConsumerPayRedisStreamConfig
* @Package com.liquidnet.service.consumer.dragon.config
* @Copyright: LightNet @ Copyright (c) 2021
* @date 2022/3/11 14:45
*/
@Configuration
public
class
ConsumerMchNotifyFailRedisStreamConfig
extends
RedisStreamConfig
{
@Autowired
private
RedisMchNotifyFailReceiver
redisMchNotifyFailReceiver
;
private
Subscription
buildReceiverSubscription
(
StreamMessageListenerContainer
<
String
,
MapRecord
<
String
,
String
,
String
>>
listenerContainer
,
int
t
)
{
return
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
PAY_MCH_NOTIFY_ERROR_GROUP
.
getCode
(),
getConsumerName
(
DragonConstant
.
MysqlRedisQueueEnum
.
PAY_MCH_NOTIFY_ERROR_KEY
.
name
()
+
t
)),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
PAY_MCH_NOTIFY_ERROR_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisMchNotifyFailReceiver
);
}
@Bean
public
Subscription
subscriptionMchNotifyFail01
(
RedisConnectionFactory
factory
)
{
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
var
subscription
=
buildReceiverSubscription
(
listenerContainer
,
1
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionMchNotifyFail02
(
RedisConnectionFactory
factory
)
{
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
var
subscription
=
buildReceiverSubscription
(
listenerContainer
,
2
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionMchNotifyFail03
(
RedisConnectionFactory
factory
)
{
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
var
subscription
=
buildReceiverSubscription
(
listenerContainer
,
3
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionMchNotifyFail04
(
RedisConnectionFactory
factory
)
{
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
var
subscription
=
buildReceiverSubscription
(
listenerContainer
,
4
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionMchNotifyFail05
(
RedisConnectionFactory
factory
)
{
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
var
subscription
=
buildReceiverSubscription
(
listenerContainer
,
5
);
listenerContainer
.
start
();
return
subscription
;
}
}
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-dragon/src/main/java/com/liquidnet/service/consumer/dragon/config/ConsumerMchNotifyRedisStreamConfig.java
0 → 100644
View file @
c5b3d56f
package
com
.
liquidnet
.
service
.
consumer
.
dragon
.
config
;
import
com.liquidnet.common.cache.redis.config.RedisStreamConfig
;
import
com.liquidnet.service.consumer.dragon.receiver.RedisMchNotifyReceiver
;
import
com.liquidnet.service.dragon.constant.DragonConstant
;
import
lombok.var
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.context.annotation.Bean
;
import
org.springframework.context.annotation.Configuration
;
import
org.springframework.data.redis.connection.RedisConnectionFactory
;
import
org.springframework.data.redis.connection.stream.Consumer
;
import
org.springframework.data.redis.connection.stream.MapRecord
;
import
org.springframework.data.redis.connection.stream.ReadOffset
;
import
org.springframework.data.redis.connection.stream.StreamOffset
;
import
org.springframework.data.redis.stream.StreamMessageListenerContainer
;
import
org.springframework.data.redis.stream.Subscription
;
/**
* @author AnJiabin <anjiabin@zhengzai.tv>
* @version V1.0
* @Description: TODO
* @class: ConsumerPayRedisStreamConfig
* @Package com.liquidnet.service.consumer.dragon.config
* @Copyright: LightNet @ Copyright (c) 2021
* @date 2022/3/11 14:45
*/
@Configuration
public
class
ConsumerMchNotifyRedisStreamConfig
extends
RedisStreamConfig
{
@Autowired
private
RedisMchNotifyReceiver
redisMchNotifyReceiver
;
private
Subscription
buildReceiverSubscription
(
StreamMessageListenerContainer
<
String
,
MapRecord
<
String
,
String
,
String
>>
listenerContainer
,
int
t
)
{
return
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
PAY_MCH_NOTIFY_GROUP
.
getCode
(),
getConsumerName
(
DragonConstant
.
MysqlRedisQueueEnum
.
PAY_MCH_NOTIFY_KEY
.
name
()
+
t
)),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
PAY_MCH_NOTIFY_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisMchNotifyReceiver
);
}
@Bean
public
Subscription
subscriptionMchNotify01
(
RedisConnectionFactory
factory
)
{
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
var
subscription
=
buildReceiverSubscription
(
listenerContainer
,
1
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionMchNotify02
(
RedisConnectionFactory
factory
)
{
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
var
subscription
=
buildReceiverSubscription
(
listenerContainer
,
2
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionMchNotify03
(
RedisConnectionFactory
factory
)
{
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
var
subscription
=
buildReceiverSubscription
(
listenerContainer
,
3
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionMchNotify04
(
RedisConnectionFactory
factory
)
{
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
var
subscription
=
buildReceiverSubscription
(
listenerContainer
,
4
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionMchNotify05
(
RedisConnectionFactory
factory
)
{
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
var
subscription
=
buildReceiverSubscription
(
listenerContainer
,
5
);
listenerContainer
.
start
();
return
subscription
;
}
}
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-dragon/src/main/java/com/liquidnet/service/consumer/dragon/config/ConsumerPayNotifyRedisStreamConfig.java
0 → 100644
View file @
c5b3d56f
package
com
.
liquidnet
.
service
.
consumer
.
dragon
.
config
;
import
com.liquidnet.common.cache.redis.config.RedisStreamConfig
;
import
com.liquidnet.service.consumer.dragon.receiver.RedisPayNotifyReceiver
;
import
com.liquidnet.service.dragon.constant.DragonConstant
;
import
lombok.var
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.context.annotation.Bean
;
import
org.springframework.context.annotation.Configuration
;
import
org.springframework.data.redis.connection.RedisConnectionFactory
;
import
org.springframework.data.redis.connection.stream.Consumer
;
import
org.springframework.data.redis.connection.stream.MapRecord
;
import
org.springframework.data.redis.connection.stream.ReadOffset
;
import
org.springframework.data.redis.connection.stream.StreamOffset
;
import
org.springframework.data.redis.stream.StreamMessageListenerContainer
;
import
org.springframework.data.redis.stream.Subscription
;
/**
* @author AnJiabin <anjiabin@zhengzai.tv>
* @version V1.0
* @Description: TODO
* @class: ConsumerPayRedisStreamConfig
* @Package com.liquidnet.service.consumer.dragon.config
* @Copyright: LightNet @ Copyright (c) 2021
* @date 2022/3/11 14:45
*/
@Configuration
public
class
ConsumerPayNotifyRedisStreamConfig
extends
RedisStreamConfig
{
@Autowired
private
RedisPayNotifyReceiver
redisPayNotifyReceiver
;
private
Subscription
buildReceiverSubscription
(
StreamMessageListenerContainer
<
String
,
MapRecord
<
String
,
String
,
String
>>
listenerContainer
,
int
t
)
{
return
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_NOTIFY_GROUP
.
getCode
(),
getConsumerName
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_NOTIFY_KEY
.
name
()
+
t
)),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_NOTIFY_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisPayNotifyReceiver
);
}
@Bean
public
Subscription
subscriptionPayNotify01
(
RedisConnectionFactory
factory
)
{
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
var
subscription
=
buildReceiverSubscription
(
listenerContainer
,
1
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPayNotify02
(
RedisConnectionFactory
factory
)
{
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
var
subscription
=
buildReceiverSubscription
(
listenerContainer
,
2
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPayNotify03
(
RedisConnectionFactory
factory
)
{
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
var
subscription
=
buildReceiverSubscription
(
listenerContainer
,
3
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPayNotify04
(
RedisConnectionFactory
factory
)
{
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
var
subscription
=
buildReceiverSubscription
(
listenerContainer
,
4
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPayNotify05
(
RedisConnectionFactory
factory
)
{
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
var
subscription
=
buildReceiverSubscription
(
listenerContainer
,
5
);
listenerContainer
.
start
();
return
subscription
;
}
}
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-dragon/src/main/java/com/liquidnet/service/consumer/dragon/config/ConsumerPayRedisStreamConfig.java
0 → 100644
View file @
c5b3d56f
package
com
.
liquidnet
.
service
.
consumer
.
dragon
.
config
;
import
com.liquidnet.common.cache.redis.config.RedisStreamConfig
;
import
com.liquidnet.service.consumer.dragon.receiver.RedisPayReceiver
;
import
com.liquidnet.service.dragon.constant.DragonConstant
;
import
lombok.var
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.context.annotation.Bean
;
import
org.springframework.context.annotation.Configuration
;
import
org.springframework.data.redis.connection.RedisConnectionFactory
;
import
org.springframework.data.redis.connection.stream.Consumer
;
import
org.springframework.data.redis.connection.stream.MapRecord
;
import
org.springframework.data.redis.connection.stream.ReadOffset
;
import
org.springframework.data.redis.connection.stream.StreamOffset
;
import
org.springframework.data.redis.stream.StreamMessageListenerContainer
;
import
org.springframework.data.redis.stream.Subscription
;
/**
* @author AnJiabin <anjiabin@zhengzai.tv>
* @version V1.0
* @Description: TODO
* @class: ConsumerPayRedisStreamConfig
* @Package com.liquidnet.service.consumer.dragon.config
* @Copyright: LightNet @ Copyright (c) 2021
* @date 2022/3/11 14:45
*/
@Configuration
public
class
ConsumerPayRedisStreamConfig
extends
RedisStreamConfig
{
@Autowired
private
RedisPayReceiver
redisPayReceiver
;
private
Subscription
buildReceiverSubscription
(
StreamMessageListenerContainer
<
String
,
MapRecord
<
String
,
String
,
String
>>
listenerContainer
,
int
t
)
{
return
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_GROUP
.
getCode
(),
getConsumerName
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_KEY
.
name
()
+
t
)),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisPayReceiver
);
}
@Bean
public
Subscription
subscriptionPay01
(
RedisConnectionFactory
factory
)
{
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
var
subscription
=
buildReceiverSubscription
(
listenerContainer
,
1
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPay02
(
RedisConnectionFactory
factory
)
{
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
var
subscription
=
buildReceiverSubscription
(
listenerContainer
,
2
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPay03
(
RedisConnectionFactory
factory
)
{
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
var
subscription
=
buildReceiverSubscription
(
listenerContainer
,
3
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPay04
(
RedisConnectionFactory
factory
)
{
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
var
subscription
=
buildReceiverSubscription
(
listenerContainer
,
4
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPay05
(
RedisConnectionFactory
factory
)
{
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
var
subscription
=
buildReceiverSubscription
(
listenerContainer
,
5
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPay06
(
RedisConnectionFactory
factory
)
{
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
var
subscription
=
buildReceiverSubscription
(
listenerContainer
,
6
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPay07
(
RedisConnectionFactory
factory
)
{
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
var
subscription
=
buildReceiverSubscription
(
listenerContainer
,
7
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPay08
(
RedisConnectionFactory
factory
)
{
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
var
subscription
=
buildReceiverSubscription
(
listenerContainer
,
8
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPay09
(
RedisConnectionFactory
factory
)
{
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
var
subscription
=
buildReceiverSubscription
(
listenerContainer
,
9
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPay10
(
RedisConnectionFactory
factory
)
{
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
var
subscription
=
buildReceiverSubscription
(
listenerContainer
,
10
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPay11
(
RedisConnectionFactory
factory
)
{
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
var
subscription
=
buildReceiverSubscription
(
listenerContainer
,
11
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPay12
(
RedisConnectionFactory
factory
)
{
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
var
subscription
=
buildReceiverSubscription
(
listenerContainer
,
12
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPay13
(
RedisConnectionFactory
factory
)
{
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
var
subscription
=
buildReceiverSubscription
(
listenerContainer
,
13
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPay14
(
RedisConnectionFactory
factory
)
{
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
var
subscription
=
buildReceiverSubscription
(
listenerContainer
,
14
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPay15
(
RedisConnectionFactory
factory
)
{
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
var
subscription
=
buildReceiverSubscription
(
listenerContainer
,
15
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPay16
(
RedisConnectionFactory
factory
)
{
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
var
subscription
=
buildReceiverSubscription
(
listenerContainer
,
16
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPay17
(
RedisConnectionFactory
factory
)
{
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
var
subscription
=
buildReceiverSubscription
(
listenerContainer
,
17
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPay18
(
RedisConnectionFactory
factory
)
{
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
var
subscription
=
buildReceiverSubscription
(
listenerContainer
,
18
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPay19
(
RedisConnectionFactory
factory
)
{
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
var
subscription
=
buildReceiverSubscription
(
listenerContainer
,
19
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPay20
(
RedisConnectionFactory
factory
)
{
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
var
subscription
=
buildReceiverSubscription
(
listenerContainer
,
20
);
listenerContainer
.
start
();
return
subscription
;
}
}
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-dragon/src/main/java/com/liquidnet/service/consumer/dragon/config/ConsumerRefundRedisStreamConfig.java
0 → 100644
View file @
c5b3d56f
package
com
.
liquidnet
.
service
.
consumer
.
dragon
.
config
;
import
com.liquidnet.common.cache.redis.config.RedisStreamConfig
;
import
com.liquidnet.service.consumer.dragon.receiver.RedisRefundReceiver
;
import
com.liquidnet.service.dragon.constant.DragonConstant
;
import
lombok.var
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.context.annotation.Bean
;
import
org.springframework.context.annotation.Configuration
;
import
org.springframework.data.redis.connection.RedisConnectionFactory
;
import
org.springframework.data.redis.connection.stream.Consumer
;
import
org.springframework.data.redis.connection.stream.MapRecord
;
import
org.springframework.data.redis.connection.stream.ReadOffset
;
import
org.springframework.data.redis.connection.stream.StreamOffset
;
import
org.springframework.data.redis.stream.StreamMessageListenerContainer
;
import
org.springframework.data.redis.stream.Subscription
;
/**
* @author AnJiabin <anjiabin@zhengzai.tv>
* @version V1.0
* @Description: TODO
* @class: ConsumerRefundRedisStreamConfig
* @Package com.liquidnet.service.consumer.dragon.config
* @Copyright: LightNet @ Copyright (c) 2021
* @date 2022/3/11 14:45
*/
@Configuration
public
class
ConsumerRefundRedisStreamConfig
extends
RedisStreamConfig
{
@Autowired
private
RedisRefundReceiver
redisRefundReceiver
;
private
Subscription
buildReceiverSubscription
(
StreamMessageListenerContainer
<
String
,
MapRecord
<
String
,
String
,
String
>>
listenerContainer
,
int
t
)
{
return
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_REFUND_GROUP
.
getCode
(),
getConsumerName
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_REFUND_KEY
.
name
()
+
t
)),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_REFUND_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisRefundReceiver
);
}
@Bean
public
Subscription
subscriptionRefund01
(
RedisConnectionFactory
factory
)
{
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
var
subscription
=
buildReceiverSubscription
(
listenerContainer
,
1
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionRefund02
(
RedisConnectionFactory
factory
)
{
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
var
subscription
=
buildReceiverSubscription
(
listenerContainer
,
2
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionRefund03
(
RedisConnectionFactory
factory
)
{
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
var
subscription
=
buildReceiverSubscription
(
listenerContainer
,
3
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionRefund04
(
RedisConnectionFactory
factory
)
{
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
var
subscription
=
buildReceiverSubscription
(
listenerContainer
,
4
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionRefund05
(
RedisConnectionFactory
factory
)
{
var
listenerContainer
=
this
.
buildStreamMessageListenerContainer
(
factory
);
var
subscription
=
buildReceiverSubscription
(
listenerContainer
,
5
);
listenerContainer
.
start
();
return
subscription
;
}
}
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-dragon/src/main/java/com/liquidnet/service/consumer/dragon/config/RedisStreamConfig.java
deleted
100644 → 0
View file @
610fde0b
package
com
.
liquidnet
.
service
.
consumer
.
dragon
.
config
;
import
com.liquidnet.service.consumer.dragon.receiver.*
;
import
com.liquidnet.service.dragon.constant.DragonConstant
;
import
lombok.var
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.context.annotation.Bean
;
import
org.springframework.context.annotation.Configuration
;
import
org.springframework.data.redis.connection.RedisConnectionFactory
;
import
org.springframework.data.redis.connection.stream.Consumer
;
import
org.springframework.data.redis.connection.stream.ReadOffset
;
import
org.springframework.data.redis.connection.stream.StreamOffset
;
import
org.springframework.data.redis.stream.StreamMessageListenerContainer
;
import
org.springframework.data.redis.stream.Subscription
;
import
java.time.Duration
;
@Configuration
public
class
RedisStreamConfig
{
@Autowired
private
RedisPayReceiver
redisPayReceiver
;
@Autowired
private
RedisRefundReceiver
redisRefundReceiver
;
@Autowired
private
RedisPayNotifyReceiver
redisPayNotifyReceiver
;
@Autowired
private
RedisMchNotifyReceiver
redisMchNotifyReceiver
;
@Autowired
private
RedisMchNotifyFailReceiver
redisMchNotifyFailReceiver
;
@Bean
public
Subscription
subscriptionPay0
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_GROUP
.
getCode
(),
"dragon-pay-0"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisPayReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPay1
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_GROUP
.
getCode
(),
"dragon-pay-1"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisPayReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPay2
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_GROUP
.
getCode
(),
"dragon-pay-2"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisPayReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPay3
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_GROUP
.
getCode
(),
"dragon-pay-3"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisPayReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPay4
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_GROUP
.
getCode
(),
"dragon-pay-4"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisPayReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPay5
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_GROUP
.
getCode
(),
"dragon-pay-5"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisPayReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPay6
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_GROUP
.
getCode
(),
"dragon-pay-6"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisPayReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPay7
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_GROUP
.
getCode
(),
"dragon-pay-7"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisPayReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPay8
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_GROUP
.
getCode
(),
"dragon-pay-8"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisPayReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPay9
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_GROUP
.
getCode
(),
"dragon-pay-9"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisPayReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionRefund0
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_REFUND_GROUP
.
getCode
(),
"dragon-refund-0"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_REFUND_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisRefundReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionRefund1
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_REFUND_GROUP
.
getCode
(),
"dragon-refund-1"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_REFUND_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisRefundReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionRefund2
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_REFUND_GROUP
.
getCode
(),
"dragon-refund-2"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_REFUND_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisRefundReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionRefund3
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_REFUND_GROUP
.
getCode
(),
"dragon-refund-3"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_REFUND_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisRefundReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionRefund4
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_REFUND_GROUP
.
getCode
(),
"dragon-refund-4"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_REFUND_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisRefundReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPayNotify0
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_NOTIFY_GROUP
.
getCode
(),
"dragon-pay-notify-0"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_NOTIFY_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisPayNotifyReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPayNotify1
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_NOTIFY_GROUP
.
getCode
(),
"dragon-pay-notify-1"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_NOTIFY_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisPayNotifyReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPayNotify2
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_NOTIFY_GROUP
.
getCode
(),
"dragon-pay-notify-2"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_NOTIFY_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisPayNotifyReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPayNotify3
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_NOTIFY_GROUP
.
getCode
(),
"dragon-pay-notify-3"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_NOTIFY_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisPayNotifyReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPayNotify4
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_NOTIFY_GROUP
.
getCode
(),
"dragon-pay-notify-4"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_NOTIFY_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisPayNotifyReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionMchNotify0
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
PAY_MCH_NOTIFY_GROUP
.
getCode
(),
"pay-mch-notify-0"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
PAY_MCH_NOTIFY_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisMchNotifyReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionMchNotify1
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
PAY_MCH_NOTIFY_GROUP
.
getCode
(),
"pay-mch-notify-1"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
PAY_MCH_NOTIFY_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisMchNotifyReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionMchNotify2
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
PAY_MCH_NOTIFY_GROUP
.
getCode
(),
"pay-mch-notify-2"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
PAY_MCH_NOTIFY_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisMchNotifyReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionMchNotify3
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
PAY_MCH_NOTIFY_GROUP
.
getCode
(),
"pay-mch-notify-3"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
PAY_MCH_NOTIFY_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisMchNotifyReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionMchNotify4
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
PAY_MCH_NOTIFY_GROUP
.
getCode
(),
"pay-mch-notify-4"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
PAY_MCH_NOTIFY_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisMchNotifyReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPayNotifyFail0
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
PAY_MCH_NOTIFY_ERROR_GROUP
.
getCode
(),
"pay-mch-notify-fail-0"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
PAY_MCH_NOTIFY_ERROR_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisMchNotifyFailReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPayNotifyFail1
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
PAY_MCH_NOTIFY_ERROR_GROUP
.
getCode
(),
"pay-mch-notify-fail-1"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
PAY_MCH_NOTIFY_ERROR_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisMchNotifyFailReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPayNotifyFail2
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
PAY_MCH_NOTIFY_ERROR_GROUP
.
getCode
(),
"pay-mch-notify-fail-2"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
PAY_MCH_NOTIFY_ERROR_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisMchNotifyFailReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPayNotifyFail3
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
PAY_MCH_NOTIFY_ERROR_GROUP
.
getCode
(),
"pay-mch-notify-fail-3"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
PAY_MCH_NOTIFY_ERROR_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisMchNotifyFailReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPayNotifyFail4
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
PAY_MCH_NOTIFY_ERROR_GROUP
.
getCode
(),
"pay-mch-notify-fail-4"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
PAY_MCH_NOTIFY_ERROR_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisMchNotifyFailReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
}
liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-dragon/src/main/java/com/liquidnet/service/consumer/dragon/config/RedisStreamConfig2.java
deleted
100644 → 0
View file @
610fde0b
package
com
.
liquidnet
.
service
.
consumer
.
dragon
.
config
;
import
com.liquidnet.service.consumer.dragon.receiver.*
;
import
com.liquidnet.service.dragon.constant.DragonConstant
;
import
lombok.var
;
import
org.springframework.beans.factory.annotation.Autowired
;
import
org.springframework.context.annotation.Bean
;
import
org.springframework.context.annotation.Configuration
;
import
org.springframework.data.redis.connection.RedisConnectionFactory
;
import
org.springframework.data.redis.connection.stream.Consumer
;
import
org.springframework.data.redis.connection.stream.ReadOffset
;
import
org.springframework.data.redis.connection.stream.StreamOffset
;
import
org.springframework.data.redis.stream.StreamMessageListenerContainer
;
import
org.springframework.data.redis.stream.Subscription
;
import
java.time.Duration
;
@Configuration
public
class
RedisStreamConfig2
{
@Autowired
private
RedisPayReceiver
redisPayReceiver
;
@Autowired
private
RedisRefundReceiver
redisRefundReceiver
;
@Autowired
private
RedisPayNotifyReceiver
redisPayNotifyReceiver
;
@Autowired
private
RedisMchNotifyReceiver
redisMchNotifyReceiver
;
@Autowired
private
RedisMchNotifyFailReceiver
redisMchNotifyFailReceiver
;
@Bean
public
Subscription
subscriptionPay10
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_GROUP
.
getCode
(),
"dragon-pay-10"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisPayReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPay11
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_GROUP
.
getCode
(),
"dragon-pay-11"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisPayReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPay12
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_GROUP
.
getCode
(),
"dragon-pay-12"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisPayReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPay13
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_GROUP
.
getCode
(),
"dragon-pay-13"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisPayReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPay14
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_GROUP
.
getCode
(),
"dragon-pay-14"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisPayReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPay15
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_GROUP
.
getCode
(),
"dragon-pay-15"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisPayReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPay16
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_GROUP
.
getCode
(),
"dragon-pay-16"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisPayReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPay17
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_GROUP
.
getCode
(),
"dragon-pay-17"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisPayReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPay18
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_GROUP
.
getCode
(),
"dragon-pay-18"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisPayReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPay19
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_GROUP
.
getCode
(),
"dragon-pay-19"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisPayReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionRefund10
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_REFUND_GROUP
.
getCode
(),
"dragon-refund-10"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_REFUND_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisRefundReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionRefund11
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_REFUND_GROUP
.
getCode
(),
"dragon-refund-11"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_REFUND_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisRefundReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionRefund12
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_REFUND_GROUP
.
getCode
(),
"dragon-refund-12"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_REFUND_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisRefundReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionRefund13
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_REFUND_GROUP
.
getCode
(),
"dragon-refund-13"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_REFUND_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisRefundReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionRefund14
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_REFUND_GROUP
.
getCode
(),
"dragon-refund-14"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_REFUND_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisRefundReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPayNotify10
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_NOTIFY_GROUP
.
getCode
(),
"dragon-pay-notify-10"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_NOTIFY_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisPayNotifyReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPayNotify11
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_NOTIFY_GROUP
.
getCode
(),
"dragon-pay-notify-11"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_NOTIFY_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisPayNotifyReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPayNotify12
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_NOTIFY_GROUP
.
getCode
(),
"dragon-pay-notify-12"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_NOTIFY_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisPayNotifyReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPayNotify13
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_NOTIFY_GROUP
.
getCode
(),
"dragon-pay-notify-13"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_NOTIFY_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisPayNotifyReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPayNotify14
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_NOTIFY_GROUP
.
getCode
(),
"dragon-pay-notify-14"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
DRAGON_PAY_NOTIFY_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisPayNotifyReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionMchNotify10
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
PAY_MCH_NOTIFY_GROUP
.
getCode
(),
"pay-mch-notify-10"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
PAY_MCH_NOTIFY_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisMchNotifyReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionMchNotify11
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
PAY_MCH_NOTIFY_GROUP
.
getCode
(),
"pay-mch-notify-11"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
PAY_MCH_NOTIFY_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisMchNotifyReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionMchNotify12
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
PAY_MCH_NOTIFY_GROUP
.
getCode
(),
"pay-mch-notify-12"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
PAY_MCH_NOTIFY_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisMchNotifyReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionMchNotify13
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
PAY_MCH_NOTIFY_GROUP
.
getCode
(),
"pay-mch-notify-13"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
PAY_MCH_NOTIFY_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisMchNotifyReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionMchNotify14
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
PAY_MCH_NOTIFY_GROUP
.
getCode
(),
"pay-mch-notify-14"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
PAY_MCH_NOTIFY_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisMchNotifyReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPayNotifyFail10
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
PAY_MCH_NOTIFY_ERROR_GROUP
.
getCode
(),
"pay-mch-notify-fail-10"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
PAY_MCH_NOTIFY_ERROR_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisMchNotifyFailReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPayNotifyFail11
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
PAY_MCH_NOTIFY_ERROR_GROUP
.
getCode
(),
"pay-mch-notify-fail-11"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
PAY_MCH_NOTIFY_ERROR_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisMchNotifyFailReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPayNotifyFail12
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
PAY_MCH_NOTIFY_ERROR_GROUP
.
getCode
(),
"pay-mch-notify-fail-12"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
PAY_MCH_NOTIFY_ERROR_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisMchNotifyFailReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPayNotifyFail13
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
PAY_MCH_NOTIFY_ERROR_GROUP
.
getCode
(),
"pay-mch-notify-fail-13"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
PAY_MCH_NOTIFY_ERROR_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisMchNotifyFailReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
@Bean
public
Subscription
subscriptionPayNotifyFail14
(
RedisConnectionFactory
factory
)
{
var
options
=
StreamMessageListenerContainer
.
StreamMessageListenerContainerOptions
.
builder
()
.
pollTimeout
(
Duration
.
ofMillis
(
1
))
.
build
();
var
listenerContainer
=
StreamMessageListenerContainer
.
create
(
factory
,
options
);
var
subscription
=
listenerContainer
.
receiveAutoAck
(
Consumer
.
from
(
DragonConstant
.
MysqlRedisQueueEnum
.
PAY_MCH_NOTIFY_ERROR_GROUP
.
getCode
(),
"pay-mch-notify-fail-14"
),
StreamOffset
.
create
(
DragonConstant
.
MysqlRedisQueueEnum
.
PAY_MCH_NOTIFY_ERROR_KEY
.
getCode
(),
ReadOffset
.
lastConsumed
()),
redisMchNotifyFailReceiver
);
listenerContainer
.
start
();
return
subscription
;
}
}
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment