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

类 RedisMessageSenderImpl

java.lang.Object

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

所有已实现的接口:

MessageSenderService

public class RedisMessageSenderImpl
extends Object
implements MessageSenderService

发布消息实现类

字段概要

字段

修饰符和类型	字段	说明
private static final long	BASE_RETRY_INTERVAL_MS
private org.springframework.data.redis.connection.RedisStreamCommands.XAddOptions	defaultAddOptions
private final RedisMessageConfigProperties	redisMessageConfigProperties
private final org.springframework.data.redis.core.StringRedisTemplate	stringRedisTemplate

构造器概要

构造器

构造器	说明
RedisMessageSenderImpl()

方法概要

修饰符和类型	方法	说明
void	init()
private void	putIgnoreNull(Map<String,String> map, String key, Object value)
<T> void	send(String streamKey, T payload)	发布redis消息，指定stream
<T> void	send(String streamKey, T payload, int retryTimes)	发布redis消息，指定stream key
private <T> void	sendMsg(String streamKey, T payload, int retryTimes)	发送消息到redis stream

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

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

字段详细资料

stringRedisTemplate

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

redisMessageConfigProperties

private final RedisMessageConfigProperties redisMessageConfigProperties

BASE_RETRY_INTERVAL_MS

private static final long BASE_RETRY_INTERVAL_MS

另请参阅:

• 常量字段值

defaultAddOptions

private org.springframework.data.redis.connection.RedisStreamCommands.XAddOptions defaultAddOptions

构造器详细资料

RedisMessageSenderImpl

public RedisMessageSenderImpl()

方法详细资料

init

@PostConstruct
public void init()

send

public <T> void send(String streamKey,
 T payload)

发布redis消息，指定stream

指定者:

send 在接口中 MessageSenderService

参数:

streamKey - stream key

payload - 消息体

send

public <T> void send(String streamKey,
 T payload,
 int retryTimes)

发布redis消息，指定stream key

指定者:

send 在接口中 MessageSenderService

参数:

streamKey - stream key

payload - 消息体

retryTimes - 重试次数

sendMsg

private <T> void sendMsg(String streamKey,
 T payload,
 int retryTimes)

发送消息到redis stream

类型参数:

T - 泛型业务对象

参数:

streamKey - stream key

payload - 消息体

putIgnoreNull

private void putIgnoreNull(Map<String,String> map,
 String key,
 Object value)