start producing messages concode_field_sep ZooKeeper zk concode_elem_sep Mutex mutex concode_elem_sep int numMessages concode_elem_sep String messagePrefix concode_elem_sep int myId concode_elem_sep int messageId concode_elem_sep String messageData concode_elem_sep String qRoot concode_elem_sep int id concode_field_sep void run
void function ( ) { for ( int loc0 = 0 ; loc0 < numMessages ; loc0 ++ ) { try { zk . create ( qRoot + messagePrefix + messageId , messageData . getBytes ( ) , ZooDefs . Ids . OPEN_ACL_UNSAFE , CreateMode . PERSISTENT ) ; } catch ( InterruptedException loc1 ) { } catch ( KeeperException loc1 ) { } messageId ++ ; } }