Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
Copyright 2012 International Business Machines Corp. See the NOTICE file distributed with this work for additional information regarding copyright ownership. Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
 
 package com.ibm.jbatch.container.util;
 
 import java.util.List;
 
 
 
 /*
  * I took out the 'work type' constant since I don't see that we want to use
  * the same thread pool for start requests as we'd use for stop requests.
  * The stop seems like it should be synchronous from the JobOperator's
  * perspective, as it returns a 'success' boolean.
  */
 public class BatchWorkUnit implements Runnable {
 
 	private String CLASSNAME = BatchWorkUnit.class.getName();
 	private Logger logger = Logger.getLogger(BatchWorkUnit.class.getPackage().getName());
 
 	private IBatchKernelService batchKernel = null;
 	private final JobControllerImpl controller;
 
 	private boolean notifyCallbackWhenDone;
 	
 	private List<Stringcontainment = null;
 
 	public BatchWorkUnit(IBatchKernelService batchKernelRuntimeJobExecutionHelper jobExecutionImpl) {
 		this(batchKerneljobExecutionImplnullnullnullnulltrue);
 	}
 
     public BatchWorkUnit(IBatchKernelService batchKernelRuntimeJobExecutionHelper jobExecutionImpl,
             BlockingQueue<PartitionDataWrapperanalyzerQueueStack<StringsubJobExitStatusQueue,
             BlockingQueue<BatchWorkUnitcompletedThreadQueueList<Stringcontainment,
             boolean notifyCallbackWhenDone) {
         this.setBatchKernel(batchKernel);
         this.setJobExecutionImpl(jobExecutionImpl);
         this.setAnalyzerQueue(analyzerQueue);
         this.setSubJobExitStatus(subJobExitStatusQueue);
         this.setCompletedThreadQueue(completedThreadQueue);
         this.setNotifyCallbackWhenDone(notifyCallbackWhenDone);
         this.setContainment(containment);
 
          = new JobControllerImpl(this.getJobExecutionImpl(), this.);
         .setSubJobExitStatusQueue(subJobExitStatusQueue);
 
     }
 
 		return this.;
 	}
 
 	public void run() {
 		String method = "run";
 		}
 
 			.fine("==========================================================");
 			.fine("Invoking executeJob on JobController; " + "JobInstance id=" + getJobExecutionImpl().getInstanceId()
 					+ ", executionId=" + getJobExecutionImpl().getExecutionId());
 			.fine("==========================================================");
 		}
 
 
 
 
 		try {
 		} catch (Exception e) {
				.fine("Exception when invoking executeJob on JobController; " + "JobInstance id="
				.fine("Job Batch Status = " + getBatchStatus() + ";  Job Exit Status = "
			}
			}
	        if (this. != null) {
	            .add(this);
	        }
			throw new BatchContainerRuntimeException("This job failed unexpectedly."e);
			.fine("==========================================================");
			.fine("Done invoking executeJob on JobController; " + "JobInstance id=" + getJobExecutionImpl().getInstanceId()
", executionId=" + getJobExecutionImpl().getExecutionId());
			.fine("Job Batch Status = " + getBatchStatus() + ";  Job Exit Status = "
			.fine("==========================================================");
		}
		}
        if (this. != null) {
            .add(this);
        }
		}
	}
	}
	private String getExitStatus() {
	}
	public void setBatchKernel(IBatchKernelService batchKernel) {
		this. = batchKernel;
	}
		return ;
	}
	public void setJobExecutionImpl(RuntimeJobExecutionHelper jobExecutionImpl) {
		this. = jobExecutionImpl;
	}
	}
	public void setNotifyCallbackWhenDone(boolean notifyCallbackWhenDone) {
		this. = notifyCallbackWhenDone;
	}
	public boolean isNotifyCallbackWhenDone() {
	}
        return ;
    }
    public void setAnalyzerQueue(BlockingQueue<PartitionDataWrapperanalyzerQueue) {
        this. = analyzerQueue;
    }
    
        return ;
    }
    public void setSubJobExitStatus(Stack<StringsubJobExitStatusQueue2) {
        this. = subJobExitStatusQueue2;
    }
        return ;
    }
    public void setCompletedThreadQueue(BlockingQueue<BatchWorkUnitcompletedThreadQueue) {
        this. = completedThreadQueue;
    }
    public List<StringgetContainment() {
        return ;
    }
    public void setContainment(List<Stringcontainment) {
        this. = containment;
    }
New to GrepCode? Check out our FAQ X