org.camunda.bpm.engine.rest.impl

Class FetchAndLockHandlerImpl

java.lang.Object

org.camunda.bpm.engine.rest.impl.FetchAndLockHandlerImpl

All Implemented Interfaces:

Runnable, FetchAndLockHandler

public class FetchAndLockHandlerImpl
extends Object
implements Runnable, FetchAndLockHandler

Author:

Tassilo Weidner

Field Summary

Fields

Modifier and Type	Field and Description
protected Thread	handlerThread
protected static Condition	IS_EXTERNAL_TASK_AVAILABLE
protected boolean	isRunning
protected boolean	isWaiting
protected static ReentrantLock	LOCK_MONITOR
protected static long	MAX_BACK_OFF_TIME
protected static long	MAX_TIMEOUT
protected List<FetchAndLockRequest>	pendingRequests
protected BlockingQueue<FetchAndLockRequest>	queue

Constructor Summary

Constructors

Constructor and Description
FetchAndLockHandlerImpl()

Method Summary

Methods

Modifier and Type	Method and Description
protected void	acquire()
void	addPendingRequest(FetchExternalTasksExtendedDto dto, javax.ws.rs.container.AsyncResponse asyncResponse, ProcessEngine processEngine) Invoked if a fetch and lock request has been sent by the client
protected void	addRequest(FetchAndLockRequest request)
protected void	errorTooManyRequests(javax.ws.rs.container.AsyncResponse asyncResponse)
protected List<LockedExternalTaskDto>	executeFetchAndLock(FetchExternalTasksExtendedDto fetchingDto, ProcessEngine processEngine)
List<FetchAndLockRequest>	getPendingRequests()
protected void	invalidRequest(javax.ws.rs.container.AsyncResponse asyncResponse, String message)
protected void	notifyAcquisition()
protected void	rejectPendingRequests()
void	run()
void	shutdown() Receives a notification that the engine rest web application is about to be shut down
void	start() Receives a notification that the engine rest web application initialization has been started
protected void	suspend(long millis)
protected void	suspendAcquisition(long millis)
protected FetchAndLockResult	tryFetchAndLock(FetchAndLockRequest request)

Methods inherited from class java.lang.Object

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

Field Detail

LOCK_MONITOR

protected static final ReentrantLock LOCK_MONITOR

IS_EXTERNAL_TASK_AVAILABLE

protected static final Condition IS_EXTERNAL_TASK_AVAILABLE

MAX_BACK_OFF_TIME

protected static final long MAX_BACK_OFF_TIME

See Also:

Constant Field Values

MAX_TIMEOUT

protected static final long MAX_TIMEOUT

See Also:

Constant Field Values

queue

protected BlockingQueue<FetchAndLockRequest> queue

pendingRequests

protected List<FetchAndLockRequest> pendingRequests

handlerThread

protected Thread handlerThread

isWaiting

protected boolean isWaiting

isRunning

protected boolean isRunning

Constructor Detail

FetchAndLockHandlerImpl

public FetchAndLockHandlerImpl()

Method Detail

run

public void run()

Specified by:

run in interface Runnable

acquire

protected void acquire()

start

public void start()

Description copied from interface: FetchAndLockHandler

Receives a notification that the engine rest web application initialization has been started

Specified by:

start in interface FetchAndLockHandler

shutdown

public void shutdown()

Description copied from interface: FetchAndLockHandler

Receives a notification that the engine rest web application is about to be shut down

Specified by:

shutdown in interface FetchAndLockHandler

suspend

protected void suspend(long millis)

suspendAcquisition

protected void suspendAcquisition(long millis)

addRequest

protected void addRequest(FetchAndLockRequest request)

notifyAcquisition

protected void notifyAcquisition()

tryFetchAndLock

protected FetchAndLockResult tryFetchAndLock(FetchAndLockRequest request)

executeFetchAndLock

protected List<LockedExternalTaskDto> executeFetchAndLock(FetchExternalTasksExtendedDto fetchingDto,
                                              ProcessEngine processEngine)

invalidRequest

protected void invalidRequest(javax.ws.rs.container.AsyncResponse asyncResponse,
                  String message)

errorTooManyRequests

protected void errorTooManyRequests(javax.ws.rs.container.AsyncResponse asyncResponse)

rejectPendingRequests

protected void rejectPendingRequests()

addPendingRequest

public void addPendingRequest(FetchExternalTasksExtendedDto dto,
                     javax.ws.rs.container.AsyncResponse asyncResponse,
                     ProcessEngine processEngine)

Description copied from interface: FetchAndLockHandler

Invoked if a fetch and lock request has been sent by the client

Specified by:

addPendingRequest in interface FetchAndLockHandler

Parameters:

dto - which is supposed to hold the payload

asyncResponse - provides means for asynchronous server side response processing

processEngine - provides the process engine context of the respective request

getPendingRequests

public List<FetchAndLockRequest> getPendingRequests()