private void scheduleMsgForAllConsumers(JetstreamMessage msg){
  if (LOGGER.isDebugEnabled())   LOGGER.debug("Spraying message - " + msg.toString());
  EventConsumerInfo info=null;
  ArrayList<LinkedList<Selection>> weightedList=m_eventTopicRegistry.get(msg.getTopic());
  if (weightedList != null) {
    Iterator<LinkedList<Selection>> weightedItr=weightedList.iterator();
    while (weightedItr.hasNext()) {
      LinkedList<Selection> consumerList=weightedItr.next();
      Iterator<Selection> itr=consumerList.iterator();
      while (itr.hasNext()) {
        info=(EventConsumerInfo)itr.next();
        if (info == null)         continue;
        dispatch(info,msg);
      }
    }
  }
 else {
    if (m_advisoryListener != null) {
      postResendAdvisory(msg);
      m_noConsumerAdvisories.increment();
    }
 else {
      m_totalMsgsDropped.increment();
      m_dropsForNoConsumer.increment();
    }
  }
}

private void scheduleMsgForAllConsumers ( JetstreamMessage msg ) { if ( LOGGER . isDebugEnabled ( ) ) LOGGER . debug ( "Spraying message - " + msg . toString ( ) ) ; EventConsumerInfo info = null ; ArrayList < LinkedList < Selection > > weightedList = m_eventTopicRegistry . get ( msg . getTopic ( ) ) ; if ( weightedList != null ) { Iterator < LinkedList < Selection > > weightedItr = weightedList . iterator ( ) ; while ( weightedItr . hasNext ( ) ) { LinkedList < Selection > consumerList = weightedItr . next ( ) ; Iterator < Selection > itr = consumerList . iterator ( ) ; while ( itr . hasNext ( ) ) { info = ( EventConsumerInfo ) itr . next ( ) ; if ( info == null ) continue ; dispatch ( info , msg ) ; } } } else { if ( m_advisoryListener != null ) { postResendAdvisory ( msg ) ; m_noConsumerAdvisories . increment ( ) ; } else { m_totalMsgsDropped . increment ( ) ; m_dropsForNoConsumer . increment ( ) ; } } }
spraytoallconsumers - this method is called when the message is tagged for spraying to all consumers .
