code: public final void connect() {
  		super.connect();
  		List<RedisURI> redisURIs = parseURLs(urls, password, secure);
  		StatefulRedisPubSubConnection<byte[], byte[]> connection;
  		ByteArrayCodec codec = new ByteArrayCodec();
  		if (urls.length > 1) {
  
  			// Clustered client
  			connection = RedisClusterClient.create(resources, redisURIs).connectPubSub(codec);
  
  		} else {
  
  			// Single connection
  			connection = RedisClient.create(resources, redisURIs.get(0)).connectPubSub(codec);
  		}
  
  		// Add listener
  		if (listener != null) {
  			connection.addListener(listener);
  		}
  		client = connection.async();
  	}
docs: --- CONNECT ---