Package org.springframework.data.redis.connection

Class ReactiveSubscription.ChannelMessage<C,M>

java.lang.Object

org.springframework.data.redis.connection.ReactiveSubscription.ChannelMessage<C,M>

Type Parameters:

C - type of how the channel name is represented.

M - type of how the message is represented.

All Implemented Interfaces:

ReactiveSubscription.Message<C,M>

Direct Known Subclasses:

ReactiveSubscription.PatternMessage

Enclosing interface:

ReactiveSubscription

public static class ReactiveSubscription.ChannelMessage<C,M>
extends Object
implements ReactiveSubscription.Message<C,M>

Value object for a Redis channel message.

Since:

2.1

Author:

Mark Paluch, Christoph Strobl

Constructor Summary

Constructors

Constructor	Description
ChannelMessage(C channel, M message)	Create a new ReactiveSubscription.ChannelMessage.

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
C	getChannel()	Get the channel the message published to.
M	getMessage()	Get the actual message body.
int	hashCode()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Details

ChannelMessage

public ChannelMessage(C channel,
 M message)

Create a new ReactiveSubscription.ChannelMessage.

Parameters:

channel - must not be null.

message - must not be null.

Method Details

getChannel

public C getChannel()

Description copied from interface: ReactiveSubscription.Message

Get the channel the message published to.

Specified by:

getChannel in interface ReactiveSubscription.Message<C,M>

Returns:

never null.

getMessage

public M getMessage()

Description copied from interface: ReactiveSubscription.Message

Get the actual message body.

Specified by:

getMessage in interface ReactiveSubscription.Message<C,M>

Returns:

never null.

equals

public boolean equals(@Nullable
 Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object