cc.carm.plugin.mineredis.api.message

类 RedisMessage

java.lang.Object

cc.carm.plugin.mineredis.api.message.RedisMessage

public class RedisMessage
extends java.lang.Object

字段概要

字段

限定符和类型	字段和说明
protected @NotNull java.lang.String	channel
protected @Nullable com.google.common.io.ByteArrayDataInput	data
protected byte[]	rawData
protected @NotNull java.lang.String	sourceServerID
protected long	timestamp

构造器概要

构造器

构造器和说明
RedisMessage(@NotNull java.lang.String channel, @NotNull java.lang.String sourceServerID, long timestamp, byte[] raw)

方法概要

限定符和类型	方法和说明
<T> T	apply(@NotNull java.util.function.Function<com.google.common.io.ByteArrayDataInput,T> handler)
@NotNull java.lang.String	channel()
com.google.common.io.ByteArrayDataInput	data()
com.google.common.io.ByteArrayDataInput	dataCopy()
@NotNull java.lang.String	getChannel()
com.google.common.io.ByteArrayDataInput	getData()
@NotNull java.lang.String	getSourceServerID()
long	getTimestamp()
boolean	isLocalMessage() 判断当前消息是否为本地(当前服务器)发出的。
byte[]	raw()
void	reset()
@NotNull java.lang.String	sourceID()
long	timestamp()

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

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

字段详细资料

channel

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

sourceServerID

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

timestamp

protected final long timestamp

rawData

protected final byte[] rawData

data

@Nullable
protected @Nullable com.google.common.io.ByteArrayDataInput data

构造器详细资料

RedisMessage

public RedisMessage(@NotNull
                    @NotNull java.lang.String channel,
                    @NotNull
                    @NotNull java.lang.String sourceServerID,
                    long timestamp,
                    byte[] raw)

方法详细资料

isLocalMessage

public boolean isLocalMessage()

判断当前消息是否为本地(当前服务器)发出的。

返回:

是否为本地发出的消息

getSourceServerID

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

sourceID

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

getChannel

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

channel

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

getTimestamp

public long getTimestamp()

timestamp

public long timestamp()

raw

public byte[] raw()

data

public com.google.common.io.ByteArrayDataInput data()

getData

public com.google.common.io.ByteArrayDataInput getData()

reset

public void reset()

dataCopy

public com.google.common.io.ByteArrayDataInput dataCopy()

apply

public <T> T apply(@NotNull
                   @NotNull java.util.function.Function<com.google.common.io.ByteArrayDataInput,T> handler)