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.impl;
 
 import java.util.List;
 
 
 
 
 
 	private final static String sourceClass = BatchletStepControllerImpl.class.getName();
 	private final static Logger logger = Logger.getLogger();
 
 
 	public BatchletStepControllerImpl(RuntimeJobExecution jobExecutionImplStep stepStepContextImpl stepContextlong rootJobExecutionIdBlockingQueue<PartitionDataWrapperanalyzerStatusQueue) {
 		super(jobExecutionImplstepstepContextrootJobExecutionIdanalyzerStatusQueue);
 	}
 
 	private void invokeBatchlet(Batchlet batchletthrows BatchContainerServiceException {
 
 		String batchletId = batchlet.getRef();
 		List<PropertypropList = (batchlet.getProperties() == null) ? null : batchlet.getProperties().getPropertyList();
 
 		String sourceMethod = "invokeBatchlet";
 			.entering(sourceMethodbatchletId);
 		}
 
 		String exitStatus = null;
 
 				propList);
 
 		try {
 			 = ProxyFactory.createBatchletProxy(batchletIdinjectionRef);
 		} catch (ArtifactValidationException e) {
 			throw new BatchContainerServiceException("Cannot create the batchlet [" + batchletId + "]"e);
 		}
 
 			.fine("Batchlet is loaded and validated: " + );
 
 
 		} else {
 
 			String processRetVal = .process();
 
 			.fine("Set process() return value = " + processRetVal + " for possible use as exitStatus");
 
 			.exiting(sourceMethodexitStatus==null ? "<null>" : exitStatus);
 		}
 	}
 
 	protected void invokeCoreStep() throws BatchContainerServiceException {
 
 		//TODO If this step is partitioned create partition artifacts
 		Partition partition = .getPartition();
 		if (partition != null) {
 			//partition.getConcurrencyElements();
 		}
 		try {
 		} finally {
		}
	}
	public synchronized void stop() { 
			if ( != null) {
			}
else {
			//TODO do we need to throw an error if the batchlet is already stopping/stopped
			//a stop gets issued twice
		}
	}
New to GrepCode? Check out our FAQ X