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 ( ) ; }
Called when the connection to the aggregator closes .