@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());
  }
}

@ 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 ( ) ) ; } }
thread processing of the syndication feeds
