src/main/java/com/aws/iot/edgeconnectorforkvs/scheduler/StartJob.java [95:100]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public void execute(JobExecutionContext context)
            throws JobExecutionException {
        JobKey jobKey = context.getJobDetail().getKey();
        JobDataMap jobDataMap = context.getJobDetail().getJobDataMap();
        String streamName = (String) jobDataMap.get(JOB_STREAM_NAME_KEY);
        Constants.JobType jobType = (Constants.JobType) jobDataMap.get(JOB_TYPE_KEY);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/main/java/com/aws/iot/edgeconnectorforkvs/scheduler/StopJob.java [55:60]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public void execute(JobExecutionContext context)
            throws JobExecutionException {
        JobKey jobKey = context.getJobDetail().getKey();
        JobDataMap jobDataMap = context.getJobDetail().getJobDataMap();
        String streamName = (String) jobDataMap.get(JOB_STREAM_NAME_KEY);
        Constants.JobType jobType = (Constants.JobType) jobDataMap.get(JOB_TYPE_KEY);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -