public void send(JetstreamMessage msg) throws Exception {
  if (msg == null) {
    throw new Exception("Null object being passed in");
  }
  Request req=new ZKSendMessageRequest(this,msg);
  if (!m_requestQueue.offer(req))   LOGGER.warn("Request Queue is Full..");
}

public void send ( JetstreamMessage msg ) throws Exception { if ( msg == null ) { throw new Exception ( "Null object being passed in" ) ; } Request req = new ZKSendMessageRequest ( this , msg ) ; if ( ! m_requestQueue . offer ( req ) ) LOGGER . warn ( "Request Queue is Full.." ) ; }
send message to groups via zk
