protected void initReceiveMessages ( ) throws IOException { messageThread = new Thread ( ( ) -> { while ( ! Thread . interrupted ( ) ) { receiveMessages ( ) ; } } ) ; messageThread . setName ( "OrientDB_DistributedDiscoveryThread" ) ; messageThread . setDaemon ( true ) ; messageThread . start ( ) ; }
inits the procedure that listens to pings from other servers eg . that discovers other nodes in the network