程序包 com.cdkjframework.redis.subscribe

类 SubscribeConsumer

java.lang.Object

com.cdkjframework.redis.subscribe.SubscribeConsumer

所有已实现的接口:

io.lettuce.core.pubsub.RedisPubSubListener<String,String>

@Component
public class SubscribeConsumer
extends Object
implements io.lettuce.core.pubsub.RedisPubSubListener<String,String>

构造器概要

构造器

构造器	说明
SubscribeConsumer(RedisConfig redisConfig)	构建函数

方法概要

修饰符和类型	方法	说明
final void	message(String channel, String message)	从频道订阅接收的消息。
final void	message(String pattern, String channel, String message)	从模式订阅接收的消息。
final void	psubscribed(String pattern, long count)	订阅一个模式。
final void	punsubscribed(String pattern, long count)	从模式中取消订阅。
void	start()	订阅数据 启动服务
void	subscribe(String channel, String message)	订阅消息回调
void	subscribe(String pattern, String channel, String message)	从模式订阅接收的消息
final void	subscribed(String channel, long count)	订阅了一个频道。
final void	unsubscribed(String channel, long count)	从频道取消订阅。

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

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

构造器详细资料

SubscribeConsumer

public SubscribeConsumer(RedisConfig redisConfig)

构建函数

方法详细资料

start

@Bean(name="start")
public void start()

订阅数据 启动服务

subscribe

public void subscribe(String channel,
 String message)

订阅消息回调

参数:

channel - 渠道.

message - 消息.

subscribe

public void subscribe(String pattern,
 String channel,
 String message)

从模式订阅接收的消息

参数:

pattern - 模式

channel - 渠道.

message - 消息.

message

public final void message(String channel,
 String message)

从频道订阅接收的消息。

指定者:

message 在接口中 io.lettuce.core.pubsub.RedisPubSubListener<String,String>

参数:

channel - 渠道.

message - 消息.

subscribed

public final void subscribed(String channel,
 long count)

订阅了一个频道。

指定者:

subscribed 在接口中 io.lettuce.core.pubsub.RedisPubSubListener<String,String>

参数:

channel - 渠道

count - 订阅数据.

message

public final void message(String pattern,
 String channel,
 String message)

从模式订阅接收的消息。

指定者:

message 在接口中 io.lettuce.core.pubsub.RedisPubSubListener<String,String>

参数:

pattern - 模式

channel - 渠道.

message - 消息.

psubscribed

public final void psubscribed(String pattern,
 long count)

订阅一个模式。

指定者:

psubscribed 在接口中 io.lettuce.core.pubsub.RedisPubSubListener<String,String>

参数:

pattern - 模式

count - 订阅数据.

unsubscribed

public final void unsubscribed(String channel,
 long count)

从频道取消订阅。

指定者:

unsubscribed 在接口中 io.lettuce.core.pubsub.RedisPubSubListener<String,String>

参数:

channel - 渠道

count - 订阅数据.

punsubscribed

public final void punsubscribed(String pattern,
 long count)

从模式中取消订阅。

指定者:

punsubscribed 在接口中 io.lettuce.core.pubsub.RedisPubSubListener<String,String>

参数:

pattern - 模式

count - 订阅数据.