void dispatchDownStream(JetstreamMessage msg) throws Exception {
  if (msg == null) {
    throw new Exception("Null object being passed in");
  }
  if (m_scheduler.supportsAffinity()) {
    scheduleMsgForEventConsumerWithAffinity(msg);
  }
 else   if (msg.broadcast())   scheduleMsgForAllConsumers(msg);
 else   scheduleMsgForLoadBalancedEventConsumer(msg);
}

void dispatchDownStream ( JetstreamMessage msg ) throws Exception { if ( msg == null ) { throw new Exception ( "Null object being passed in" ) ; } if ( m_scheduler . supportsAffinity ( ) ) { scheduleMsgForEventConsumerWithAffinity ( msg ) ; } else if ( msg . broadcast ( ) ) scheduleMsgForAllConsumers ( msg ) ; else scheduleMsgForLoadBalancedEventConsumer ( msg ) ; }
dispatch the marshalled object dowstream to to the mina layer to be sent across on the iosession determined after executing the lb algorithm . we might want to queue the object so that it can be resent in case mina reports a problem .
