Package glide.api.models.configuration

Class ClusterSubscriptionConfiguration

java.lang.Object

glide.api.models.configuration.BaseSubscriptionConfiguration

glide.api.models.configuration.ClusterSubscriptionConfiguration

public final class ClusterSubscriptionConfiguration
extends BaseSubscriptionConfiguration

Subscription configuration for GlideClusterClient.

Example:

 // Configuration with 3 subscriptions and a callback:
 ClusterSubscriptionConfiguration subscriptionConfiguration =
     ClusterSubscriptionConfiguration.builder()
         .subscription(EXACT, "notifications")
         .subscription(EXACT, "news")
         .subscription(SHARDED, "data")
         .callback(callback)
         .build();
 // Now it could be supplied to `GlideClusterClientConfiguration`:
 GlideClusterClientConfiguration clientConfiguration =
     GlideClusterClientConfiguration.builder()
         .address(NodeAddress.builder().port(6379).build())
         .subscriptionConfiguration(subscriptionConfiguration)
         .build();
 

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ClusterSubscriptionConfiguration.ClusterSubscriptionConfigurationBuilder	Builder for ClusterSubscriptionConfiguration.
static class	ClusterSubscriptionConfiguration.PubSubClusterChannelMode	Describes subscription modes for cluster client.

Nested classes/interfaces inherited from class glide.api.models.configuration.BaseSubscriptionConfiguration

BaseSubscriptionConfiguration.BaseSubscriptionConfigurationBuilder<B extends BaseSubscriptionConfiguration.BaseSubscriptionConfigurationBuilder<B,C>,C extends BaseSubscriptionConfiguration>, BaseSubscriptionConfiguration.ChannelMode, BaseSubscriptionConfiguration.MessageCallback

Field Summary

Fields inherited from class glide.api.models.configuration.BaseSubscriptionConfiguration

callback, context

Method Summary

Modifier and Type	Method	Description
static ClusterSubscriptionConfiguration.ClusterSubscriptionConfigurationBuilder	builder()
java.util.Map<ClusterSubscriptionConfiguration.PubSubClusterChannelMode,java.util.Set<GlideString>>	getSubscriptions()	PubSub subscriptions to be used for the client. Will be applied via SUBSCRIBE/PSUBSCRIBE/SSUBSCRIBE commands during connection establishment.

Methods inherited from class glide.api.models.configuration.BaseSubscriptionConfiguration

getCallback, getContext

Methods inherited from class java.lang.Object

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

Method Detail

builder

public static ClusterSubscriptionConfiguration.ClusterSubscriptionConfigurationBuilder builder()

getSubscriptions

public java.util.Map<ClusterSubscriptionConfiguration.PubSubClusterChannelMode,java.util.Set<GlideString>> getSubscriptions()

PubSub subscriptions to be used for the client.
Will be applied via SUBSCRIBE/PSUBSCRIBE/SSUBSCRIBE commands during connection establishment.