docs: protected void connectionClosed(IoSession session) {
  		this.connected = false;
  		this._disconnect();
  		log.info("Connection lost to aggregator at {}:{}", this.host,
  				Integer.valueOf(this.port));
  
  		while (this.stayConnected) {
  			try {
  				Thread.sleep(this.connectionRetryDelay);
  			} catch (InterruptedException ie) {
  				// Ignored
  			}
  			log.warn("Reconnecting to aggregator at {}:{}", this.host,
  					Integer.valueOf(this.port));
  			if (this.connect(this.connectionTimeout)) {
  				return;
  			}
  			log.warn("Failed to reconnect to aggregator at {}:{}", this.host,
  					Integer.valueOf(this.port));
  
  		}
  		this.finishConnection();
  
  	}