@Override public void incomingObject(IAnalyzedInterval analyzedInterval) throws AdeException {
  for (  IAnalyzedMessageSummary ams : analyzedInterval.getAnalyzedMessages()) {
    final String id=ams.getMessageId();
    MsgData data=m_msgData.get(id);
    if (data == null) {
      data=new MsgData();
      m_msgData.put(id,data);
    }
    if (!isClustered(ams)) {
      data.m_totalLogCounts+=Math.log(ams.getNumberOfAppearances());
      data.m_intervalCount++;
    }
    data.m_allCount+=ams.getNumberOfAppearances();
    data.m_intervalAllCount++;
    if (data.m_maxNumAppearance < ams.getNumberOfAppearances()) {
      data.m_maxNumAppearance=ams.getNumberOfAppearances();
    }
  }
  ++m_totalIntervalCount;
}

@ Override public void incomingObject ( IAnalyzedInterval analyzedInterval ) throws AdeException { for ( IAnalyzedMessageSummary ams : analyzedInterval . getAnalyzedMessages ( ) ) { final String id = ams . getMessageId ( ) ; MsgData data = m_msgData . get ( id ) ; if ( data == null ) { data = new MsgData ( ) ; m_msgData . put ( id , data ) ; } if ( ! isClustered ( ams ) ) { data . m_totalLogCounts += Math . log ( ams . getNumberOfAppearances ( ) ) ; data . m_intervalCount ++ ; } data . m_allCount += ams . getNumberOfAppearances ( ) ; data . m_intervalAllCount ++ ; if ( data . m_maxNumAppearance < ams . getNumberOfAppearances ( ) ) { data . m_maxNumAppearance = ams . getNumberOfAppearances ( ) ; } } ++ m_totalIntervalCount ; }
create msgdata objects for each message id in an analyzed interval . if the message is not in a cluster , then we add to the total log value of the number of messages in an interval , and interval count . for all messages , we keep track of the total number of message instances , and the max number of appearances this message instance has appeared over all intervals .
