程序包 com.sie.mbm.mom.framework.mq.async.redis

类 MessageSubscriptionImpl

java.lang.Object

com.sie.mbm.mom.framework.mq.async.redis.MessageSubscriptionImpl

所有已实现的接口:

MessageSubscriptionService

public class MessageSubscriptionImpl
extends Object
implements MessageSubscriptionService

消息订阅服务实现

字段概要

字段

修饰符和类型	字段	说明
private final org.springframework.data.redis.stream.StreamMessageListenerContainer<String,org.springframework.data.redis.connection.stream.MapRecord<String,String,String>>	container
private List<MessageHandlerInfo>	messageHandlerInfos
private final RedisMessageHelper	redisMessageHelper
private final org.springframework.data.redis.core.StringRedisTemplate	stringRedisTemplate

构造器概要

构造器

构造器	说明
MessageSubscriptionImpl()

方法概要

修饰符和类型	方法	说明
private void	createGroupIfNotExists(String stream, String group, org.springframework.data.redis.core.StringRedisTemplate stringRedisTemplate)	创建消费组
List<MessageHandlerInfo>	getSubscribes()	获取所有订阅
private void	registerSubscription(org.springframework.data.redis.stream.StreamMessageListenerContainer<String,org.springframework.data.redis.connection.stream.MapRecord<String,String,String>> container, MessageHandlerInfo messageHandlerInfo, RedisMessageHelper redisMessageHelper, int consumeThreadIndex)
void	subscribe(MessageHandlerInfo messageHandlerInfo)	订阅

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

container

private final org.springframework.data.redis.stream.StreamMessageListenerContainer<String,org.springframework.data.redis.connection.stream.MapRecord<String,String,String>> container

stringRedisTemplate

private final org.springframework.data.redis.core.StringRedisTemplate stringRedisTemplate

redisMessageHelper

private final RedisMessageHelper redisMessageHelper

messageHandlerInfos

private List<MessageHandlerInfo> messageHandlerInfos

构造器详细资料

MessageSubscriptionImpl

public MessageSubscriptionImpl()

方法详细资料

subscribe

public void subscribe(MessageHandlerInfo messageHandlerInfo)

订阅

指定者:

subscribe 在接口中 MessageSubscriptionService

参数:

messageHandlerInfo - 订阅信息

getSubscribes

public List<MessageHandlerInfo> getSubscribes()

获取所有订阅

指定者:

getSubscribes 在接口中 MessageSubscriptionService

返回:

订阅

registerSubscription

private void registerSubscription(org.springframework.data.redis.stream.StreamMessageListenerContainer<String,org.springframework.data.redis.connection.stream.MapRecord<String,String,String>> container,
 MessageHandlerInfo messageHandlerInfo,
 RedisMessageHelper redisMessageHelper,
 int consumeThreadIndex)

createGroupIfNotExists

private void createGroupIfNotExists(String stream,
 String group,
 org.springframework.data.redis.core.StringRedisTemplate stringRedisTemplate)

创建消费组

参数:

stream - stream key

group - stream group