@SuppressWarnings("unchecked") protected void notify(Mx1Message m,Mx1Listener replyTo){
  Vector<Mx1Listener> v;
synchronized (this) {
    v=(Vector<Mx1Listener>)listeners.clone();
  }
  if (log.isDebugEnabled()) {
    log.debug("notify of incoming packet: " + m.toString());
  }
  int cnt=v.size();
  for (int i=0; i < cnt; i++) {
    Mx1Listener client=listeners.elementAt(i);
    if (client != replyTo) {
      client.message(m);
    }
  }
}

@ SuppressWarnings ( "unchecked" ) protected void notify ( Mx1Message m , Mx1Listener replyTo ) { Vector < Mx1Listener > v ; synchronized ( this ) { v = ( Vector < Mx1Listener > ) listeners . clone ( ) ; } if ( log . isDebugEnabled ( ) ) { log . debug ( "notify of incoming packet: " + m . toString ( ) ) ; } int cnt = v . size ( ) ; for ( int i = 0 ; i < cnt ; i ++ ) { Mx1Listener client = listeners . elementAt ( i ) ; if ( client != replyTo ) { client . message ( m ) ; } } }
forward a message to all registered listeners .
