question: 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 ( ) ; } } }
target:  sprayToAllConsumers - this method is called when the message is tagged for spraying to all consumers.