void function ( Ignite arg0 ) { final String loc0 = queue . name ( ) ; arg0 . compute ( ) . broadcast ( new QueueClosure ( loc0 , false ) ) ; System . out . println ( "srini_string" + queue . size ( ) + ']' ) ; }
read items from head and tail of queue . concode_field_sep String queueName concode_elem_sep int RETRIES concode_elem_sep IgniteQueue<String> queue concode_elem_sep boolean put concode_field_sep IgniteQueue<String> initializeQueue concode_elem_sep void writeToQueue concode_elem_sep void clearAndRemoveQueue concode_elem_sep void main concode_elem_sep void run