@ Override public void start ( ) throws Exception { try { reRegisterServices ( ) ; } catch ( KeeperException e ) { log . error ( "Could not register instances - will try again later" , e ) ; } client . getConnectionStateListenable ( ) . addListener ( connectionStateListener ) ; }
The discovery must be started before use