void function ( IgniteMessaging arg0 , final CountDownLatch arg1 , final CountDownLatch arg2 ) { arg0 . localListen ( TOPIC . ORDERED , ( nodeId , msg ) -> { arg1 . countDown ( ) ; return arg1 . getCount ( ) > 0 ; } ) ; arg0 . localListen ( TOPIC . UNORDERED , ( nodeId , msg ) -> { arg2 . countDown ( ) ; return arg2 . getCount ( ) > 0 ; } ) ; }
listen for messages from remote nodes . concode_field_sep int MESSAGES_NUM concode_field_sep void startListening concode_elem_sep void main