code: public StatefulRedisPubSubConnection<String, String> connectPubSub(RedisURI redisURI) {
  
          assertNotNull(redisURI);
          return getConnection(connectPubSubAsync(newStringStringCodec(), redisURI, redisURI.getTimeout()));
      }
docs: Open a new pub/sub connection to a Redis server using the supplied {@link RedisURI} that treats keys and values as UTF-8
  strings.
  
  @param redisURI the Redis server to connect to, must not be {@literal null}
  @return A new stateful pub/sub connection