cc.carm.plugin.mineredis.api.channel

类 RedisChannel

java.lang.Object

cc.carm.plugin.mineredis.api.channel.RedisChannel

所有已实现的接口:

RedisMessageListener

public class RedisChannel
extends java.lang.Object
implements RedisMessageListener

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	RedisChannel.RedisChannelBuilder

字段概要

字段

限定符和类型	字段和说明
protected @NotNull java.lang.String	channel
static java.lang.String	CHANNEL_DELIMITER
protected @Nullable java.util.function.Predicate<RedisMessage>	filter
protected @Nullable java.util.function.Function<RedisMessage,PreparedRedisMessage>	handler

构造器概要

构造器

构造器和说明
RedisChannel(@NotNull java.lang.String channel, @Nullable java.util.function.Predicate<RedisMessage> filter, @Nullable java.util.function.Function<RedisMessage,PreparedRedisMessage> handler)

方法概要

限定符和类型	方法和说明
static RedisChannel.RedisChannelBuilder	at(java.lang.String... channelParts) 创建一个新的 RedisChannel 实例，用于监听指定的频道。
static RedisChannel.RedisChannelBuilder	at(java.lang.String channel) 创建一个新的 RedisChannel 实例，用于监听指定的频道。
@NotNull java.lang.String	getChannel()
void	handle(RedisMessage message)
long	publish(@NotNull com.google.common.io.ByteArrayDataOutput data)
long	publish(@NotNull java.util.function.Consumer<com.google.common.io.ByteArrayDataOutput> data)
long	publish(java.lang.Object... values)
io.lettuce.core.RedisFuture<java.lang.Long>	publishAsync(@NotNull com.google.common.io.ByteArrayDataOutput data)
io.lettuce.core.RedisFuture<java.lang.Long>	publishAsync(@NotNull java.util.function.Consumer<com.google.common.io.ByteArrayDataOutput> data)
io.lettuce.core.RedisFuture<java.lang.Long>	publishAsync(java.lang.Object... values)
boolean	shouldRegister()

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

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

字段详细资料

CHANNEL_DELIMITER

public static final java.lang.String CHANNEL_DELIMITER

另请参阅:

常量字段值

channel

@NotNull
protected final @NotNull java.lang.String channel

filter

@Nullable
protected final @Nullable java.util.function.Predicate<RedisMessage> filter

handler

@Nullable
protected final @Nullable java.util.function.Function<RedisMessage,PreparedRedisMessage> handler

构造器详细资料

RedisChannel

public RedisChannel(@NotNull
                    @NotNull java.lang.String channel,
                    @Nullable
                    @Nullable java.util.function.Predicate<RedisMessage> filter,
                    @Nullable
                    @Nullable java.util.function.Function<RedisMessage,PreparedRedisMessage> handler)

方法详细资料

at

public static RedisChannel.RedisChannelBuilder at(java.lang.String channel)

创建一个新的 RedisChannel 实例，用于监听指定的频道。

参数:

channel - 频道名称，使用 CHANNEL_DELIMITER 作为分隔符。

返回:

一个新的 RedisChannelBuilder 实例，用于构建 RedisChannel。

at

public static RedisChannel.RedisChannelBuilder at(java.lang.String... channelParts)

创建一个新的 RedisChannel 实例，用于监听指定的频道。

参数:

channelParts - 频道的各个部分，将使用 CHANNEL_DELIMITER 连接。

返回:

一个新的 RedisChannelBuilder 实例，用于构建 RedisChannel。

getChannel

@NotNull
public @NotNull java.lang.String getChannel()

shouldRegister

public boolean shouldRegister()

handle

public void handle(RedisMessage message)

指定者:

handle 在接口中 RedisMessageListener

publishAsync

public io.lettuce.core.RedisFuture<java.lang.Long> publishAsync(@NotNull
                                                                @NotNull com.google.common.io.ByteArrayDataOutput data)

publishAsync

public io.lettuce.core.RedisFuture<java.lang.Long> publishAsync(@NotNull
                                                                @NotNull java.util.function.Consumer<com.google.common.io.ByteArrayDataOutput> data)

publishAsync

public io.lettuce.core.RedisFuture<java.lang.Long> publishAsync(java.lang.Object... values)

publish

public long publish(@NotNull
                    java.lang.Object... values)

publish

public long publish(@NotNull
                    @NotNull com.google.common.io.ByteArrayDataOutput data)

publish

public long publish(@NotNull
                    @NotNull java.util.function.Consumer<com.google.common.io.ByteArrayDataOutput> data)