PubSubClusterEndpoint (Lettuce 6.3.3.BUILD-SNAPSHOT API)

java.lang.Object
- io.lettuce.core.protocol.DefaultEndpoint
- - io.lettuce.core.pubsub.PubSubEndpoint<K,V>
  - - io.lettuce.core.cluster.PubSubClusterEndpoint<K,V>

All Implemented Interfaces:

AsyncCloseable, AsyncCloseable, Endpoint, PushHandler, RedisChannelWriter, Closeable, AutoCloseable
```
public class PubSubClusterEndpoint<K,V>
extends PubSubEndpoint<K,V>
```
Author:

Mark Paluch

Field Summary
- Fields inherited from class io.lettuce.core.protocol.DefaultEndpoint
  channel

Constructor Summary

Constructors
Constructor	Description
`PubSubClusterEndpoint(ClientOptions clientOptions, ClientResources clientResources)`	Initialize a new instance that handles commands from the supplied queue.

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`addListener(RedisClusterPubSubListener<K,V> listener)`	Add a new `listener`.
`RedisClusterPubSubListener<K,V>`	`getUpstreamListener()`
`protected void`	`notifyListeners(PubSubMessage<K,V> output)`
`void`	`removeListener(RedisClusterPubSubListener<K,V> listener)`	Remove an existing `listener`.
`void`	`setNodeMessagePropagation(boolean nodeMessagePropagation)`

Methods inherited from class io.lettuce.core.pubsub.PubSubEndpoint
addListener, containsViolatingCommands, getChannels, getListeners, getPatterns, hasChannelSubscriptions, hasPatternSubscriptions, isSubscribed, notifyChannelActive, rejectCommand, rejectCommands, removeListener, write, write

Methods inherited from class io.lettuce.core.protocol.DefaultEndpoint
addListener, close, closeAsync, disconnect, doExclusive, drainCommands, flushCommands, getClientResources, getId, getProtocolVersion, getPushListeners, initialState, isClosed, logPrefix, notifyChannelInactive, notifyDrainQueuedCommands, notifyException, registerConnectionWatchdog, removeListener, reset, setAutoFlushCommands, setConnectionFacade, writeToBuffer

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - PubSubClusterEndpoint
```
public PubSubClusterEndpoint(ClientOptions clientOptions,
                             ClientResources clientResources)
```
    Initialize a new instance that handles commands from the supplied queue.
    
    Parameters:
    
    clientOptions - client options for this connection, must not be null
    
    clientResources - client resources for this connection, must not be null.
- Method Detail
  - addListener
```
public void addListener(RedisClusterPubSubListener<K,V> listener)
```
    Add a new listener.
    
    Parameters:
    
    listener - the listener, must not be null.
  - getUpstreamListener
```
public RedisClusterPubSubListener<K,V> getUpstreamListener()
```
  - removeListener
```
public void removeListener(RedisClusterPubSubListener<K,V> listener)
```
    Remove an existing listener.
    
    Parameters:
    
    listener - the listener, must not be null.
  - setNodeMessagePropagation
```
public void setNodeMessagePropagation(boolean nodeMessagePropagation)
```
  - notifyListeners
```
protected void notifyListeners(PubSubMessage<K,V> output)
```
    Overrides:
    
    notifyListeners in class PubSubEndpoint<K,V>