correlation id is a '' / '' separated nested string the first part is the table with tbl = concode_field_sep PlaceHolder placeHolder concode_field_sep Object getCorrelationId concode_elem_sep String constructPathFromCorrelationId concode_elem_sep Stream<Path> getPathStream concode_elem_sep Message<FileMessage> generateMessage concode_elem_sep long getAggregatorTimeout concode_elem_sep Message<Collection<FileMessage>> enrichHeader concode_elem_sep void doneSimulate concode_elem_sep void sendMessage concode_elem_sep boolean isReleaseTriggerMessage concode_elem_sep String getPartition concode_elem_sep String getSource concode_elem_sep boolean isPartition concode_elem_sep void bulkMessageGenerator concode_elem_sep String getSubjectName
String function ( String arg0 ) { String loc0 = isPartition ( arg0 ) ? arg0 . substring ( 0 , arg0 . indexOf ( "srini_string" ) ) : arg0 ; return loc0 . replace ( Constants . CORREL_ID_TABLENAME_LABEL + Constants . CORREL_ID_LABEL_VALUE_SEP , "srini_string" ) ; }