public class ExternalTaskClientImpl extends Object implements ExternalTaskClient
Modifier and Type | Field and Description |
---|---|
protected TopicSubscriptionManager |
topicSubscriptionManager |
Constructor and Description |
---|
ExternalTaskClientImpl(TopicSubscriptionManager topicSubscriptionManager) |
Modifier and Type | Method and 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
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
create
protected TopicSubscriptionManager topicSubscriptionManager
public ExternalTaskClientImpl(TopicSubscriptionManager topicSubscriptionManager)
public TopicSubscriptionBuilder subscribe(String topicName)
ExternalTaskClient
subscribe
in interface ExternalTaskClient
topicName
- the client subscribes topublic void stop()
ExternalTaskClient
stop
in interface ExternalTaskClient
public void start()
ExternalTaskClient
start
in interface ExternalTaskClient
public boolean isActive()
isActive
in interface ExternalTaskClient
true
if the client is actively fetching for tasks
false
if the client is not actively fetching for tasks
public TopicSubscriptionManager getTopicSubscriptionManager()
Copyright © 2022. All rights reserved.