void discoverEventConsumers(){
  printInfo("sending discover message");
  EventConsumerDiscover ecd=new EventConsumerDiscover(m_context,m_hostName);
  ecd.setPriority(JetstreamMessage.INTERNAL_MSG_PRIORITY);
  try {
    m_messageServiceProxy.publish(m_ecdiscover,ecd,this);
  }
 catch (  Exception e) {
    String message="Failed to publish EventConsumerDiscover message - ";
    message+=" Caught Exception ";
    message+=e.getMessage();
    LOGGER.error(message);
  }
}

void discoverEventConsumers ( ) { printInfo ( "sending discover message" ) ; EventConsumerDiscover ecd = new EventConsumerDiscover ( m_context , m_hostName ) ; ecd . setPriority ( JetstreamMessage . INTERNAL_MSG_PRIORITY ) ; try { m_messageServiceProxy . publish ( m_ecdiscover , ecd , this ) ; } catch ( Exception e ) { String message = "Failed to publish EventConsumerDiscover message - " ; message += " Caught Exception " ; message += e . getMessage ( ) ; LOGGER . error ( message ) ; } }
post a discovereventconsumers message
