Package org.camunda.bpm.client.impl

Class ExternalTaskClientImpl

java.lang.Object

org.camunda.bpm.client.impl.ExternalTaskClientImpl

All Implemented Interfaces:

ExternalTaskClient

public class ExternalTaskClientImpl
extends Object
implements ExternalTaskClient

Author:

Tassilo Weidner

Field Summary

Fields

Modifier and Type	Field	Description
protected TopicSubscriptionManager	topicSubscriptionManager

Constructor Summary

Constructors

Constructor	Description
ExternalTaskClientImpl(TopicSubscriptionManager topicSubscriptionManager)

Method Summary

Modifier and Type	Method	Description
TopicSubscriptionManager	getTopicSubscriptionManager()
boolean	isActive()
void	start()	Starts continuous fetching and locking of tasks
void	stop()	Stops continuous fetching and locking of tasks
TopicSubscriptionBuilder	subscribe(String topicName)	Creates a fluent builder to create and configure a topic subscription

Methods inherited from class java.lang.Object

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

Field Details

topicSubscriptionManager

protected TopicSubscriptionManager topicSubscriptionManager

Constructor Details

ExternalTaskClientImpl

public ExternalTaskClientImpl(TopicSubscriptionManager topicSubscriptionManager)

Method Details

subscribe

public TopicSubscriptionBuilder subscribe(String topicName)

Description copied from interface: ExternalTaskClient

Creates a fluent builder to create and configure a topic subscription

Specified by:

subscribe in interface ExternalTaskClient

Parameters:

topicName - the client subscribes to

Returns:

builder to apply configurations on

stop

public void stop()

Description copied from interface: ExternalTaskClient

Stops continuous fetching and locking of tasks

Specified by:

stop in interface ExternalTaskClient

start

public void start()

Description copied from interface: ExternalTaskClient

Starts continuous fetching and locking of tasks

Specified by:

start in interface ExternalTaskClient

isActive

public boolean isActive()

Specified by:

isActive in interface ExternalTaskClient

Returns:

• true if the client is actively fetching for tasks
• false if the client is not actively fetching for tasks

getTopicSubscriptionManager

public TopicSubscriptionManager getTopicSubscriptionManager()