void function ( String arg0 ) { onFailure ( arg0 , new NotMasterException ( "srini_string" + arg0 + "srini_string" ) ) ; }
called when the task was rejected because the local node is no longer master concode_field_sep PlaceHolder placeHolder concode_field_sep void clusterStateProcessed concode_elem_sep void onFailure