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, waitcreateprotected TopicSubscriptionManager topicSubscriptionManager
public ExternalTaskClientImpl(TopicSubscriptionManager topicSubscriptionManager)
public TopicSubscriptionBuilder subscribe(String topicName)
ExternalTaskClientsubscribe in interface ExternalTaskClienttopicName - the client subscribes topublic void stop()
ExternalTaskClientstop in interface ExternalTaskClientpublic void start()
ExternalTaskClientstart in interface ExternalTaskClientpublic boolean isActive()
isActive in interface ExternalTaskClienttrue 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.