public void registerTopic(JetstreamTopic topic){
  if (!m_registeredTopics.contains(topic))   m_registeredTopics.add(topic);
  LOGGER.info("Register Topic :: " + topic.getTopicName());
  Request registerReq=new WatchTopicRequest(this,m_zkhandle,topic);
  if (!m_requestQueue.offer(registerReq))   LOGGER.warn("Request Queue is Full..");
}

public void registerTopic ( JetstreamTopic topic ) { if ( ! m_registeredTopics . contains ( topic ) ) m_registeredTopics . add ( topic ) ; LOGGER . info ( "Register Topic :: " + topic . getTopicName ( ) ) ; Request registerReq = new WatchTopicRequest ( this , m_zkhandle , topic ) ; if ( ! m_requestQueue . offer ( registerReq ) ) LOGGER . warn ( "Request Queue is Full.." ) ; }
registering the topic name to transport . each topic will be created as a znode in zk . watch is also set after creating the node to receive notifications .
