public class SpringTopicSubscriptionImpl extends Object implements SpringTopicSubscription, org.springframework.beans.factory.InitializingBean
Modifier and Type | Field and Description |
---|---|
protected org.springframework.context.ApplicationEventPublisher |
applicationEventPublisher |
protected ExternalTaskClient |
client |
protected ExternalTaskHandler |
externalTaskHandler |
protected static SubscriptionLoggerUtil |
LOG |
protected SubscriptionConfiguration |
subscriptionConfiguration |
protected TopicSubscription |
topicSubscription |
protected TopicSubscriptionBuilder |
topicSubscriptionBuilder |
Constructor and Description |
---|
SpringTopicSubscriptionImpl() |
protected static final SubscriptionLoggerUtil LOG
protected SubscriptionConfiguration subscriptionConfiguration
protected ExternalTaskHandler externalTaskHandler
protected TopicSubscriptionBuilder topicSubscriptionBuilder
protected TopicSubscription topicSubscription
@Autowired protected ExternalTaskClient client
@Autowired protected org.springframework.context.ApplicationEventPublisher applicationEventPublisher
protected java.util.function.Predicate<org.springframework.context.ApplicationEvent> isEventThatCanStartSubscription()
@EventListener public void start(org.springframework.context.ApplicationEvent event)
public void initialize()
protected void publishInitializedEvent(String topicName)
public void open()
SpringTopicSubscription
SpringTopicSubscription.isAutoOpen()
is
false
open
in interface SpringTopicSubscription
public boolean isOpen()
isOpen
in interface SpringTopicSubscription
true
when the topic subscription is already released for execution
false
when the topic subscription is not already released for execution;
call SpringTopicSubscription.open()
to release the topic for executionpublic void closeInternally()
public void close()
SpringTopicSubscription
TopicSubscription.close()
.close
in interface SpringTopicSubscription
close
in interface TopicSubscription
TopicSubscription.close()
public boolean isAutoOpen()
isAutoOpen
in interface SpringTopicSubscription
true
when the topic subscription is automatically released for execution
false
when you need to call SpringTopicSubscription.open()
to release the topic for executionpublic void setExternalTaskHandler(ExternalTaskHandler externalTaskHandler)
public SubscriptionConfiguration getSubscriptionConfiguration()
public void setSubscriptionConfiguration(SubscriptionConfiguration subscriptionConfiguration)
public String getTopicName()
getTopicName
in interface TopicSubscription
public Long getLockDuration()
getLockDuration
in interface TopicSubscription
null
, the client or the default lock duration is applied
public ExternalTaskHandler getExternalTaskHandler()
getExternalTaskHandler
in interface TopicSubscription
public List<String> getVariableNames()
getVariableNames
in interface TopicSubscription
public boolean isLocalVariables()
isLocalVariables
in interface TopicSubscription
false
means all variables visible in the
scope of the external task will be fetched, true
means
only local variables (to the scope of the external task) will be
fetched.public String getBusinessKey()
getBusinessKey
in interface TopicSubscription
public String getProcessDefinitionId()
getProcessDefinitionId
in interface TopicSubscription
public List<String> getProcessDefinitionIdIn()
getProcessDefinitionIdIn
in interface TopicSubscription
public String getProcessDefinitionKey()
getProcessDefinitionKey
in interface TopicSubscription
public List<String> getProcessDefinitionKeyIn()
getProcessDefinitionKeyIn
in interface TopicSubscription
public String getProcessDefinitionVersionTag()
getProcessDefinitionVersionTag
in interface TopicSubscription
public Map<String,Object> getProcessVariables()
getProcessVariables
in interface TopicSubscription
public boolean isWithoutTenantId()
isWithoutTenantId
in interface TopicSubscription
public List<String> getTenantIdIn()
getTenantIdIn
in interface TopicSubscription
public boolean isIncludeExtensionProperties()
isIncludeExtensionProperties
in interface TopicSubscription
false
,
which means that no extension properties will be available within
the external-task-client. true
means that all defined
extension properties are fetched and provided.Copyright © 2022. All rights reserved.