程序包 com.cdkjframework.redis.realize

类 RedisPubSubConnection

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

  • 构造器详细资料

    • RedisPubSubConnection

      public RedisPubSubConnection()

  • 方法详细资料

    • isMulti

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

    • sync

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

    • async

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

    • reactive

      public io.lettuce.core.pubsub.api.reactive.RedisPubSubReactiveCommands<String,String> reactive()
      指定者:
      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>

    • 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.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>