Class SpringTopicSubscriptionImpl

    • Constructor Detail

      • SpringTopicSubscriptionImpl

        public SpringTopicSubscriptionImpl()
    • Method Detail

      • isEventThatCanStartSubscription

        protected java.util.function.Predicate<org.springframework.context.ApplicationEvent> isEventThatCanStartSubscription()
      • start

        @EventListener
        public void start​(org.springframework.context.ApplicationEvent event)
      • initialize

        public void initialize()
      • publishInitializedEvent

        protected void publishInitializedEvent​(java.lang.String topicName)
      • 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()
      • setExternalTaskHandler

        public void setExternalTaskHandler​(ExternalTaskHandler externalTaskHandler)
      • setSubscriptionConfiguration

        public void setSubscriptionConfiguration​(SubscriptionConfiguration subscriptionConfiguration)
      • getTopicName

        public java.lang.String getTopicName()
        Specified by:
        getTopicName in interface TopicSubscription
        Returns:
        the topic name of the subscription
      • getLockDuration

        public java.lang.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
      • getVariableNames

        public java.util.List<java.lang.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 java.lang.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 java.lang.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 java.util.List<java.lang.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 java.lang.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 java.util.List<java.lang.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 java.lang.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 java.util.Map<java.lang.String,​java.lang.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 java.util.List<java.lang.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 java.lang.String[] toArray​(java.util.List<java.lang.String> list)
      • afterPropertiesSet

        public void afterPropertiesSet()
                                throws java.lang.Exception
        Specified by:
        afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean
        Throws:
        java.lang.Exception