java.lang.Object
- org.camunda.bpm.client.spring.impl.subscription.SpringTopicSubscriptionImpl

All Implemented Interfaces:

SpringTopicSubscription, TopicSubscription, org.springframework.beans.factory.InitializingBean

Direct Known Subclasses:

PropertiesAwareSpringTopicSubscription
```
public class SpringTopicSubscriptionImpl
extends Object
implements SpringTopicSubscription, org.springframework.beans.factory.InitializingBean
```

Field Summary

Fields
Modifier and Type	Field	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 Summary

Constructors
Constructor Description

SpringTopicSubscriptionImpl()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`afterPropertiesSet()`
`void`	`close()`	Delegates to `TopicSubscription.close()`.
`void`	`closeInternally()`
`String`	`getBusinessKey()`
`ExternalTaskHandler`	`getExternalTaskHandler()`
`Long`	`getLockDuration()`
`String`	`getProcessDefinitionId()`
`List<String>`	`getProcessDefinitionIdIn()`
`String`	`getProcessDefinitionKey()`
`List<String>`	`getProcessDefinitionKeyIn()`
`String`	`getProcessDefinitionVersionTag()`
`Map<String,Object>`	`getProcessVariables()`
`SubscriptionConfiguration`	`getSubscriptionConfiguration()`
`List<String>`	`getTenantIdIn()`
`String`	`getTopicName()`
`List<String>`	`getVariableNames()`
`void`	`initialize()`
`boolean`	`isAutoOpen()`
`protected Predicate<org.springframework.context.ApplicationEvent>`	`isEventThatCanStartSubscription()`
`boolean`	`isIncludeExtensionProperties()`
`boolean`	`isLocalVariables()`
`boolean`	`isOpen()`
`boolean`	`isWithoutTenantId()`
`void`	`open()`	Releases the topic subscription for asynchronous execution when `SpringTopicSubscription.isAutoOpen()` is `false`
`protected void`	`publishInitializedEvent(String topicName)`
`void`	`setExternalTaskHandler(ExternalTaskHandler externalTaskHandler)`
`void`	`setSubscriptionConfiguration(SubscriptionConfiguration subscriptionConfiguration)`
`void`	`start(org.springframework.context.ApplicationEvent event)`
`protected String[]`	`toArray(List<String> list)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - LOG
```
protected static final SubscriptionLoggerUtil LOG
```
  - subscriptionConfiguration
```
protected SubscriptionConfiguration subscriptionConfiguration
```
  - externalTaskHandler
```
protected ExternalTaskHandler externalTaskHandler
```
  - topicSubscriptionBuilder
```
protected TopicSubscriptionBuilder topicSubscriptionBuilder
```
  - topicSubscription
```
protected TopicSubscription topicSubscription
```
  - client
```
@Autowired
protected ExternalTaskClient client
```
  - applicationEventPublisher
```
@Autowired
protected org.springframework.context.ApplicationEventPublisher applicationEventPublisher
```
- Constructor Detail
  - SpringTopicSubscriptionImpl
```
public SpringTopicSubscriptionImpl()
```
- Method Detail
  - isEventThatCanStartSubscription
```
protected Predicate<org.springframework.context.ApplicationEvent> isEventThatCanStartSubscription()
```
  - start
```
@EventListener
public void start(org.springframework.context.ApplicationEvent event)
```
  - initialize
```
public void initialize()
```
  - publishInitializedEvent
```
protected void publishInitializedEvent(String topicName)
```
  - open
```
public void open()
```
    Description copied from interface: SpringTopicSubscription
    
    Releases the topic subscription for asynchronous execution when SpringTopicSubscription.isAutoOpen() is false
    
    Specified by:
    
    open in interface SpringTopicSubscription
  - isOpen
```
public boolean isOpen()
```
    Specified by:
    
    isOpen in interface SpringTopicSubscription
    
    Returns:
    
    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 execution
  - closeInternally
```
public void closeInternally()
```
  - close
```
public void close()
```
    Description copied from interface: SpringTopicSubscription
    
    Delegates to TopicSubscription.close().
    
    Specified by:
    
    close in interface SpringTopicSubscription
    
    Specified by:
    
    close in interface TopicSubscription
    
    See Also:
    
    TopicSubscription.close()
  - isAutoOpen
```
public boolean isAutoOpen()
```
    Specified by:
    
    isAutoOpen in interface SpringTopicSubscription
    
    Returns:
    
    true when the topic subscription is automatically released for execution
    false when you need to call SpringTopicSubscription.open() to release the topic for execution
  - setExternalTaskHandler
```
public void setExternalTaskHandler(ExternalTaskHandler externalTaskHandler)
```
  - getSubscriptionConfiguration
```
public SubscriptionConfiguration getSubscriptionConfiguration()
```
  - setSubscriptionConfiguration
```
public void setSubscriptionConfiguration(SubscriptionConfiguration subscriptionConfiguration)
```
  - getTopicName
```
public String getTopicName()
```
    Specified by:
    
    getTopicName in interface TopicSubscription
    
    Returns:
    
    the topic name of the subscription
  - getLockDuration
```
public Long getLockDuration()
```
    Specified by:
    
    getLockDuration in interface TopicSubscription
    
    Returns:
    
    the duration of the lock applied to the topic
    if null, the client or the default lock duration is applied
  - getExternalTaskHandler
```
public ExternalTaskHandler getExternalTaskHandler()
```
    Specified by:
    
    getExternalTaskHandler in interface TopicSubscription
    
    Returns:
    
    the external task handler of the topic
  - getVariableNames
```
public List<String> getVariableNames()
```
    Specified by:
    
    getVariableNames in interface TopicSubscription
    
    Returns:
    
    a list of variable names which are supposed to be retrieved
  - isLocalVariables
```
public boolean isLocalVariables()
```
    Specified by:
    
    isLocalVariables in interface TopicSubscription
    
    Returns:
    
    whether or not variables from greater scopes than the external task are fetched. 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.
  - getBusinessKey
```
public String getBusinessKey()
```
    Specified by:
    
    getBusinessKey in interface TopicSubscription
    
    Returns:
    
    the business key associated with the external tasks which are supposed to be fetched and locked
  - getProcessDefinitionId
```
public String getProcessDefinitionId()
```
    Specified by:
    
    getProcessDefinitionId in interface TopicSubscription
    
    Returns:
    
    the process definition id associated with the external tasks which are supposed to be fetched and locked
  - getProcessDefinitionIdIn
```
public List<String> getProcessDefinitionIdIn()
```
    Specified by:
    
    getProcessDefinitionIdIn in interface TopicSubscription
    
    Returns:
    
    the process definition ids associated with the external tasks which are supposed to be fetched and locked
  - getProcessDefinitionKey
```
public String getProcessDefinitionKey()
```
    Specified by:
    
    getProcessDefinitionKey in interface TopicSubscription
    
    Returns:
    
    the process definition key associated with the external tasks which are supposed to be fetched and locked
  - getProcessDefinitionKeyIn
```
public List<String> getProcessDefinitionKeyIn()
```
    Specified by:
    
    getProcessDefinitionKeyIn in interface TopicSubscription
    
    Returns:
    
    the process definition keys associated with the external tasks which are supposed to be fetched and locked
  - getProcessDefinitionVersionTag
```
public String getProcessDefinitionVersionTag()
```
    Specified by:
    
    getProcessDefinitionVersionTag in interface TopicSubscription
    
    Returns:
    
    the process definition version tag associated with the external task which are supposed to be fetched and locked
  - getProcessVariables
```
public Map<String,Object> getProcessVariables()
```
    Specified by:
    
    getProcessVariables in interface TopicSubscription
    
    Returns:
    
    the process variables associated with the external task which are supposed to be fetched and locked
  - isWithoutTenantId
```
public boolean isWithoutTenantId()
```
    Specified by:
    
    isWithoutTenantId in interface TopicSubscription
    
    Returns:
    
    the tenant id presence for the external tasks which are supposed to be fetched and locked
  - getTenantIdIn
```
public List<String> getTenantIdIn()
```
    Specified by:
    
    getTenantIdIn in interface TopicSubscription
    
    Returns:
    
    the tenant ids associated with the external tasks which are supposed to be fetched and locked
  - isIncludeExtensionProperties
```
public boolean isIncludeExtensionProperties()
```
    Specified by:
    
    isIncludeExtensionProperties in interface TopicSubscription
    
    Returns:
    
    whether or not custom extension properties defined in the external task activity are included. The default is 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.
  - toArray
```
protected String[] toArray(List<String> list)
```
  - afterPropertiesSet
```
public void afterPropertiesSet()
                        throws Exception
```
    Specified by:
    
    afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean
    
    Throws:
    
    Exception

Class SpringTopicSubscriptionImpl

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

LOG

subscriptionConfiguration

externalTaskHandler

topicSubscriptionBuilder

topicSubscription

client

applicationEventPublisher

Constructor Detail

SpringTopicSubscriptionImpl

Method Detail

isEventThatCanStartSubscription

start

initialize

publishInitializedEvent

open

isOpen

closeInternally

close

isAutoOpen

setExternalTaskHandler

getSubscriptionConfiguration

setSubscriptionConfiguration

getTopicName

getLockDuration

getExternalTaskHandler

getVariableNames

isLocalVariables

getBusinessKey

getProcessDefinitionId

getProcessDefinitionIdIn

getProcessDefinitionKey

getProcessDefinitionKeyIn

getProcessDefinitionVersionTag

getProcessVariables

isWithoutTenantId

getTenantIdIn

isIncludeExtensionProperties

toArray

afterPropertiesSet