程序包 com.cdkjframework.redis.realize

类 RedisClusterPubSubConnection

java.lang.Object
com.cdkjframework.redis.realize.RedisClusterPubSubConnection
所有已实现的接口:
io.lettuce.core.api.AsyncCloseable, io.lettuce.core.api.StatefulConnection<String,String>, io.lettuce.core.api.StatefulRedisConnection<String,String>, io.lettuce.core.cluster.pubsub.StatefulRedisClusterPubSubConnection<String,String>, io.lettuce.core.internal.AsyncCloseable, io.lettuce.core.pubsub.StatefulRedisPubSubConnection<String,String>, AutoCloseable
public class RedisClusterPubSubConnection extends Object implements io.lettuce.core.cluster.pubsub.StatefulRedisClusterPubSubConnection<String,String>

  • 构造器详细资料

    • RedisClusterPubSubConnection

      public RedisClusterPubSubConnection()

  • 方法详细资料

    • isMulti

      public boolean isMulti()
      指定者:
      isMulti 在接口中 io.lettuce.core.api.StatefulRedisConnection<String,String>

    • sync

      public io.lettuce.core.cluster.pubsub.api.sync.RedisClusterPubSubCommands<String,String> sync()
      指定者:
      sync 在接口中 io.lettuce.core.cluster.pubsub.StatefulRedisClusterPubSubConnection<String,String>
      指定者:
      sync 在接口中 io.lettuce.core.api.StatefulRedisConnection<String,String>
      指定者:
      sync 在接口中 io.lettuce.core.pubsub.StatefulRedisPubSubConnection<String,String>

    • async

      public io.lettuce.core.cluster.pubsub.api.async.RedisClusterPubSubAsyncCommands<String,String> async()
      指定者:
      async 在接口中 io.lettuce.core.cluster.pubsub.StatefulRedisClusterPubSubConnection<String,String>
      指定者:
      async 在接口中 io.lettuce.core.api.StatefulRedisConnection<String,String>
      指定者:
      async 在接口中 io.lettuce.core.pubsub.StatefulRedisPubSubConnection<String,String>

    • reactive

      public io.lettuce.core.cluster.pubsub.api.reactive.RedisClusterPubSubReactiveCommands<String,String> reactive()
      指定者:
      reactive 在接口中 io.lettuce.core.cluster.pubsub.StatefulRedisClusterPubSubConnection<String,String>
      指定者:
      reactive 在接口中 io.lettuce.core.api.StatefulRedisConnection<String,String>
      指定者:
      reactive 在接口中 io.lettuce.core.pubsub.StatefulRedisPubSubConnection<String,String>

    • addListener

      public void addListener(io.lettuce.core.pubsub.RedisPubSubListener<String,String> redisPubSubListener)
      指定者:
      addListener 在接口中 io.lettuce.core.pubsub.StatefulRedisPubSubConnection<String,String>

    • removeListener

      public void removeListener(io.lettuce.core.pubsub.RedisPubSubListener<String,String> redisPubSubListener)
      指定者:
      removeListener 在接口中 io.lettuce.core.pubsub.StatefulRedisPubSubConnection<String,String>

    • getConnection

      public io.lettuce.core.pubsub.StatefulRedisPubSubConnection<String,String> getConnection(String s)
      指定者:
      getConnection 在接口中 io.lettuce.core.cluster.pubsub.StatefulRedisClusterPubSubConnection<String,String>

    • getConnectionAsync

      public CompletableFuture<io.lettuce.core.pubsub.StatefulRedisPubSubConnection<String,String>> getConnectionAsync(String s)
      指定者:
      getConnectionAsync 在接口中 io.lettuce.core.cluster.pubsub.StatefulRedisClusterPubSubConnection<String,String>

    • getConnection

      public io.lettuce.core.pubsub.StatefulRedisPubSubConnection<String,String> getConnection(String s, int i)
      指定者:
      getConnection 在接口中 io.lettuce.core.cluster.pubsub.StatefulRedisClusterPubSubConnection<String,String>

    • getConnectionAsync

      public CompletableFuture<io.lettuce.core.pubsub.StatefulRedisPubSubConnection<String,String>> getConnectionAsync(String s, int i)
      指定者:
      getConnectionAsync 在接口中 io.lettuce.core.cluster.pubsub.StatefulRedisClusterPubSubConnection<String,String>

    • getPartitions

      public io.lettuce.core.cluster.models.partitions.Partitions getPartitions()
      指定者:
      getPartitions 在接口中 io.lettuce.core.cluster.pubsub.StatefulRedisClusterPubSubConnection<String,String>

    • setNodeMessagePropagation

      public void setNodeMessagePropagation(boolean b)
      指定者:
      setNodeMessagePropagation 在接口中 io.lettuce.core.cluster.pubsub.StatefulRedisClusterPubSubConnection<String,String>

    • addListener

      public void addListener(io.lettuce.core.cluster.pubsub.RedisClusterPubSubListener<String,String> redisClusterPubSubListener)
      指定者:
      addListener 在接口中 io.lettuce.core.cluster.pubsub.StatefulRedisClusterPubSubConnection<String,String>

    • removeListener

      public void removeListener(io.lettuce.core.cluster.pubsub.RedisClusterPubSubListener<String,String> redisClusterPubSubListener)
      指定者:
      removeListener 在接口中 io.lettuce.core.cluster.pubsub.StatefulRedisClusterPubSubConnection<String,String>

    • setTimeout

      public void setTimeout(Duration duration)
      指定者:
      setTimeout 在接口中 io.lettuce.core.api.StatefulConnection<String,String>

    • getTimeout

      public Duration getTimeout()
      指定者:
      getTimeout 在接口中 io.lettuce.core.api.StatefulConnection<String,String>

    • dispatch

      public <T> io.lettuce.core.protocol.RedisCommand<String,String,T> dispatch(io.lettuce.core.protocol.RedisCommand<String,String,T> redisCommand)
      指定者:
      dispatch 在接口中 io.lettuce.core.api.StatefulConnection<String,String>

    • dispatch

      public Collection<io.lettuce.core.protocol.RedisCommand<String,String,?>> dispatch(Collection<? extends io.lettuce.core.protocol.RedisCommand<String,String,?>> collection)
      指定者:
      dispatch 在接口中 io.lettuce.core.api.StatefulConnection<String,String>

    • close

      public void close()
      指定者:
      close 在接口中 AutoCloseable
      指定者:
      close 在接口中 io.lettuce.core.api.StatefulConnection<String,String>

    • closeAsync

      public CompletableFuture<Void> closeAsync()
      指定者:
      closeAsync 在接口中 io.lettuce.core.api.AsyncCloseable
      指定者:
      closeAsync 在接口中 io.lettuce.core.internal.AsyncCloseable
      指定者:
      closeAsync 在接口中 io.lettuce.core.api.StatefulConnection<String,String>

    • isOpen

      public boolean isOpen()
      指定者:
      isOpen 在接口中 io.lettuce.core.api.StatefulConnection<String,String>

    • getOptions

      public io.lettuce.core.ClientOptions getOptions()
      指定者:
      getOptions 在接口中 io.lettuce.core.api.StatefulConnection<String,String>

    • getResources

      public io.lettuce.core.resource.ClientResources getResources()
      指定者:
      getResources 在接口中 io.lettuce.core.api.StatefulConnection<String,String>

    • reset

      @Deprecated public void reset()
      已过时。
      指定者:
      reset 在接口中 io.lettuce.core.api.StatefulConnection<String,String>

    • setAutoFlushCommands

      public void setAutoFlushCommands(boolean b)
      指定者:
      setAutoFlushCommands 在接口中 io.lettuce.core.api.StatefulConnection<String,String>

    • flushCommands

      public void flushCommands()
      指定者:
      flushCommands 在接口中 io.lettuce.core.api.StatefulConnection<String,String>

    • addListener

      public void addListener(io.lettuce.core.cluster.api.push.RedisClusterPushListener redisClusterPushListener)
      指定者:
      addListener 在接口中 io.lettuce.core.cluster.pubsub.StatefulRedisClusterPubSubConnection<String,String>

    • removeListener

      public void removeListener(io.lettuce.core.cluster.api.push.RedisClusterPushListener redisClusterPushListener)
      指定者:
      removeListener 在接口中 io.lettuce.core.cluster.pubsub.StatefulRedisClusterPubSubConnection<String,String>

    • addListener

      public void addListener(io.lettuce.core.api.push.PushListener pushListener)
      指定者:
      addListener 在接口中 io.lettuce.core.api.StatefulRedisConnection<String,String>

    • removeListener

      public void removeListener(io.lettuce.core.api.push.PushListener pushListener)
      指定者:
      removeListener 在接口中 io.lettuce.core.api.StatefulRedisConnection<String,String>

    • addListener

      public void addListener(io.lettuce.core.RedisConnectionStateListener redisConnectionStateListener)
      指定者:
      addListener 在接口中 io.lettuce.core.api.StatefulConnection<String,String>

    • removeListener

      public void removeListener(io.lettuce.core.RedisConnectionStateListener redisConnectionStateListener)
      指定者:
      removeListener 在接口中 io.lettuce.core.api.StatefulConnection<String,String>