public void run()

in streams-contrib/streams-provider-rss/src/main/java/org/apache/streams/rss/provider/RssEventProcessor.java [82:116]

28 lines of code
10 McCabe index (conditional complexity)


  public void run() {

    while (true) {
      Object item;
      try {
        item = inQueue.poll();
        if (item instanceof String && item.equals(TERMINATE)) {
          LOGGER.info("Terminating!");
          break;
        }

        Thread.sleep(new Random().nextInt(100));

        // if the target is string, just pass-through
        if ( String.class.equals(outClass)) {
          outQueue.offer(new StreamsDatum(item.toString()));
        } else if ( SyndEntry.class.equals(outClass)) {
          outQueue.offer(new StreamsDatum(item));
        } else if ( Activity.class.equals(outClass)) {
          // convert to desired format
          SyndEntry entry = (SyndEntry)item;
          if ( entry != null ) {
            Activity out = syndEntryActivitySerializer.deserialize(this.syndEntrySerializer.deserialize((SyndEntry)item));

            if ( out != null ) {
              outQueue.offer(new StreamsDatum(out));
            }
          }
        }

      } catch (Exception ex) {
        ex.printStackTrace();
      }
    }
  }