code: @Override
  	public void connect() {
  		if (clientSub != null || clientPub != null) {
  			disconnect();
  		}
  		status.set(STATUS_CONNECTING_1);
  
  		// Create redis clients
  		clientSub = new RedisPubSubClient(urls, password, secure, executor, this, this);
  		clientPub = new RedisPubSubClient(urls, password, secure, executor, this, null);
  
  		// Connect sub
  		try {
  			clientSub.connect();
  		} catch (Exception cause) {
  			unableToConnect(cause);
  			return;
  		}
  
  		// Connect pub
  		try {
  			clientPub.connect();
  		} catch (Exception cause) {
  			unableToConnect(cause);
  		}
  	}
docs: --- CONNECT ---