code: @Override
  	public void publish(Event event) {
  
  		// Connected
  		if (event instanceof ConnectedEvent) {
  			if (status.compareAndSet(STATUS_CONNECTING_1, STATUS_CONNECTING_2)) {
  
  				// First connection is Ok
  				return;
  			}
  			if (status.compareAndSet(STATUS_CONNECTING_2, STATUS_CONNECTED)) {
  
  				// Second connection is Ok
  				logger.info("All Redis pub-sub connections estabilished.");
  				connected(false);
  			}
  			return;
  		}
  
  		// Disconnected
  		if (event instanceof DisconnectedEvent) {
  			int s = status.getAndSet(STATUS_DISCONNECTED);
  			if (s != STATUS_DISCONNECTED && s != STATUS_DISCONNECTING) {
  				logger.info("Redis pub-sub connection aborted.");
  				reconnect();
  			}
  		}
  
  	}
docs: --- REDIS EVENT LISTENER METHODS ---