cc.carm.plugin.mineredis.api.channel

类 RedisRequest<MSG>

java.lang.Object

cc.carm.plugin.mineredis.api.channel.RedisRequest<MSG>

所有已实现的接口:

RedisMessageListener

public class RedisRequest<MSG>
extends java.lang.Object
implements RedisMessageListener

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	RedisRequest.Builder<REQUEST>

字段概要

字段

限定符和类型	字段和说明
protected @NotNull java.lang.String	channel
protected @Nullable java.util.function.Predicate<RedisMessage>	filter
protected @Nullable java.util.function.Function<RedisMessage,PreparedRedisMessage>	handler
protected @NotNull java.util.function.BiConsumer<com.google.common.io.ByteArrayDataOutput,MSG>	serializer

构造器概要

构造器

构造器和说明
RedisRequest(@NotNull java.lang.String channel, @Nullable java.util.function.Predicate<RedisMessage> filter, @NotNull java.util.function.BiConsumer<com.google.common.io.ByteArrayDataOutput,MSG> serializer, @Nullable java.util.function.Function<RedisMessage,PreparedRedisMessage> handler)

方法概要

限定符和类型	方法和说明
static <T> RedisRequest.Builder<T>	at(java.lang.String channel, java.lang.Class<T> requestClazz) 创建一个新的 RedisRequest.Builder 实例，用于构建 RedisRequest。
@NotNull java.lang.String	getChannel()
void	handle(RedisMessage message)
long	publish(MSG message)
long	publish(@NotNull java.util.function.Supplier<MSG> message)
@NotNull io.lettuce.core.RedisFuture<java.lang.Long>	publishAsync(MSG message)
@NotNull io.lettuce.core.RedisFuture<java.lang.Long>	publishAsync(@NotNull java.util.function.Supplier<MSG> message)
boolean	shouldRegister()

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

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

字段详细资料

channel

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

serializer

@NotNull
protected @NotNull java.util.function.BiConsumer<com.google.common.io.ByteArrayDataOutput,MSG> serializer

filter

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

handler

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

构造器详细资料

RedisRequest

public RedisRequest(@NotNull
                    @NotNull java.lang.String channel,
                    @Nullable
                    @Nullable java.util.function.Predicate<RedisMessage> filter,
                    @NotNull
                    @NotNull java.util.function.BiConsumer<com.google.common.io.ByteArrayDataOutput,MSG> serializer,
                    @Nullable
                    @Nullable java.util.function.Function<RedisMessage,PreparedRedisMessage> handler)

方法详细资料

at

public static <T> RedisRequest.Builder<T> at(java.lang.String channel,
                                             java.lang.Class<T> requestClazz)

创建一个新的 RedisRequest.Builder 实例，用于构建 RedisRequest。

类型参数:

T - 请求消息的类型参数，通常是一个具体的类。

参数:

channel - 频道名称，通常是一个字符串标识符。

requestClazz - 请求消息的类类型，用于序列化和反序列化。

返回:

一个新的 RedisRequest.Builder 实例，用于构建 RedisRequest。

shouldRegister

public boolean shouldRegister()

handle

public void handle(RedisMessage message)

指定者:

handle 在接口中 RedisMessageListener

getChannel

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

publish

public long publish(@NotNull
                    @NotNull java.util.function.Supplier<MSG> message)

publish

public long publish(@NotNull
                    MSG message)

publishAsync

@NotNull
public @NotNull io.lettuce.core.RedisFuture<java.lang.Long> publishAsync(@NotNull
                                                                                  @NotNull java.util.function.Supplier<MSG> message)

publishAsync

@NotNull
public @NotNull io.lettuce.core.RedisFuture<java.lang.Long> publishAsync(@NotNull
                                                                                  MSG message)