uima-ducc-container/src/main/java/org/apache/uima/ducc/container/jd/fsm/wi/ActionProcessPreempt.java [60:106]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
	public void engage(Object objectData) {
		String location = "engage";
		logger.trace(location, ILogger.null_id, "");
		IActionData actionData = (IActionData) objectData;
		try {
			if(actionData != null) {
				IWorkItem wi = actionData.getWorkItem();
				IMetaTask metaCas = wi.getMetaCas();
				JobDriver jd = JobDriver.getInstance();
				CasManager cm = jd.getCasManager();
				WiTracker tracker = WiTracker.getInstance();
				IRemoteWorkerProcess rwp = tracker.getRemoteWorkerProcess(wi);
				JobDriverHelper jdh = JobDriverHelper.getInstance();
				if(rwp != null) {
					if(metaCas != null) {
						recallWorkItem(actionData, cm, metaCas, wi);
						IWorkItemStateKeeper wisk = jd.getWorkItemStateKeeper();
						MetaCasHelper metaCasHelper = new MetaCasHelper(metaCas);
						IProcessStatistics pStats = jdh.getProcessStatistics(rwp);
						int seqNo = metaCasHelper.getSystemKey();
						wisk.preempt(seqNo);
						pStats.preempt(wi);
						displayProcessStatistics(logger, actionData, wi, pStats);
						wi.reset();
					}
					else {
						MessageBuffer mb = LoggerHelper.getMessageBuffer(actionData);
						mb.append("No CAS found for processing");
						logger.info(location, ILogger.null_id, mb.toString());
					}
				}
				else {
					MessageBuffer mb = LoggerHelper.getMessageBuffer(actionData);
					mb.append("No remote worker process entry found for processing");
					logger.info(location, ILogger.null_id, mb.toString());
				}
			}
			else {
				MessageBuffer mb = LoggerHelper.getMessageBuffer(actionData);
				mb.append("No action data found for processing");
				logger.warn(location, ILogger.null_id, mb.toString());
			}
		}
		catch(Exception e) {
			logger.error(location, ILogger.null_id, e);
		}
	}
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



uima-ducc-container/src/main/java/org/apache/uima/ducc/container/jd/fsm/wi/ActionProcessVolunteered.java [60:106]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
	public void engage(Object objectData) {
		String location = "engage";
		logger.trace(location, ILogger.null_id, "");
		IActionData actionData = (IActionData) objectData;
		try {
			if(actionData != null) {
				IWorkItem wi = actionData.getWorkItem();
				IMetaTask metaCas = wi.getMetaCas();
				JobDriver jd = JobDriver.getInstance();
				CasManager cm = jd.getCasManager();
				WiTracker tracker = WiTracker.getInstance();
				IRemoteWorkerProcess rwp = tracker.getRemoteWorkerProcess(wi);
				JobDriverHelper jdh = JobDriverHelper.getInstance();
				if(rwp != null) {
					if(metaCas != null) {
						recallWorkItem(actionData, cm, metaCas, wi);
						IWorkItemStateKeeper wisk = jd.getWorkItemStateKeeper();
						MetaCasHelper metaCasHelper = new MetaCasHelper(metaCas);
						IProcessStatistics pStats = jdh.getProcessStatistics(rwp);
						int seqNo = metaCasHelper.getSystemKey();
						wisk.preempt(seqNo);
						pStats.preempt(wi);
						displayProcessStatistics(logger, actionData, wi, pStats);
						wi.reset();
					}
					else {
						MessageBuffer mb = LoggerHelper.getMessageBuffer(actionData);
						mb.append("No CAS found for processing");
						logger.info(location, ILogger.null_id, mb.toString());
					}
				}
				else {
					MessageBuffer mb = LoggerHelper.getMessageBuffer(actionData);
					mb.append("No remote worker process entry found for processing");
					logger.info(location, ILogger.null_id, mb.toString());
				}
			}
			else {
				MessageBuffer mb = LoggerHelper.getMessageBuffer(actionData);
				mb.append("No action data found for processing");
				logger.warn(location, ILogger.null_id, mb.toString());
			}
		}
		catch(Exception e) {
			logger.error(location, ILogger.null_id, e);
		}
	}
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -