Package org.camunda.bpm.client.topic.impl

Class TopicSubscriptionManager

java.lang.Object

org.camunda.bpm.client.topic.impl.TopicSubscriptionManager

All Implemented Interfaces:

Runnable

public class TopicSubscriptionManager
extends Object
implements Runnable

Author:

Tassilo Weidner

Field Summary

Fields

Modifier and Type	Field	Description
protected ReentrantLock	ACQUISITION_MONITOR
protected BackoffStrategy	backoffStrategy
protected long	clientLockDuration
protected EngineClient	engineClient
protected Map<String,ExternalTaskHandler>	externalTaskHandlers
protected ExternalTaskServiceImpl	externalTaskService
protected Condition	IS_WAITING
protected AtomicBoolean	isBackoffStrategyDisabled
protected AtomicBoolean	isRunning
protected static final TopicSubscriptionManagerLogger	LOG
protected CopyOnWriteArrayList<TopicSubscription>	subscriptions
protected List<TopicRequestDto>	taskTopicRequests
protected Thread	thread
protected TypedValues	typedValues

Constructor Summary

Constructors

Constructor	Description
TopicSubscriptionManager(EngineClient engineClient, TypedValues typedValues, long clientLockDuration)

Method Summary

Modifier and Type	Method	Description
protected void	acquire()
void	disableBackoffStrategy()
protected FetchAndLockResponseDto	fetchAndLock(List<TopicRequestDto> subscriptions)
EngineClient	getEngineClient()
List<TopicSubscription>	getSubscriptions()
protected void	handleExternalTask(ExternalTask externalTask, ExternalTaskHandler taskHandler)
boolean	isRunning()
protected void	prepareAcquisition(TopicSubscription subscription)
protected void	resume()
void	run()
protected void	runBackoffStrategy(FetchAndLockResponseDto fetchAndLockResponse)
void	setBackoffStrategy(BackoffStrategy backOffStrategy)
void	start()
void	stop()
protected void	subscribe(TopicSubscription subscription)
protected void	suspend(long waitTime)
protected void	unsubscribe(TopicSubscriptionImpl subscription)

Methods inherited from class java.lang.Object

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

Field Details

LOG

protected static final TopicSubscriptionManagerLogger LOG

ACQUISITION_MONITOR

protected ReentrantLock ACQUISITION_MONITOR

IS_WAITING

protected Condition IS_WAITING

isRunning

protected AtomicBoolean isRunning

externalTaskService

protected ExternalTaskServiceImpl externalTaskService

engineClient

protected EngineClient engineClient

subscriptions

protected CopyOnWriteArrayList<TopicSubscription> subscriptions

taskTopicRequests

protected List<TopicRequestDto> taskTopicRequests

externalTaskHandlers

protected Map<String,ExternalTaskHandler> externalTaskHandlers

thread

protected Thread thread

backoffStrategy

protected BackoffStrategy backoffStrategy

isBackoffStrategyDisabled

protected AtomicBoolean isBackoffStrategyDisabled

typedValues

protected TypedValues typedValues

clientLockDuration

protected long clientLockDuration

Constructor Details

TopicSubscriptionManager

public TopicSubscriptionManager(EngineClient engineClient,
 TypedValues typedValues,
 long clientLockDuration)

Method Details

run

public void run()

Specified by:

run in interface Runnable

acquire

protected void acquire()

prepareAcquisition

protected void prepareAcquisition(TopicSubscription subscription)

fetchAndLock

protected FetchAndLockResponseDto fetchAndLock(List<TopicRequestDto> subscriptions)

handleExternalTask

protected void handleExternalTask(ExternalTask externalTask,
 ExternalTaskHandler taskHandler)

stop

public void stop()

start

public void start()

subscribe

protected void subscribe(TopicSubscription subscription)

unsubscribe

protected void unsubscribe(TopicSubscriptionImpl subscription)

getEngineClient

public EngineClient getEngineClient()

getSubscriptions

public List<TopicSubscription> getSubscriptions()

isRunning

public boolean isRunning()

setBackoffStrategy

public void setBackoffStrategy(BackoffStrategy backOffStrategy)

runBackoffStrategy

protected void runBackoffStrategy(FetchAndLockResponseDto fetchAndLockResponse)

suspend

protected void suspend(long waitTime)

resume

protected void resume()

disableBackoffStrategy

public void disableBackoffStrategy()