question: @ Override public void run ( ) { try { while ( true ) { InputStreamReader isr = null ; try { isr = new InputStreamReader ( getFeedInputStream ( ) ) ; SyndFeedInput feedInput = new SyndFeedInput ( ) ; SyndFeed feed = feedInput . build ( isr ) ; List entries = feed . getEntries ( ) ; List < RomeFeedEntry > nfeedItems = new ArrayList < RomeFeedEntry > ( ) ; boolean oldEntries = false ; for ( int i = 0 ; i < entries . size ( ) ; ++ i ) { SyndEntry syndEntry = ( SyndEntry ) entries . get ( i ) ; RomeFeedEntry romeFeedEntry = getSerializableEntry ( syndEntry ) ; if ( ! oldEntries ) { if ( ! feedItems . contains ( romeFeedEntry ) ) { outputPort . emit ( romeFeedEntry ) ; } else if ( orderedUpdate ) { oldEntries = true ; } } nfeedItems . add ( romeFeedEntry ) ; } feedItems = nfeedItems ; } catch ( Exception e ) { logger . error ( e . getMessage ( ) ) ; } finally { if ( isr != null ) { try { isr . close ( ) ; } catch ( Exception ce ) { logger . error ( ce . getMessage ( ) ) ; } } } Thread . sleep ( interval ) ; } } catch ( InterruptedException ie ) { logger . error ( "Interrupted: " + ie . getMessage ( ) ) ; } }
target:  Thread processing of the syndication feeds