Package org.camunda.bpm.engine.impl.jobexecutor

Class JobExecutorLogger

java.lang.Object

org.camunda.commons.logging.BaseLogger

org.camunda.bpm.engine.impl.ProcessEngineLogger

org.camunda.bpm.engine.impl.jobexecutor.JobExecutorLogger

public class JobExecutorLogger
extends ProcessEngineLogger

Author:

Daniel Meyer

Field Summary

Fields inherited from class org.camunda.bpm.engine.impl.ProcessEngineLogger

ADMIN_PLUGIN_LOGGER, BPMN_BEHAVIOR_LOGGER, BPMN_PARSE_LOGGER, CMD_LOGGER, CMMN_OPERATION_LOGGER, CMMN_TRANSFORMER_LOGGER, CMNN_BEHAVIOR_LOGGER, CONFIG_LOGGER, CONTAINER_INTEGRATION_LOGGER, CONTEXT_LOGGER, CORE_LOGGER, DECISION_LOGGER, EXTERNAL_TASK_LOGGER, INCIDENT_LOGGER, INDENTITY_LOGGER, INSTANCE, JOB_EXECUTOR_LOGGER, METRICS_LOGGER, MIGRATION_LOGGER, PERSISTENCE_LOGGER, PROCESS_APPLICATION_LOGGER, PROJECT_CODE, PVM_LOGGER, SCRIPT_LOGGER, SECURITY_LOGGER, TEST_LOGGER, TX_LOGGER, UTIL_LOGGER

Fields inherited from class org.camunda.commons.logging.BaseLogger

componentId, delegateLogger, projectCode

Constructor Summary

Constructors

Constructor	Description
JobExecutorLogger()

Method Summary

Modifier and Type	Method	Description
void	acquiredJobs(String processEngine, AcquiredJobs acquiredJobs)
void	availableJobExecutionThreads(String processEngine, int numAvailableThreads)
void	availableThreadsCalculationError()
void	couldNotDeterminePriority(ExecutionEntity execution, Object value, ProcessEngineException e)
void	currentJobExecutions(String processEngine, int numExecutions)
void	debugAcquiredJobNotFound(String jobId)
void	debugAddingNewExclusiveJobToJobExecutorCOntext(String jobId)
void	debugDecrementingRetriesForJob(String id)
void	debugFailedJobListenerSkipped(String jobId)
void	debugFailedJobNotFound(String jobId)
void	debugFallbackToDefaultRetryStrategy()
void	debugInitiallyAppyingRetryCycleForJob(String id, int times)
void	debugJobAcquisitionThreadSleeping(long millis)
void	debugNotifyingJobExecutor(String string)
void	exceptionDuringJobAcquisition(Exception e)
void	exceptionWhileExecutingJob(String nextJobId, Throwable t)
void	exceptionWhileExecutingJob(JobEntity job, Throwable exception)
void	exceptionWhileParsingExpression(String jobId, String exceptionMessage)
void	exceptionWhileUnlockingJob(String jobId, Throwable t)
void	executeJobs(String processEngine, Collection<String> jobs)
void	failedAcquisitionLocks(String processEngine, AcquiredJobs acquiredJobs)
void	ignoringSuspendedJob(ProcessDefinition processDefinition)
void	infoJobExecutorDoesNotHandleBatchJobs(ProcessEngineConfigurationImpl config)
void	infoJobExecutorDoesNotHandleHistoryCleanupJobs(ProcessEngineConfigurationImpl config)
void	interruptedWhileShuttingDownjobExecutor(InterruptedException e)
void	jobExecutionWaitInterrupted()
ProcessEngineException	jobExecutorPriorityRangeException(String reason)
void	jobExecutorThreadWokeUp()
ProcessEngineException	jobNotFoundException(String jobId)
void	jobsToAcquire(String processEngine, int numJobsToAcquire)
void	numJobsInQueue(String processEngine, int numJobsInQueue, int maxQueueSize)
void	rejectedJobExecutions(String processEngine, int numJobsRejected)
void	shuttingDownTheJobExecutor(String name)
void	startingToAcquireJobs(String name)
void	startingUpJobExecutor(String name)
void	stoppedJobAcquisition(String name)
void	timeoutDuringShutdown()
void	totalQueueCapacityCalculationError()
void	warnHistoryCleanupBatchWindowNotFound()
ProcessEngineException	wrapJobExecutionFailure(JobFailureCollector jobFailureCollector, Throwable cause)

Methods inherited from class org.camunda.bpm.engine.impl.ProcessEngineLogger

couldNotDetermineIp, exceptionWhileClosingProcessEngine, exceptionWhileInitializingProcessengine, historyCleanupJobReconfigurationFailure, initializingProcessEngine, initializingProcessEngineForResource, processEngineAlreadyInitialized, processEngineClosed, processEngineCreated, shouldLogCmdException, shouldLogJobException

Methods inherited from class org.camunda.commons.logging.BaseLogger

createLogger, exceptionMessage, formatMessageTemplate, isDebugEnabled, isErrorEnabled, isInfoEnabled, isWarnEnabled, log, log, logDebug, logError, logInfo, logTrace, logWarn

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

JobExecutorLogger

public JobExecutorLogger()

Method Details

debugAcquiredJobNotFound

public void debugAcquiredJobNotFound(String jobId)

exceptionWhileExecutingJob

public void exceptionWhileExecutingJob(JobEntity job,
 Throwable exception)

debugFallbackToDefaultRetryStrategy

public void debugFallbackToDefaultRetryStrategy()

debugDecrementingRetriesForJob

public void debugDecrementingRetriesForJob(String id)

debugInitiallyAppyingRetryCycleForJob

public void debugInitiallyAppyingRetryCycleForJob(String id,
 int times)

exceptionWhileExecutingJob

public void exceptionWhileExecutingJob(String nextJobId,
 Throwable t)

couldNotDeterminePriority

public void couldNotDeterminePriority(ExecutionEntity execution,
 Object value,
 ProcessEngineException e)

debugAddingNewExclusiveJobToJobExecutorCOntext

public void debugAddingNewExclusiveJobToJobExecutorCOntext(String jobId)

timeoutDuringShutdown

public void timeoutDuringShutdown()

interruptedWhileShuttingDownjobExecutor

public void interruptedWhileShuttingDownjobExecutor(InterruptedException e)

debugJobAcquisitionThreadSleeping

public void debugJobAcquisitionThreadSleeping(long millis)

jobExecutorThreadWokeUp

public void jobExecutorThreadWokeUp()

jobExecutionWaitInterrupted

public void jobExecutionWaitInterrupted()

startingUpJobExecutor

public void startingUpJobExecutor(String name)

shuttingDownTheJobExecutor

public void shuttingDownTheJobExecutor(String name)

ignoringSuspendedJob

public void ignoringSuspendedJob(ProcessDefinition processDefinition)

debugNotifyingJobExecutor

public void debugNotifyingJobExecutor(String string)

startingToAcquireJobs

public void startingToAcquireJobs(String name)

exceptionDuringJobAcquisition

public void exceptionDuringJobAcquisition(Exception e)

stoppedJobAcquisition

public void stoppedJobAcquisition(String name)

exceptionWhileUnlockingJob

public void exceptionWhileUnlockingJob(String jobId,
 Throwable t)

acquiredJobs

public void acquiredJobs(String processEngine,
 AcquiredJobs acquiredJobs)

executeJobs

public void executeJobs(String processEngine,
 Collection<String> jobs)

debugFailedJobNotFound

public void debugFailedJobNotFound(String jobId)

wrapJobExecutionFailure

public ProcessEngineException wrapJobExecutionFailure(JobFailureCollector jobFailureCollector,
 Throwable cause)

jobNotFoundException

public ProcessEngineException jobNotFoundException(String jobId)

exceptionWhileParsingExpression

public void exceptionWhileParsingExpression(String jobId,
 String exceptionMessage)

warnHistoryCleanupBatchWindowNotFound

public void warnHistoryCleanupBatchWindowNotFound()

infoJobExecutorDoesNotHandleHistoryCleanupJobs

public void infoJobExecutorDoesNotHandleHistoryCleanupJobs(ProcessEngineConfigurationImpl config)

infoJobExecutorDoesNotHandleBatchJobs

public void infoJobExecutorDoesNotHandleBatchJobs(ProcessEngineConfigurationImpl config)

debugFailedJobListenerSkipped

public void debugFailedJobListenerSkipped(String jobId)

jobExecutorPriorityRangeException

public ProcessEngineException jobExecutorPriorityRangeException(String reason)

failedAcquisitionLocks

public void failedAcquisitionLocks(String processEngine,
 AcquiredJobs acquiredJobs)

jobsToAcquire

public void jobsToAcquire(String processEngine,
 int numJobsToAcquire)

rejectedJobExecutions

public void rejectedJobExecutions(String processEngine,
 int numJobsRejected)

availableJobExecutionThreads

public void availableJobExecutionThreads(String processEngine,
 int numAvailableThreads)

currentJobExecutions

public void currentJobExecutions(String processEngine,
 int numExecutions)

numJobsInQueue

public void numJobsInQueue(String processEngine,
 int numJobsInQueue,
 int maxQueueSize)

availableThreadsCalculationError

public void availableThreadsCalculationError()

totalQueueCapacityCalculationError

public void totalQueueCapacityCalculationError()