public SetChangelogMapping(String source,String taskName,int changelogPartitionNumber){
  super(source);
  setType(TYPE);
  setKey(taskName);
  putMessageValue(CHANGELOG_VALUE_KEY,String.valueOf(changelogPartitionNumber));
}

public SetChangelogMapping ( String source , String taskName , int changelogPartitionNumber ) { super ( source ) ; setType ( TYPE ) ; setKey ( taskName ) ; putMessageValue ( CHANGELOG_VALUE_KEY , String . valueOf ( changelogPartitionNumber ) ) ; }
the change log mapping message is used to store changelog partition information for a given task name .
